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-24 03:14:29 +03:00
parent 267a861ebb
commit faa1086e78
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/server.rs
View File

@ -1,5 +1,5 @@
use crossbeam_channel::unbounded; use crossbeam_channel::unbounded;
use tokio::{net::UdpSocket, sync::Mutex}; use tokio::{net::UdpSocket, sync::Mutex, time};
use x25519_dalek::{PublicKey, StaticSecret}; use x25519_dalek::{PublicKey, StaticSecret};
use std::io::{Read, Write}; use std::io::{Read, Write};
use base64::prelude::*; use base64::prelude::*;
@ -49,11 +49,8 @@ pub async fn server_mode(server_config: ServerConfiguration) {
let addrs_lcl = addresses.clone(); let addrs_lcl = addresses.clone();
if keepalive_sec > 0 { if keepalive_sec > 0 {
tokio::spawn(async move { tokio::spawn(async move {
let mut now = std::time::Instant::now();
let kps = std::time::Duration::from_secs(5);
loop { loop {
if now.elapsed() < kps { continue; } time::sleep(time::Duration::from_secs(3)).await;
now = std::time::Instant::now();
let mut mmp = addrs_lcl.lock().await; let mut mmp = addrs_lcl.lock().await;
mmp.values().for_each(|p| { mmp.values().for_each(|p| {
let _ = send2hnd_cl.send((UDPKeepAlive{}.serialize(), p.addr)); let _ = send2hnd_cl.send((UDPKeepAlive{}.serialize(), p.addr));