Function MultiProcessBigData

Descent3/multi.cpp:9955–10004

Takes a bunch of messages, check them for validity, and pass them to multi_process_data.

// Takes a bunch of messages, check them for validity,
// and pass them to multi_process_data.
void MultiProcessBigData(uint8_t *buf, int len, network_address *from_addr) {
  int type, bytes_processed = 0;
  int16_t sub_len;
  int slot = 0;
  int last_type = -1, last_len = -1;

  // Update timer stuff so we don't disconnect due to timeout
  if (Netgame.local_role == LR_CLIENT) {
    Netgame.last_server_time = timer_GetTime();
  } else {
    slot = MultiMatchPlayerToAddress(from_addr);
    if (slot >= 0) {
      // This is to prevent clients who have disconnected on the client side
      // but not the server side from being credited with a recent packet
      // just because they are looking for a game
      if ((buf[0] != MP_GET_PXO_GAME_INFO) && (buf[0] != MP_GET_GAME_INFO)) {
        NetPlayers[slot].last_packet_time = timer_GetTime();
      } else {
        // Someone who we think is still connected is looking for game info!
        // We aren't going to process this packet because otherwise they
        // might try to join which wouldn't work and they would be credited
        // with sending a packet and the server wouldn't disconnect them.
        mprintf(0, "Ignoring game info request from a currently connected user (%s)\n", Players[slot].callsign);
        return;
      }
    }
  }

  while (bytes_processed < len) {
    type = buf[bytes_processed];
    sub_len = INTEL_SHORT((*(int16_t *)(buf + bytes_processed + 1)));

    if (sub_len < 3 || type == 0 || (len - bytes_processed) < 2) {
      mprintf(0, "Got a corrupted packet!\n");
      Int3();
      return; // just throw the rest out
    }

    if ((bytes_processed + sub_len) > len) {
      mprintf(1, "multi_process_bigdata: packet type %d too int16_t (%d>%d)!\n", type, (bytes_processed + sub_len), len);
      Int3();
      return;
    }

    MultiProcessData(&buf[bytes_processed], sub_len, slot, from_addr);
    bytes_processed += sub_len;
    last_type = type;
    last_len = sub_len;
  }
}