Function nw_WorkReliable

networking/networking.cpp:1260–1521

#define CONNECTSEQ 0x142 // Magic number for starting a connection, just so it isn't 0

void nw_WorkReliable(uint8_t *data, int len, network_address *naddr) {
  int i;
  int rcode = -1;
  int16_t max_len = NETBUFFERSIZE;
  static reliable_header rcv_buff;
  static SOCKADDR rcv_addr;
  int bytesin = 0;
  int addrlen = sizeof(SOCKADDR);
  uint32_t rcvid; // The id of who we actually received a packet from, as opposed to socketid parm

  if (NP_TCP == naddr->connection_type) {
    SOCKADDR_IN *inaddr = (SOCKADDR_IN *)&rcv_addr;
    memcpy(&inaddr->sin_addr, &naddr->address, 4);
    inaddr->sin_port = htons(naddr->port);
  }

  if (Net_connect_sequence == R_NET_SEQUENCE_CONNECTING) {
    nw_HandleConnectResponse(data, len, naddr);
    return;
  }
  // Check for incoming data

  reliable_socket *rsocket = NULL;
  // Check to see if we need to send a packet out.
  if ((serverconn != -1) && (reliable_sockets[serverconn].status == RNF_LIMBO) &&
      ((timer_GetTime() - last_sent_iamhere) > NETRETRYTIME)) {
    reliable_header conn_header;
    // Now send I_AM_HERE packet
    conn_header.type = RNT_I_AM_HERE;
    conn_header.seq = INTEL_SHORT((int16_t)(~CONNECTSEQ));
    conn_header.data_len = INTEL_SHORT((int16_t)0);
    last_sent_iamhere = timer_GetTime();
    network_address send_address;
    memset(&send_address, 0, sizeof(network_address));

    send_address.connection_type = reliable_sockets[serverconn].connection_type;
    if (NP_TCP == send_address.connection_type) {
      SOCKADDR_IN *inaddr = (SOCKADDR_IN *)&reliable_sockets[serverconn].addr;
      memcpy(send_address.address, &inaddr->sin_addr, 4);
      send_address.port = htons(inaddr->sin_port);
      send_address.connection_type = NP_TCP;
    }

    int ret = nw_SendWithID(NWT_RELIABLE, (uint8_t *)&conn_header, RELIABLE_PACKET_HEADER_ONLY_SIZE, &send_address);

    if ((ret == SOCKET_ERROR) && (WSAEWOULDBLOCK == WSAGetLastError())) {
      reliable_sockets[serverconn].last_packet_sent = timer_GetTime() - NETRETRYTIME;
    } else {
      reliable_sockets[serverconn].last_packet_sent = timer_GetTime();
    }
  }
  network_protocol link_type = naddr->connection_type;
  network_address d3_rcv_addr;
  memcpy(&d3_rcv_addr, naddr, sizeof(network_address));
  memcpy((uint8_t *)&rcv_buff, data, len);
  SOCKADDR_IN *rcvaddr, *rsockaddr;

  do {