|
|
|
|
@ -120,8 +120,8 @@ int CTCPReaderWriterClient::read(unsigned char* buffer, unsigned int length)
|
|
|
|
|
assert(m_fd != -1);
|
|
|
|
|
|
|
|
|
|
ssize_t len = recv(m_fd, buffer, length, 0);
|
|
|
|
|
if (len < 0) {
|
|
|
|
|
fprintf(stderr, "Error returned from recv, err=%d\n", errno);
|
|
|
|
|
if (int(len) != int(length)) {
|
|
|
|
|
fprintf(stderr, "Error read returned %d from recv, err=%d\n", int(len), errno);
|
|
|
|
|
return -1;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@ -157,11 +157,14 @@ bool CTCPReaderWriterClient::write(const unsigned char* buffer, unsigned int len
|
|
|
|
|
|
|
|
|
|
ssize_t ret = ::send(m_fd, (char *)buffer, length, 0);
|
|
|
|
|
if (ret != ssize_t(length)) {
|
|
|
|
|
fprintf(stderr, "Error returned from send, err=%d\n", errno);
|
|
|
|
|
return false;
|
|
|
|
|
if (ret < 0)
|
|
|
|
|
fprintf(stderr, "Error returned from send, err=%d\n", errno);
|
|
|
|
|
else
|
|
|
|
|
fprintf(stderr, "Error only wrote %d of %d bytes\n", int(ret), int(length));
|
|
|
|
|
return true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return true;
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
bool CTCPReaderWriterClient::writeLine(const std::string& line)
|
|
|
|
|
|