diff --git a/src/connection/manager.rs b/src/connection/manager.rs index e0c13dd..8024b1b 100644 --- a/src/connection/manager.rs +++ b/src/connection/manager.rs @@ -27,7 +27,6 @@ type Connection = Arc>>; static CONNECTED: AtomicBool = ATOMIC_BOOL_INIT; static STARTED: AtomicBool = ATOMIC_BOOL_INIT; static HANDSHAKED: AtomicBool = ATOMIC_BOOL_INIT; -static HANDSHAKING: AtomicBool = ATOMIC_BOOL_INIT; pub struct Manager { send_channel: SyncSender, @@ -112,7 +111,7 @@ impl Manager { } fn handshake(connection: Connection, client_id: u64) -> Result<()> { - if CONNECTED.load(Ordering::SeqCst) && !HANDSHAKED.load(Ordering::SeqCst) && !HANDSHAKING.load(Ordering::SeqCst) { + if CONNECTED.load(Ordering::SeqCst) && !HANDSHAKED.load(Ordering::SeqCst) { let hs = json![{ "client_id": client_id.to_string(), "v": 1,