messages cleanup

veilid-core/src/network_manager/mod.rs

@@ -980,8 +980,9 @@ impl NetworkManager {
         if let Some(tsbehind) = tsbehind {
             if tsbehind.as_u64() != 0 && (ts > ets && ts.saturating_sub(ets) > tsbehind) {
                 log_net!(debug
-                    "envelope time was too far in the past: {}ms ",
+                    "Timestamp behind: {}ms ({})",
-                    timestamp_to_secs(ts.saturating_sub(ets).as_u64()) * 1000f64
+                    timestamp_to_secs(ts.saturating_sub(ets).as_u64()) * 1000f64,
+                    connection_descriptor.remote()
                 );
                 return Ok(false);
             }
@@ -989,8 +990,9 @@ impl NetworkManager {
         if let Some(tsahead) = tsahead {
             if tsahead.as_u64() != 0 && (ts < ets && ets.saturating_sub(ts) > tsahead) {
                 log_net!(debug
-                    "envelope time was too far in the future: {}ms",
+                    "Timestamp ahead: {}ms ({})",
-                    timestamp_to_secs(ets.saturating_sub(ts).as_u64()) * 1000f64
+                    timestamp_to_secs(ets.saturating_sub(ts).as_u64()) * 1000f64,
+                    connection_descriptor.remote()
                 );
                 return Ok(false);
             }

veilid-core/src/network_manager/native/protocol/tcp.rs

@@ -143,7 +143,7 @@ impl RawTcpProtocolHandler {
             ps,
         ));
 
-        log_net!(debug "TCP: on_accept_async from: {}", socket_addr);
+        log_net!(debug "Connection accepted from: {} (TCP)", socket_addr);
 
         Ok(Some(conn))
     }

veilid-core/src/network_manager/native/protocol/ws.rs

@@ -212,7 +212,7 @@ impl WebsocketProtocolHandler {
             ws_stream,
         ));
 
-        log_net!(debug "{}: on_accept_async from: {}", if self.arc.tls { "WSS" } else { "WS" }, socket_addr);
+        log_net!(debug "Connection accepted from: {} ({})", socket_addr, if self.arc.tls { "WSS" } else { "WS" });
 
         Ok(Some(conn))
     }

veilid-core/src/network_manager/network_connection.rs

@@ -300,7 +300,11 @@ impl NetworkConnection {
                         .then(|res| async {
                             match res {
                                 Ok(v) => {
-                                    
+                                    if v.is_no_connection() {
+                                        let peer_address = protocol_connection.descriptor().remote();
+                                        log_net!(debug "Connection closed from: {} ({})", peer_address.socket_address().to_socket_addr(), peer_address.protocol_type());
+                                        return RecvLoopAction::Finish;
+                                    }
                                     let mut message = network_result_value_or_log!(v => {
                                         return RecvLoopAction::Finish;
                                     });