LeCroy LSA1000, Operator'S Manual

Page: 79 / 115

B – 6
Appendix B
space_left = len;
while (1)
{
// block here until data is received of timeout expires
result = select(hSocket, &rd_set, NULL, NULL, &tval);
if (result < 1)
{
TCP_ClearDevice();
MessageBox(0, sCommandBuffer, "Read timeout", MB_OK);
return -1;
}
// get the header info first
accum = 0;
while (1)
{
memset(&header, 0, sizeof(TCP_HEADER));
if ((result = recv(hSocket, (char *) & accum, sizeof(header) - accum, 0)) < 0)
{
TCP_ClearDevice();
MessageBox(0, "Unable to receive header info from the server.", "ERROR", MB_OK);
return -1;
}
accum += result;
if (accum>=sizeof(header))
break;
}
header.iLength = ntohl(header.iLength);
if (header.iLength < 1)
return 0;
// only read to len amount
if (header.iLength > space_left)
{
header.iLength = space_left;
sprintf(tmpStr, "Read buffer size (%d bytes) is too small", len);
MessageBox(0, tmpStr, "ERROR", MB_OK);
}
// read the rest of the block
accum = 0;
while (1)
{
idxPtr = buf + (buf accum);
bytes_more = header.iLength - accum;
if ((space_left-accum) < TCP_MINIMUM_PACKET_SIZE)
{
TCP_ClearDevice();