We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 054140a commit d50a6c9Copy full SHA for d50a6c9
src/stream.cpp
@@ -764,7 +764,10 @@ void controlBroadcastThread(control_server_t *server) {
764
if(session->state.load(std::memory_order_acquire) == session::state_e::STOPPING) {
765
pos = server->_map_addr_session->erase(pos);
766
767
- enet_peer_disconnect_now(session->control.peer, 0);
+ if(session->control.peer) {
768
+ enet_peer_disconnect_now(session->control.peer, 0);
769
+ }
770
+
771
session->controlEnd.raise(true);
772
continue;
773
}
0 commit comments