Function nw_ReceiveReliable

networking/networking.cpp:971–1017

// >0 Buffer filled with the number of bytes recieved

int nw_ReceiveReliable(SOCKET socketid, uint8_t *buffer, int max_len) {

  int i;
  if (Use_DirectPlay) {
#ifdef WIN32
    dp_DirectPlayDispatch();

    // try and get a free buffer and return its size
    if (nw_psnet_buffer_get_next_by_packet_id((uint8_t *)buffer, &max_len, socketid)) {
      return max_len;
    }
    return 0;
#endif
  }
  reliable_socket *rsocket = NULL;
  // nw_WorkReliable();
  nw_DoReceiveCallbacks();
  if (socketid >= MAXRELIABLESOCKETS) {
    mprintf(0, "Invalid socket id passed to nw_NewReceiveReliable() -- %d\n", socketid);
    return -1;
  }
  rsocket = &reliable_sockets[socketid];
  if ((RNF_CONNECTED != rsocket->status) && (RNF_LIMBO != rsocket->status)) {
    mprintf(0, "Can't receive packet because it isn't connected in nw_ReceiveReliable(). socket = %d\n", socketid);
    return 0;
  }
  // If the buffer position is the position we are waiting for, fill in
  // the buffer we received in the call to this function and return true

  for (i = 0; i < MAXNETBUFFERS; i++) {
    if ((rsocket->rsequence[i] == rsocket->oursequence) && (rsocket->rbuffers[i])) {
      memcpy(buffer, rsocket->rbuffers[i]->buffer, rsocket->recv_len[i]);
      mem_free(rsocket->rbuffers[i]);
      rsocket->rbuffers[i] = NULL;
      rsocket->rsequence[i] = 0;
/*
      mprintf(0,"Found packet for upper layer in nw_ReceiveReliable() %d bytes. seq:%d.\n",
               rsocket->recv_len[i],
               rsocket->oursequence);
*/
      rsocket->oursequence++;
      return rsocket->recv_len[i];
    }
  }

  return 0;
}

// This function will look for a control packet, indicating a
// desire to establish a reliable link.