@@ -86,11 +86,11 @@ void WebSocketServer::OnOpen(ix::WebSocketOpenInfo openInfo, std::shared_ptr<ix:
8686 {
8787 return ;
8888 }
89-
90- {
91- std::lock_guard<std::mutex> lock (m_headersMutex);
92- m_connectionHeaders[connectionState->getId ()] = openInfo.headers ;
93- }
89+
90+ {
91+ std::lock_guard<std::mutex> lock (m_headersMutex);
92+ m_connectionHeaders[connectionState->getId ()] = openInfo.headers ;
93+ }
9494
9595 g_TaskQueue.Push ([this , openInfo, connectionState]()
9696 {
@@ -108,13 +108,13 @@ void WebSocketServer::OnClose(ix::WebSocketCloseInfo closeInfo, std::shared_ptr<
108108 {
109109 return ;
110110 }
111+
112+ std::string connectionId = connectionState->getId ();
111113
112- std::string connectionId = connectionState->getId ();
113-
114- {
115- std::lock_guard<std::mutex> lock (m_headersMutex);
116- m_connectionHeaders.erase (connectionId);
117- }
114+ {
115+ std::lock_guard<std::mutex> lock (m_headersMutex);
116+ m_connectionHeaders.erase (connectionId);
117+ }
118118
119119 g_TaskQueue.Push ([this , closeInfo, connectionState]()
120120 {
@@ -182,13 +182,13 @@ bool WebSocketServer::disconnectClient(const std::string& clientId) {
182182}
183183
184184std::vector<std::string> WebSocketServer::getClientIds () {
185- std::vector<std::string> clientIds;
185+ std::vector<std::string> clientIds;
186186
187- auto clients = m_webSocketServer.getClients ();
187+ auto clients = m_webSocketServer.getClients ();
188188
189- for (const auto & client : clients) {
190- clientIds.push_back (client.second );
191- }
189+ for (const auto & client : clients) {
190+ clientIds.push_back (client.second );
191+ }
192192
193- return clientIds;
193+ return clientIds;
194194}
0 commit comments