Changes to be committed:
modified: src/tcp_client.rs modified: src/tcp_server.rs
This commit is contained in:
parent
c574360258
commit
ddca6f3441
@ -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::<VpnPacket>(&vpn_packet).unwrap();
|
let serialized_data = bincode::serialize(&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();
|
||||||
}
|
}
|
||||||
|
@ -18,6 +18,7 @@ pub async fn server_mode(bind_addr: String) {
|
|||||||
|
|
||||||
let mut config = tun2::Configuration::default();
|
let mut config = tun2::Configuration::default();
|
||||||
config.address("10.8.0.1");
|
config.address("10.8.0.1");
|
||||||
|
config.netmask("255.255.255.0");
|
||||||
config.tun_name("tun0");
|
config.tun_name("tun0");
|
||||||
config.up();
|
config.up();
|
||||||
|
|
||||||
@ -114,7 +115,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::<VpnPacket>(&vpn_packet).unwrap();
|
let serialized_data = bincode::serialize(&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