ssize_t size = read(sock, &event.rawBuffer[0], 4096);
if (size == 0) {
+ LogDebug("Reading returned 0 bytes, closing socket: " << sock);
CloseSocket(sock);
} else if (size >= 0) {
event.rawBuffer.resize(size);
// and connection is open. Time to close it!
// Putting new timeout in queue here is pointless.
desc.isTimeout = false;
+ LogWarning("Closing socket because of timeout: " << pqTimeout.sock);
CloseSocket(pqTimeout.sock);
// All done. Now we should process next select ;-)
auto &desc = m_socketDescriptionVector[buffer.connectionID.sock];
if (!desc.isOpen) {
- LogError("Received packet for write but connection is closed. Packet ignored!");
+ LogError("Received packet for write but connection is closed. Packet ignored! Socket: "
+ << buffer.connectionID.sock);
continue;
}
if (desc.counter != buffer.connectionID.counter)
{
- LogError("Received packet for write but counter is broken. Packet ignored!");
+ LogError("Received packet for write but counter is broken. Packet ignored! Socket: "
+ << buffer.connectionID.sock);
continue;
}
if (desc.useSendMsg) {
- LogError("Some service tried to push rawdata to socket that usees sendmsg!");
+ LogError("Some service tried to push rawdata to socket that usees sendmsg! Socket: "
+ << buffer.connectionID.sock);
continue;
}
auto &desc = m_socketDescriptionVector[data.connectionID.sock];
if (!desc.isOpen) {
- LogDebug("Received packet for sendmsg but connection is closed. Packet ignored!");
+ LogDebug("Received packet for sendmsg but connection is closed. Packet ignored! Socket: "
+ << data.connectionID.sock);
continue;
}
if (desc.counter != data.connectionID.counter)
{
- LogDebug("Received packet for write but counter is broken. Packet ignored!");
+ LogDebug("Received packet for write but counter is broken. Packet ignored! Socket: "
+ << data.connectionID.sock);
continue;
}
if (!desc.useSendMsg) {
- LogError("Some service tries to push SendMsgData to socket that uses write!");
+ LogError("Some service tries to push SendMsgData to socket that uses write! Socket: "
+ << data.connectionID.sock);
continue;
}