C++ TCP Socket Exponential Увеличивающая задержка

Question

У меня, похоже, проблема с увеличением задержки при передаче пакетов с моего TCP-сервера. Теперь этот сервер должен быть TCP, поскольку UDP блокируется брандмауэрами (это тип связи клиент-сервер-клиент). Я также знаю, что отправка структуры с целыми числами с плавающей запятой, как я, крайне не переносима, однако в обозримом будущем эта система будет работать с клиентом Windows на сервер Windows на клиент Windows.

Проблема заключается в следующем: клиент начинает получать данные должным образом от другого клиента, однако есть задержка, которая экспоненциально ухудшается (где примерно на 3 минуты пакеты отстают почти на 30 секунд, но правильно , когда они ДОЛЖНЫ прибыть). Я исследовал его и нашел ответ на странице Microsoft, объясняющий, что это связано с полными буферами отправки, однако их синтаксис для setsockopt не соответствует документированным примерам, поэтому, возможно, я ошибаюсь.

Во всяком случае, любые советы будут оценены:

Соответствующая часть сервера:

(Если принять() называется :)

int buff_size = 2048000; 
int nodel = 1; 
setsockopt(sock, SOL_SOCKET, SO_SNDBUF, (char*)&buff_size, sizeof(int)); 
setsockopt(sock, SOL_SOCKET, SO_RCVBUF, (char*)&buff_size, sizeof(int)); 
setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, (char*)&nodel, sizeof(nodel)); 

сообщение перенаправления цикл:

if (gp->curr_pilot < sz && gp->users[gp->curr_pilot].pilot == TRUE) { 
      char* pbuf = new char[1024]; 
      int recvd = recv(gp->users[gp->curr_pilot].sockfd_data, pbuf, 1024, NULL); 
      if (recvd > 0) { 
       for (int i = 0; i < sz; i++) { 
        if (i != gp->curr_pilot && gp->users[i].unioned == TRUE) 
         send(gp->users[i].sockfd_data, pbuf, recvd, NULL); 
       } 
      } 
      delete[] pbuf; 
     } 

Клиент (мастер устанавливается, когда он отправляется, и он правильно устанавливается на m y code):

(данные - это моя структура удвоений, которая записывается клиентом, cdata - это копия, которая записывается в клиент).

while (kill_dataproc == FALSE) { 
    if (master == TRUE) { 
     char* buff = new char[1024]; 
     int packet_signer = 1192; 
     memcpy_s(buff, intsz, &packet_signer, intsz); 
     memcpy_s((void*)(buff + intsz), sz, data, sz); 
     send(server_sock, buff, buffsize, NULL); 
     delete[] buff; 
    } 
    else {   
     char* buffer = new char[1024]; 
     int recvd = recv(server_sock, buffer, 1024, MSG_PEEK); 
     if (recvd > 0) { 
      int newpacketsigner = 0; 
      memcpy_s(&newpacketsigner, intsz, buffer, intsz); 

      if (newpacketsigner == 1192) { 
       if (recvd >= buffsize) { 
        char* nbuf = new char[buffsize]; 
        int recvd2 = recv(server_sock, nbuf, buffsize, NULL); 
        int err = WSAGetLastError(); 

        memcpy_s(&newpacketsigner, intsz, nbuf, intsz); 
        memcpy_s(cdata, sz, (void*)(nbuf + intsz), sz); 
        //do things w/ the struct      
        delete[] nbuf;      
       } 
      } 
      else     
       recv(server_sock, buffer, 1024, NULL); 
     } 
     delete[] buffer; 
    } 

    Sleep(10); 
} 

Как одинаковые вызовы setsockopt и называются сокетами клиента, и все розетки, сервер и клиент, являются блокирующими.

Answer 1

Вы считаете, что ваши чтения заполняют буфер. Они обязаны передавать хотя бы один байт. Вам нужно петлю.

Итак, у вас есть непрочитанная резервная копия данных и остановка отправителя.

NB Буферы, принимающие буферы, больше 64k и поэтому могут быть неработоспособными, если они не установлены до того, как сокет подключен. В случае сервера вам необходимо установить размер буфера приема в прослушивающем сокете. Принятые сокеты наследуют его. Если вы этого не сделаете, масштабирование окна не будет действовать, поэтому окно> 64k не может быть объявлено (если платформа по умолчанию не имеет окна).