Function nw_SendReliable

networking/networking.cpp:1083–1217

}

int nw_SendReliable(uint32_t socketid, uint8_t *data, int length, bool urgent) {
  int i;
  int bytesout;
  int use_buffer = -1;
  reliable_socket *rsocket;
  reliable_header send_header;
  int send_this_packet = 1;

  if (length == 0) {
    mprintf(0, "Attempting to send 0 byte network packet in nw_SendReliable()\n");
    Int3();
  }
  // mprintf(0,"Socket id passed to nw_NewSendReliable() -- %d\n",socketid);

  if (NetDebugFile) {
    cfprintf(NetDebugFile, "nw_SendReliable packet of type %d at %f seconds.\n", data[0], timer_GetTime());
  }

  if (Use_DirectPlay) {
#ifdef WIN32
    network_address who_to;
    who_to.connection_type = NP_DIRECTPLAY;
    memcpy(&who_to.address, &socketid, sizeof(DPID));
    return dp_DirectPlaySend(&who_to, data, length, true);
#endif
  }

  ASSERT(length < sizeof(reliable_header));
  // nw_WorkReliable();
  nw_DoReceiveCallbacks();

  if (socketid >= MAXRELIABLESOCKETS) {
    mprintf(0, "Invalid socket id passed to nw_NewSendReliable() -- %d\n", socketid);
    return -1;
  }

  rsocket = &reliable_sockets[socketid];
  if (rsocket->status != RNF_CONNECTED) {
    // We can't send because this isn't a connected reliable socket.
    mprintf(0, "Can't send packet because of status %d in nw_SendReliable(). socket = %d\n", rsocket->status, socketid);
    return -1;
  }
  if (urgent)
    rsocket->send_urgent = 1;
  // See if there is a packet waiting to be sent
  if (-1 != rsocket->waiting_packet_number) {
    int pnum = rsocket->waiting_packet_number;
    ASSERT(rsocket->sbuffers[pnum]);
    // See if there's room for this data
    if (sizeof(reliable_net_sendbuffer) < (rsocket->send_len[pnum] + length)) {
      // Send the previous packet, then use the normal code to generate a new packet
      mprintf(0, "Pending reliable packet buffer full, sending packet now.\n");
      rsocket->waiting_packet_number = -1;

      use_buffer = pnum;
      network_address send_address;
      memset(&send_address, 0, sizeof(network_address));