Subversion Repositories Games.Chess Giants

}

int RecvWithTimeout (int socket_id, float timeout_in_seconds, char *outbuf, size_t outbuf_size, int flags)

{

   // variant of recv() that honors a specific timeout in seconds

   unsigned long nonblocking_mode;

   unsigned long msec_start;

   float timediff;

   int total_size;

   int recv_size;

   // make socket non blocking

   nonblocking_mode = 1;

   ioctlsocket (socket_id, FIONBIO, &nonblocking_mode);

   // loop endlessly, noting the time at which we start

   msec_start = GetTickCount ();

   total_size = 0;

   for (;;)

   {

      // see how much time elapsed since the last time we received data

      timediff = (GetTickCount () - msec_start) / 1000.0f;

      if (timediff > timeout_in_seconds)

         break; // if we've waited long enough, give up

                // see if we have something to read from the socket

      recv_size = recv (socket_id, &outbuf[total_size], outbuf_size - total_size, flags);

      if (recv_size == 0)

         break; // on TCP disconnection, give up too

      else if (recv_size < 0)

      {

         Sleep (100); // if nothing was received then we want to wait a little before trying again, 0.1 seconds

         continue;

      }

      total_size += recv_size; // increase the received bytes count

      outbuf[total_size] = 0; // terminate outbuf ourselves

      if (total_size == outbuf_size)

         break; // if the output buffer is full, give up

      msec_start = GetTickCount (); // and remember when we last received data (i.e. now)

   }

   return (total_size); // and return the number of bytes received