alterwain/Frida
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Changes to be committed:

Browse Source 
modified:   src/server.rs
This commit is contained in:
Michael Wain 2024-08-26 03:17:18 +03:00
parent fab3d08699
commit 586815114f
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/server.rs
View File

@ -16,14 +16,14 @@ use crate::udp::{UDPKeepAlive, UDPSerializable, UDPVpnHandshake, UDPVpnPacket};
pub async fn server_mode(server_config: ServerConfiguration) { pub async fn server_mode(server_config: ServerConfiguration) {
info!("Starting server..."); info!("Starting server...");
//let mut config = tun2::Configuration::default(); let mut config = tun2::Configuration::default();
//config.address(&server_config.interface.internal_address) config.address(&server_config.interface.internal_address)
// .netmask("255.255.255.0") .netmask("255.255.255.0")
// .tun_name("tun0") .tun_name("tun0")
// .up(); .up();
//let dev = tun2::create(&config).unwrap(); let dev = tun2::create(&config).unwrap();
//let (mut dev_reader, mut dev_writer) = dev.split(); let (mut dev_reader, mut dev_writer) = dev.split();
let sock = UdpSocket::bind(&server_config.interface.bind_address).await.unwrap(); let sock = UdpSocket::bind(&server_config.interface.bind_address).await.unwrap();
let sock_rec = Arc::new(sock); let sock_rec = Arc::new(sock);
@ -36,13 +36,13 @@ pub async fn server_mode(server_config: ServerConfiguration) {
let (send2hnd, recv2hnd) = unbounded::<(Vec<u8>, SocketAddr)>(); let (send2hnd, recv2hnd) = unbounded::<(Vec<u8>, SocketAddr)>();
/* tokio::spawn(async move { tokio::spawn(async move {
loop { loop {
if let Ok(bytes) = recv2tun.recv() { if let Ok(bytes) = recv2tun.recv() {
dev_writer.write_all(&bytes).unwrap(); dev_writer.write_all(&bytes).unwrap();
} }
} }
});*/ });
let keepalive_sec = server_config.interface.keepalive.clone(); let keepalive_sec = server_config.interface.keepalive.clone();
let send2hnd_cl = send2hnd.clone(); let send2hnd_cl = send2hnd.clone();
@ -70,7 +70,7 @@ pub async fn server_mode(server_config: ServerConfiguration) {
}); });
let addrs_cl = addresses.clone(); let addrs_cl = addresses.clone();
/* tokio::spawn(async move { tokio::spawn(async move {
let mut buf = vec![0; 4096]; let mut buf = vec![0; 4096];
while let Ok(n) = dev_reader.read(&mut buf) { while let Ok(n) = dev_reader.read(&mut buf) {
if n <= 19 { continue; } if n <= 19 { continue; }
@ -96,7 +96,7 @@ pub async fn server_mode(server_config: ServerConfiguration) {
} }
drop(mp); drop(mp);
} }
});*/ });
let mut buf = vec![0; 2048]; let mut buf = vec![0; 2048];
let addrs_lp = addresses.clone(); let addrs_lp = addresses.clone();