Do not spawn new tasks per packet.

Instead, rely on the channel to rate limit and limit memory usage.
zlogic · Nov 30, 2024 · b0a9d28 · b0a9d28
1 parent a995408
commit b0a9d28
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/src/ikev2/mod.rs b/src/ikev2/mod.rs
@@ -1041,9 +1041,7 @@ impl FortiService {
                             }
                         };
                         if !data.is_empty() {
-                            let rt = runtime::Handle::current();
-                            let tx = sessions_tx.clone();
-                            rt.spawn(async move { tx.send(SessionMessage::VpnPacket(data)).await });
+                            let _ = sessions_tx.send(SessionMessage::VpnPacket(data)).await;
                         }
                     }
                     FortiServiceCommand::SendEcho => {
@@ -1109,9 +1107,7 @@ impl FortiService {
 
     async fn send_packet(&self, data: Vec<u8>) -> Result<(), IKEv2Error> {
         if let Some(tx) = self.command_sender.as_ref() {
-            let rt = runtime::Handle::current();
-            let tx = tx.clone();
-            rt.spawn(async move { tx.send(FortiServiceCommand::SendPacket(data)).await });
+            let _ = tx.send(FortiServiceCommand::SendPacket(data)).await;
             Ok(())
         } else {
             Err("VPN client service is not running".into())