|
@ -156,7 +156,7 @@ where |
|
|
match pkt_receiver.recv_pkts().await {
|
|
|
match pkt_receiver.recv_pkts().await {
|
|
|
Ok(pkts) => {
|
|
|
Ok(pkts) => {
|
|
|
for pkt in pkts {
|
|
|
for pkt in pkts {
|
|
|
trace!("[recv from {:?}] {:?}", client_id, pkt);
|
|
|
|
|
|
|
|
|
info!("[recv from {:?}] {:?}", client_id, pkt);
|
|
|
server_sender.send(ClientAction::Packet(client_id, pkt)).await.unwrap();
|
|
|
server_sender.send(ClientAction::Packet(client_id, pkt)).await.unwrap();
|
|
|
}
|
|
|
}
|
|
|
},
|
|
|
},
|
|
@ -194,7 +194,7 @@ where |
|
|
*cipher_out.lock().await = outc;
|
|
|
*cipher_out.lock().await = outc;
|
|
|
}
|
|
|
}
|
|
|
ServerStateAction::Packet(pkt) => {
|
|
|
ServerStateAction::Packet(pkt) => {
|
|
|
trace!("[send to {:?}] {:?}", client_id, pkt);
|
|
|
|
|
|
|
|
|
info!("[send to {:?}] {:?}", client_id, pkt);
|
|
|
if let Err(err) = send_pkt(socket.clone(), cipher_out.clone(), pkt).await {
|
|
|
if let Err(err) = send_pkt(socket.clone(), cipher_out.clone(), pkt).await {
|
|
|
warn!("[client {:?} send error ] {:?}", client_id, err);
|
|
|
warn!("[client {:?} send error ] {:?}", client_id, err);
|
|
|
}
|
|
|
}
|
|
|