further improvements to decrease contention on the server

This commit is contained in:
David White 2008-03-11 02:54:38 +00:00
parent 31a3f81875
commit 75effab510

View file

@ -597,10 +597,11 @@ void receive_data(TCPsocket sock)
const threading::lock lock(*management_mutex);
pending_receives.push_back(sock);
sockets_locked.insert(std::pair<TCPsocket,SOCKET_STATE>(sock,SOCKET_READY));
socket_state_map::const_iterator i = sockets_locked.insert(std::pair<TCPsocket,SOCKET_STATE>(sock,SOCKET_READY)).first;
if(i->second == SOCKET_READY || i->second == SOCKET_ERRORED) {
cond->notify_one();
}
}
cond->notify_one();
}
TCPsocket get_received_data(TCPsocket sock, config& cfg)