client pool -> peer set

Author: Boog900

Cargo.lock

@@ -2,7 +2,7 @@
 resolver = "2"
 
 members = [
-	"binaries/cuprated",
+	#"binaries/cuprated",
 	"constants",
 	"consensus",
 	"consensus/context",

Cargo.toml

@@ -29,9 +29,9 @@ mod request_handler;
 mod timeout_monitor;
 mod weak;
 
-use crate::client::weak::WeakClient;
 pub use connector::{ConnectRequest, Connector};
 pub use handshaker::{DoHandshakeRequest, HandshakeError, HandshakerBuilder};
+pub use weak::WeakClient;
 
 /// An internal identifier for a given peer, will be their address if known
 /// or a random u128 if not.
@@ -131,6 +131,12 @@ impl<Z: NetworkZone> Client<Z> {
         .into()
     }
 
+    pub fn alive(&self) -> bool {
+        !(self.error.try_get_err().is_some()
+            || self.connection_handle.is_finished()
+            || self.timeout_handle.is_finished())
+    }
+
     pub fn downgrade(&self) -> WeakClient<Z> {
         WeakClient {
             info: self.info.clone(),

p2p/p2p-core/src/client.rs

@@ -21,11 +21,10 @@ monero-serai = { workspace = true, features = ["std"] }
 tower = { workspace = true, features = ["buffer"] }
 tokio = { workspace = true, features = ["rt", "rt-multi-thread"] }
 rayon = { workspace = true }
-tokio-util = { workspace = true }
 tokio-stream = { workspace = true, features = ["sync", "time"] }
 futures = { workspace = true, features = ["std"] }
 pin-project = { workspace = true }
-dashmap = { workspace = true }
+indexmap = { workspace = true }
 
 thiserror = { workspace = true }
 bytes = { workspace = true, features = ["std"] }