Changes to be committed:
modified: src/tcp_client.rs modified: src/tcp_server.rs
This commit is contained in:
parent
b1f4021c98
commit
31bc540619
@ -115,7 +115,7 @@ pub async fn client_mode(remote_addr: String) {
|
|||||||
loop {
|
loop {
|
||||||
if let Ok(bytes) = mx.recv() {
|
if let Ok(bytes) = mx.recv() {
|
||||||
let vpn_packet = VpnPacket::init(bytes);
|
let vpn_packet = VpnPacket::init(bytes);
|
||||||
let serialized_data = bincode::serialize(&vpn_packet).unwrap();
|
let serialized_data = bincode::serialize::<VpnPacket>(&vpn_packet).unwrap();
|
||||||
//info!("Writing to sock: {:?}", serialized_data);
|
//info!("Writing to sock: {:?}", serialized_data);
|
||||||
sock_writer.write_all(&serialized_data).await.unwrap();
|
sock_writer.write_all(&serialized_data).await.unwrap();
|
||||||
}
|
}
|
||||||
|
@ -116,7 +116,7 @@ pub async fn server_mode(bind_addr: String) {
|
|||||||
loop {
|
loop {
|
||||||
if let Ok(bytes) = thread_mx.recv() {
|
if let Ok(bytes) = thread_mx.recv() {
|
||||||
let vpn_packet = VpnPacket::init(bytes);
|
let vpn_packet = VpnPacket::init(bytes);
|
||||||
let serialized_data = bincode::serialize(&vpn_packet).unwrap();
|
let serialized_data = bincode::serialize::<VpnPacket>(&vpn_packet).unwrap();
|
||||||
sock_writer.write_all(&serialized_data).await.unwrap();
|
sock_writer.write_all(&serialized_data).await.unwrap();
|
||||||
//info!("Wrote to sock: {:?}", serialized_data);
|
//info!("Wrote to sock: {:?}", serialized_data);
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user