ssize_t iReturn = send(socket, (char*)data, (int)len, 0);
if (iReturn < (ssize_t)len)
ssize_t iReturn = send(socket, (char*)data, (int)len, 0);
if (iReturn < (ssize_t)len)
FD_SET(socket, &fd_read);
if (select((int)socket + 1, &fd_read, NULL, NULL, &tv) == 0)
FD_SET(socket, &fd_read);
if (select((int)socket + 1, &fd_read, NULL, NULL, &tv) == 0)
TcpSocketSetBlocking(socket, false);
}
ssize_t iReadResult = (iTimeoutMs > 0) ?
TcpSocketSetBlocking(socket, false);
}
ssize_t iReadResult = (iTimeoutMs > 0) ?
- recv(socket, (char*)data + iBytesRead, (int)(len - iBytesRead), MSG_WAITALL) :
+ recv(socket, (char*)data + iBytesRead, (int)(len - iBytesRead), 0) :
recv(socket, (char*)data, (int)len, MSG_WAITALL);
*iError = GetSocketError();
recv(socket, (char*)data, (int)len, MSG_WAITALL);
*iError = GetSocketError();
}
inline bool TcpResolveAddress(const char *strHost, uint16_t iPort, int *iError, struct addrinfo **info)
}
inline bool TcpResolveAddress(const char *strHost, uint16_t iPort, int *iError, struct addrinfo **info)