Let's use ZRuntime::Reception to handle accept_task

eclipse-zenoh · Feb 1, 2024 · a98aaf2 · a98aaf2
1 parent 052c18c
commit a98aaf2
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 5 deletions.
diff --git a/io/zenoh-links/zenoh-link-quic/src/unicast.rs b/io/zenoh-links/zenoh-link-quic/src/unicast.rs
@@ -435,7 +435,7 @@ impl LinkManagerUnicastTrait for LinkManagerUnicastQuic {
             zasyncwrite!(c_listeners).remove(&c_addr);
             res
         };
-        tracker.spawn_on(task, &zenoh_runtime::ZRuntime::TX);
+        tracker.spawn_on(task, &zenoh_runtime::ZRuntime::Reception);
 
         // Initialize the QuicAcceptor
         let locator = endpoint.to_locator();

diff --git a/io/zenoh-links/zenoh-link-udp/src/unicast.rs b/io/zenoh-links/zenoh-link-udp/src/unicast.rs
@@ -414,7 +414,7 @@ impl LinkManagerUnicastTrait for LinkManagerUnicastUdp {
                         zasyncwrite!(c_listeners).remove(&c_addr);
                         res
                     };
-                    tracker.spawn_on(task, &zenoh_runtime::ZRuntime::TX);
+                    tracker.spawn_on(task, &zenoh_runtime::ZRuntime::Reception);
 
                     let locator = endpoint.to_locator();
                     let listener = ListenerUnicastUdp::new(endpoint, token, tracker);
@@ -612,7 +612,6 @@ async fn accept_read_task(
                         //       tool. In case of systemd-based systems, this can be changed by using the
                         //       "sysctl" command line tool.
                         tokio::time::sleep(Duration::from_micros(*UDP_ACCEPT_THROTTLE_TIME)).await;
-                        continue;
                     }
                 }
             }

diff --git a/io/zenoh-links/zenoh-link-unixsock_stream/src/unicast.rs b/io/zenoh-links/zenoh-link-unixsock_stream/src/unicast.rs
@@ -386,7 +386,7 @@ impl LinkManagerUnicastTrait for LinkManagerUnicastUnixSocketStream {
             zasyncwrite!(c_listeners).remove(&c_path);
             res
         };
-        tracker.spawn_on(task, &zenoh_runtime::ZRuntime::TX);
+        tracker.spawn_on(task, &zenoh_runtime::ZRuntime::Reception);
 
         let locator = endpoint.to_locator();
         let listener = ListenerUnixSocketStream::new(endpoint, token, tracker, lock_fd);

diff --git a/io/zenoh-links/zenoh-link-ws/src/unicast.rs b/io/zenoh-links/zenoh-link-ws/src/unicast.rs
@@ -363,7 +363,7 @@ impl LinkManagerUnicastTrait for LinkManagerUnicastWs {
             zasyncwrite!(c_listeners).remove(&c_addr);
             res
         };
-        tracker.spawn_on(task, &zenoh_runtime::ZRuntime::TX);
+        tracker.spawn_on(task, &zenoh_runtime::ZRuntime::Reception);
 
         let locator = endpoint.to_locator();
         let listener = ListenerUnicastWs::new(endpoint, token, tracker);