udpサーバで最新のパケットを受信 - C

Question

UDPサーバがselectシステムコールでパケットを受信して​​います。そして、私は各UDPクライアントから最新のパケットを受信したいと思います。 （私はまた、複数のUDPクライアントパケットを聞きたい）。

私の簡単なUDP-サーバーのコード：

int main(void) { 
    int fd; 
    int port = 5678; 
    char buffer[1024]; 
    fd_set readfs; 
    socklen_t client_length; 
    struct timeval timeout_interval; 
    struct sockaddr_in6 server_addr; 
    struct sockaddr_in6 client_addr; 
    int result; 
    int recv; 
    char client_addr_ipv6[100]; 

    fd = socket(PF_INET6, SOCK_DGRAM, 0); 
    printf(" \e[1m \e[34m ---------------------------------------- \n-------------------- UDP SERVER --------------------\n \e[39m \e[0m \n"); 
    printf("Process: \e[34m %d \e[49m Port ..\n", port); 

    if (fd < 0) { 
     printf("ERR: fd < 0"); 
    } else { 
     memset(&server_addr, 0, sizeof(server_addr)); 
     server_addr.sin6_family = AF_INET6; 
     server_addr.sin6_addr = in6addr_any; 
     server_addr.sin6_port = htons(port); 
     memset(&client_addr, 0, sizeof(client_addr)); 
     client_addr.sin6_family = AF_INET6; 
     client_addr.sin6_addr = in6addr_any; 
     client_addr.sin6_port = htons(port); 

     if (bind(fd, (struct sockaddr *) &server_addr, sizeof(server_addr)) 
       >= 0) { 
      printf("\e[1m INFO: \e[0m \e[34m Bind success.. \e[39m\n"); 

     } else { 
      printf("Bind."); 
      return -1; 
     } 
     for (;;) { 
      FD_ZERO(&readfs); 
      FD_SET(fd, &readfs); 
      int max_fd = MAX(0, fd); 
      timeout_interval.tv_sec = 3; 
      timeout_interval.tv_usec = 50000000; 

      result = select(max_fd + 1, &readfs, NULL, NULL, &timeout_interval); 
      //printf("\n %d \t %d \n", result, fd); 
      if (result < 0) { 
       printf("ERR\n"); 
      } else if (result == 0) { 
       printf("\nTimeout\n"); 
      } else { 
       if (FD_ISSET(fd, &readfs)) { 
        client_length = sizeof(client_addr); 
        if ((recv = recvfrom(fd, buffer, sizeof(buffer), 0, 
            (struct sockaddr *) &client_addr, &client_length)) 
          < 0) { 
         printf("Recv-ERR!"); 
         break; 
        } 
        inet_ntop(AF_INET6, &(client_addr.sin6_addr), client_addr_ipv6, 100); 
        //printf("Client IP/Port : %s ",client_addr_ipv6); 

        printf("\n ------------------------------------------ \n"); 
        printf("\e[1m Data: \e[0m \e[32m %.*s \n Client IP/Port : \e[34m %s/%d \n\e[39m", recv, buffer,client_addr_ipv6,ntohs(client_addr.sin6_port)); 
       } 
      } 
     } 
    } 
} 

Answer 1

これを処理するための最良の方法は、送信者が各パケットにシーケンス番号を入れていることです。送信されるパケットごとに、シーケンス番号は1だけ増加します。

受信側では、受信した最後のパケットのカウンタを追跡します。入って来る次のパケットがより大きいカウンタを持っているならば、それは最新です。それが大きくなければ、それは古いパケットであり、アプリケーションのために適切な方法で処理することができます。

また、recv変数の名前をrecv_lenのように変更する必要があります。 recvは、この変数定義によってマスクされるソケット関数の名前です。