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

modified: frida_client/src/client.rs

Browse Source
This commit is contained in:
Michael Wain 2024-12-09 19:14:48 +03:00
parent fb773e2c67
commit 35ae3c42fd
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
frida_client/src/client.rs
View File

@ -24,7 +24,7 @@ pub mod general {
} }
impl CoreVpnClient { impl CoreVpnClient {
pub async fn start(&mut self, sock: UdpSocket, dev_reader: DeviceReader, dev_writer: DeviceWriter) { pub async fn start(&mut self, sock: UdpSocket, dev_reader: DeviceReader, dev_writer: DeviceWriter, mtu: u16) {
info!("Starting client..."); info!("Starting client...");
let dr_cancel: CancellationToken = CancellationToken::new(); let dr_cancel: CancellationToken = CancellationToken::new();
@ -58,7 +58,7 @@ pub mod general {
let mut buf1 = vec![0; 4096]; // should be changed to less bytes let mut buf1 = vec![0; 4096]; // should be changed to less bytes
tokio::spawn(async move { tokio::spawn(async move {
let mut buf = vec![0; 1400]; // mtu let mut buf = vec![0; mtu.into()]; // mtu
loop { loop {
match dev_reader.read(&mut buf).await { match dev_reader.read(&mut buf).await {
Ok(n) => { Ok(n) => {
@ -199,7 +199,6 @@ pub mod desktop {
use frida_core::device::AbstractDevice; use frida_core::device::AbstractDevice;
use log::info; use log::info;
use tokio::net::UdpSocket; use tokio::net::UdpSocket;
use tokio::sync::Mutex;
#[cfg(target_os = "linux")] #[cfg(target_os = "linux")]
use network_interface::{NetworkInterface, NetworkInterfaceConfig}; use network_interface::{NetworkInterface, NetworkInterfaceConfig};
@ -272,10 +271,11 @@ pub mod desktop {
info!("s_interface: {:?}", &self.s_interface); info!("s_interface: {:?}", &self.s_interface);
info!("client_address: {:?}", &self.client_config.client.address); info!("client_address: {:?}", &self.client_config.client.address);
let mut config = AbstractDevice::default(); let mut config = AbstractDevice::default();
let mtu: u16 = 1400;
config.address(self.client_config.client.address.parse().unwrap()) config.address(self.client_config.client.address.parse().unwrap())
.netmask(Ipv4Addr::new(255, 255, 255, 255)) .netmask(Ipv4Addr::new(255, 255, 255, 255))
.destination(Ipv4Addr::new(10, 66, 66, 1)) .destination(Ipv4Addr::new(10, 66, 66, 1))
.mtu(1400) .mtu(mtu)
.tun_name("tun0"); .tun_name("tun0");
info!("SSS: {:?}", &self.client_config.server.endpoint); info!("SSS: {:?}", &self.client_config.server.endpoint);
@ -293,7 +293,7 @@ pub mod desktop {
configure_routes(&s_a.ip().to_string(), self.s_interface.clone()); configure_routes(&s_a.ip().to_string(), self.s_interface.clone());
}*/ }*/
client.start(sock, dev_reader, dev_writer).await; client.start(sock, dev_reader, dev_writer, mtu).await;
} }
} }
} }