modified: src/client.rs
All checks were successful
gitea/Frida-android-native/pipeline/head This commit looks good

This commit is contained in:
Michael Wain 2024-10-12 17:29:20 +03:00
parent 88aafc15d9
commit b8e5a96e60

View File

@ -25,7 +25,7 @@ use robusta_jni::jni::JNIEnv;
use crate::jni::FridaLib;
pub async fn client_mode(client_config: ClientConfiguration, fd: i32, env: &JNIEnv<'_>, close_token: CancellationToken) {
let (ltx, lrx) = mpsc::unbounded_channel::<Vec<u8>>();
let (ltx, mut lrx) = mpsc::unbounded_channel::<Vec<u8>>();
ltx.send("Starting client...".as_bytes().to_vec());
let sock = UdpSocket::bind("0.0.0.0:25565").await.unwrap();
@ -41,8 +41,8 @@ pub async fn client_mode(client_config: ClientConfiguration, fd: i32, env: &JNIE
let sock_rec = Arc::new(sock);
let sock_snd = sock_rec.clone();
let (tx, rx) = mpsc::unbounded_channel::<Vec<u8>>();
let (dx, mx) = mpsc::unbounded_channel::<Vec<u8>>();
let (tx, mut rx) = mpsc::unbounded_channel::<Vec<u8>>();
let (dx, mut mx) = mpsc::unbounded_channel::<Vec<u8>>();
let cipher_shared: Arc<Mutex<Option<x25519_dalek::SharedSecret>>> = Arc::new(Mutex::new(None));