diff options
Diffstat (limited to 'src/netapp.rs')
| -rw-r--r-- | src/netapp.rs | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/netapp.rs b/src/netapp.rs index a7a3acf..8c0b50c 100644 --- a/src/netapp.rs +++ b/src/netapp.rs @@ -243,6 +243,15 @@ impl NetApp { .log_err("Failed to await for connection collector"); } + /// Drop all endpoint handlers + /// + /// Use this when terminating to break reference cycles + pub fn drop_all_handlers(&self) { + for (_, endpoint) in self.endpoints.read().unwrap().iter() { + endpoint.drop_handler(); + } + } + /// Attempt to connect to a peer, given by its ip:port and its public key. /// The public key will be checked during the secret handshake process. /// This function returns once the connection has been established and a |