| 1098 | } |
| 1099 | |
| 1100 | void HTTPServer::ClearConnectedClients() |
| 1101 | { |
| 1102 | Assume(!m_thread_socket_handler.joinable()); // must be called after JoinSocketsThreads() |
| 1103 | if (m_connected.empty()) return; |
| 1104 | LogWarning("Force-disconnecting %d HTTP client(s) that did not disconnect gracefully", m_connected.size()); |
| 1105 | m_connected_size.fetch_sub(m_connected.size(), std::memory_order_relaxed); |
| 1106 | m_connected.clear(); |
| 1107 | } |
| 1108 | |
| 1109 | bool HTTPRemoteClient::ReadRequest(HTTPRequest& req) |
| 1110 | { |
no test coverage detected