|
@ -119,7 +119,7 @@ async fn send_pkt<S: SendServerPacket + Send + std::fmt::Debug>(socket: Arc<asyn |
|
|
-> Result<(), NetworkError>
|
|
|
-> Result<(), NetworkError>
|
|
|
{
|
|
|
{
|
|
|
let buf = pkt.as_bytes();
|
|
|
let buf = pkt.as_bytes();
|
|
|
//println!("sndbuf: {:?}", buf);
|
|
|
|
|
|
|
|
|
trace!("[send buf] {:?}", buf);
|
|
|
let cbuf = cipher.lock().await.encrypt(&buf)?;
|
|
|
let cbuf = cipher.lock().await.encrypt(&buf)?;
|
|
|
let mut ssock = &*socket;
|
|
|
let mut ssock = &*socket;
|
|
|
ssock.write_all(&cbuf).await?;
|
|
|
ssock.write_all(&cbuf).await?;
|
|
|