File tree 3 files changed +10
-6
lines changed
3 files changed +10
-6
lines changed Original file line number Diff line number Diff line change @@ -342,7 +342,7 @@ impl TransportLinkMulticastUniversal {
342
342
)
343
343
. await ;
344
344
if let Err ( e) = res {
345
- tracing:: debug!( "{}" , e) ;
345
+ tracing:: debug!( "TX task failed: {}" , e) ;
346
346
// Spawn a task to avoid a deadlock waiting for this same task
347
347
// to finish in the close() joining its handle
348
348
zenoh_runtime:: ZRuntime :: Net . spawn ( async move { c_transport. delete ( ) . await } ) ;
@@ -378,7 +378,7 @@ impl TransportLinkMulticastUniversal {
378
378
. await ;
379
379
c_signal. trigger ( ) ;
380
380
if let Err ( e) = res {
381
- tracing:: debug!( "{}" , e) ;
381
+ tracing:: debug!( "RX task failed: {}" , e) ;
382
382
// Spawn a task to avoid a deadlock waiting for this same task
383
383
// to finish in the close() joining its handle
384
384
zenoh_runtime:: ZRuntime :: Net . spawn ( async move { c_transport. delete ( ) . await } ) ;
Original file line number Diff line number Diff line change @@ -746,13 +746,17 @@ impl TransportManager {
746
746
let c_manager = self . clone ( ) ;
747
747
self . task_controller
748
748
. spawn_with_rt ( zenoh_runtime:: ZRuntime :: Acceptor , async move {
749
- if let Err ( e ) = tokio:: time:: timeout (
749
+ if tokio:: time:: timeout (
750
750
c_manager. config . unicast . accept_timeout ,
751
751
super :: establishment:: accept:: accept_link ( link, & c_manager) ,
752
752
)
753
753
. await
754
+ . is_err ( )
754
755
{
755
- tracing:: debug!( "{}" , e) ;
756
+ tracing:: debug!(
757
+ "Failed to accept link before deadline ({}ms)" ,
758
+ c_manager. config. unicast. accept_timeout. as_millis( )
759
+ ) ;
756
760
}
757
761
incoming_counter. fetch_sub ( 1 , SeqCst ) ;
758
762
} ) ;
Original file line number Diff line number Diff line change @@ -97,7 +97,7 @@ impl TransportLinkUnicastUniversal {
97
97
. await ;
98
98
99
99
if let Err ( e) = res {
100
- tracing:: debug!( "{}" , e) ;
100
+ tracing:: debug!( "TX task failed: {}" , e) ;
101
101
// Spawn a task to avoid a deadlock waiting for this same task
102
102
// to finish in the close() joining its handle
103
103
// TODO(yuyuan): do more study to check which ZRuntime should be used or refine the
@@ -125,7 +125,7 @@ impl TransportLinkUnicastUniversal {
125
125
126
126
// TODO(yuyuan): improve this callback
127
127
if let Err ( e) = res {
128
- tracing:: debug!( "{}" , e) ;
128
+ tracing:: debug!( "RX task failed: {}" , e) ;
129
129
130
130
// Spawn a task to avoid a deadlock waiting for this same task
131
131
// to finish in the close() joining its handle
You can’t perform that action at this time.
0 commit comments