Function MultiProcessIncoming

Descent3/multi.cpp:2153–2191

MultiProcessIncoming reads incoming data off the unreliable and reliable ports and sends the data to process_big_data

// MultiProcessIncoming reads incoming data off the unreliable and reliable ports and sends
// the data to process_big_data
void MultiProcessIncoming() {
  int size, i;
  uint8_t *data;
  network_address from_addr;

  data = &(Multi_receive_buffer[0]);

  // get the other net players data
  while ((size = nw_Receive(data, &from_addr)) > 0) {
    MultiProcessBigData(data, size, &from_addr);
    if (ServerTimeout) {
      LastPacketReceived = timer_GetTime();
    }
  } // end while

  // read reliable sockets for data
  data = &(Multi_receive_buffer[0]);
  if (Netgame.local_role == LR_SERVER) {
    for (i = 0; i < MAX_NET_PLAYERS; i++) {
      if (Player_num == i)
        continue;

      if ((NetPlayers[i].flags & NPF_CONNECTED) && (NetPlayers[i].reliable_socket != INVALID_SOCKET) &&
          (NetPlayers[i].reliable_socket != 0)) {

        while ((size = nw_ReceiveReliable(NetPlayers[i].reliable_socket, data, MAX_RECEIVE_SIZE)) > 0) {
          MultiProcessBigData(data, size, &NetPlayers[i].addr);
        }
      }
    }
  } else {
    // if I'm not the master of the game, read reliable data from my connection with the server
    if ((NetPlayers[Player_num].reliable_socket != INVALID_SOCKET) && (NetPlayers[Player_num].reliable_socket != 0)) {
      while ((size = nw_ReceiveReliable(NetPlayers[Player_num].reliable_socket, data, MAX_RECEIVE_SIZE)) > 0) {
        MultiProcessBigData(data, size, &Netgame.server_address);
      }
    }
  }
}

// Starts a packet of data
int START_DATA(int type, uint8_t *data, int *count, uint8_t reliable) {