diff options
author | Alex <alex@adnab.me> | 2022-09-02 14:22:57 +0200 |
---|---|---|
committer | Alex <alex@adnab.me> | 2022-09-02 14:22:57 +0200 |
commit | a82700c5a27612002e6ee029ae77915b8114182f (patch) | |
tree | 7c79d9d17e1506f1fcddc6163fb27b2570f71113 /src/client.rs | |
parent | 8c73b276557405e5d7eac8139b6f8a79d0379200 (diff) | |
parent | ca25331d7320dddbe8f76c2a74bf406cd0622c2e (diff) | |
download | netapp-a82700c5a27612002e6ee029ae77915b8114182f.tar.gz netapp-a82700c5a27612002e6ee029ae77915b8114182f.zip |
Merge pull request 'Fix ping timeout and interval' (#4) from fix-ping into main
Reviewed-on: https://git.deuxfleurs.fr/lx/netapp/pulls/4
Diffstat (limited to 'src/client.rs')
-rw-r--r-- | src/client.rs | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/client.rs b/src/client.rs index 8227e8f..5c5a05b 100644 --- a/src/client.rs +++ b/src/client.rs @@ -102,13 +102,16 @@ impl ClientConn { netapp.connected_as_client(peer_id, conn.clone()); + let debug_name = format!("CLI {}", hex::encode(&peer_id[..8])); + tokio::spawn(async move { - let send_future = tokio::spawn(conn.clone().send_loop(query_recv, write)); + let debug_name_2 = debug_name.clone(); + let send_future = tokio::spawn(conn.clone().send_loop(query_recv, write, debug_name_2)); let conn2 = conn.clone(); let recv_future = tokio::spawn(async move { select! { - r = conn2.recv_loop(read) => r, + r = conn2.recv_loop(read, debug_name) => r, _ = await_exit(stop_recv_loop_recv) => Ok(()) } }); |