Function nw_ReliableResend

networking/networking.cpp:2530–2668

MTS: only used in this file? Resend any unack'd packets and send any buffered packets, heartbeats, etc.

// MTS: only used in this file?
// Resend any unack'd packets and send any buffered packets, heartbeats, etc.
void nw_ReliableResend(void) {
  int i, j;
  int rcode = -1;
  int16_t max_len = NETBUFFERSIZE;
  static reliable_header rcv_buff;
  static SOCKADDR rcv_addr;
  int bytesin = 0;
  int addrlen = sizeof(SOCKADDR);
  reliable_socket *rsocket = NULL;
  // Go through each reliable socket that is connected and do any needed work.
  for (j = 0; j < MAXRELIABLESOCKETS; j++) {
    rsocket = &reliable_sockets[j];

    if (serverconn == -1) {
      if (rsocket->status == RNF_LIMBO)
        if ((timer_GetTime() - rsocket->last_packet_received) > NETTIMEOUT) {
          mprintf(0, "Reliable (but in limbo) socket (%d) timed out in nw_WorkReliable().\n", j);
          memset(rsocket, 0, sizeof(reliable_socket));
          rsocket->status = RNF_UNUSED; // Won't work if this is an outgoing connection.
        }
    } else {
      if ((rsocket->status == RNF_LIMBO) && ((timer_GetTime() - first_sent_iamhere) > NETTIMEOUT)) {
        rsocket->status = RNF_BROKEN;
        mprintf(0, "Reliable socket (%d) timed out in nw_WorkReliable().\n", j);
      }
    }

    if (rsocket->status == RNF_CONNECTED) {
      float retry_packet_time;
      if ((rsocket->mean_ping == 0) || (rsocket->mean_ping > (NETRETRYTIME * 4))) {
        retry_packet_time = NETRETRYTIME;
      } else {
        if (rsocket->mean_ping < MIN_NET_RETRYTIME) {
          retry_packet_time = (float)MIN_NET_RETRYTIME;
          // mprintf(0,"Using retransmission time of %f\n",retry_packet_time);
        } else {
          retry_packet_time = ((float)(float)rsocket->mean_ping * (float)1.25);
          // mprintf(0,"Using retransmission time of %f\n",retry_packet_time);
        }
      }
      // Iterate through send buffers.
      for (i = 0; i < MAXNETBUFFERS; i++) {
        if (((i == rsocket->waiting_packet_number) &&
             ((((timer_GetTime() - rsocket->last_sent) > R_NET_PACKET_QUEUE_TIME)) ||
              ((rsocket->mean_ping > 0) && (rsocket->mean_ping < R_NET_PACKET_QUEUE_TIME)) || rsocket->send_urgent)) ||
            ((rsocket->sbuffers[i]) && ((timer_GetTime() - rsocket->timesent[i]) >= retry_packet_time))) // Send again
        {

          if (i == rsocket->waiting_packet_number) {
            rsocket->waiting_packet_number = -1;
            rsocket->last_sent = timer_GetTime();
            // mprintf(0,"Sending delayed packet...\n");
          }
          reliable_header send_header;
          // mprintf(0,"Resending reliable packet in nw_WorkReliable().\n");
          send_header.send_time = INTEL_FLOAT(timer_GetTime());
          send_header.seq = INTEL_SHORT(rsocket->ssequence[i]);
          memcpy(send_header.data, rsocket->sbuffers[i]->buffer, rsocket->send_len[i]);