Skip to content

Commit d50a6c9

Browse files
committed
Fix crash if control stream never connects
1 parent 054140a commit d50a6c9

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/stream.cpp

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -764,7 +764,10 @@ void controlBroadcastThread(control_server_t *server) {
764764
if(session->state.load(std::memory_order_acquire) == session::state_e::STOPPING) {
765765
pos = server->_map_addr_session->erase(pos);
766766

767-
enet_peer_disconnect_now(session->control.peer, 0);
767+
if(session->control.peer) {
768+
enet_peer_disconnect_now(session->control.peer, 0);
769+
}
770+
768771
session->controlEnd.raise(true);
769772
continue;
770773
}

0 commit comments

Comments
 (0)