c - 套接字编程代码在 XP 上执行但在 Windows 7 上失败

标签 c sockets windows-7 cygwin windows-xp

首先让我告诉您代码的目标。 它是一个udp服务器,应该提供有关收到的数据包数量和花费的时间等的统计信息。客户端代码是公司嵌入式代码的一部分,不能共享。下面是代码。

/*
** listener.c -- a datagram sockets "server" demo
*/

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/select.h>
#include <netdb.h>
#include <time.h>
#include <math.h>
#include "windows.h"

#define MYPORT "4950"   // Default port number users will be connecting to

#define MAXBUFLEN 1497 

#define TIMEOUT_PERIOD_IN_SEC  5  /* Time out after the last packet reception */

//#define DEBUG_ENABLE

// get sockaddr, IPv4 or IPv6:
void *get_in_addr(struct sockaddr *sa)
{
    if (sa->sa_family == AF_INET) {
        return &(((struct sockaddr_in*)sa)->sin_addr);
    }

    return &(((struct sockaddr_in6*)sa)->sin6_addr);
}


int main(int argc, char *argv[]) 
{
    int sockfd;
    struct addrinfo hints, *servinfo, *p;
    int rv;
    int numbytes=0;
    struct sockaddr_storage their_addr;
    char buf[MAXBUFLEN];
    socklen_t addr_len;
    char s[INET6_ADDRSTRLEN];
    int flag=1;
    struct timeval tv;
    fd_set rfds;
    int retval;
    long long  length = 0;
    double   totalTxBits=0;
    double   dataRate=0;

        FILETIME   sysTime;
        long long  startTime=0;
        long long  endTime=0;
        long long  timeDurationInMicSec;
    long total_no_of_packets=0;
    long expected_length=0;
        char portNum[8];
        int i;

       switch(argc)
       {
       case 2:
               {
                   strncpy(portNum, argv[1],8);

                   if((0==strcmp(portNum,"-h")) || (0==strcmp(portNum,"h")))
                   {
                       printf("\r\nUsage: \r\n\t udpserver.exe [<port num>] [<expected length(bytes)>]\r\n");
                       printf("\r\nNote: All parameters are optional\r\n");
                       printf("\r\nExample: \r\n\t i) udpserver.exe \r\n");
                       printf("\n\t ii) udpserver.exe 8000 \r\n");
                       printf("\n\t iii) udpserver.exe 8000 100000\r\n");
                       printf("\n\t iv) udpserver.exe 8000 100000 1400\r\n");

                       return 1;
                   }

                   // Make sure that argument contains nothing but digits
                   for (i = 0; i < strlen(portNum); i++)
                   {
                       if (!isdigit(portNum[i]))
                       {
                           printf("\r\n Invalid port number \r\n");
                           printf("\r\nUsage: \r\n\t udpserver.exe [<port num>] [<expected length>]\r\n");
                            return 1;
                       }
                   }

               }
           break;

       case 3:
            {
               strncpy(portNum, argv[1],8);

               /* Make sure that argument contains nothing but digits */
               for (i = 0; i < strlen(portNum); i++)
               {
                   if (!isdigit(portNum[i]))
                   {
                       printf("\r\n Invalid port number \r\n");
                       return 1;
                   }
               }

               printf("\r\nExpected length                 :%d \r\n",atoi(argv[2]));
               expected_length = atoi(argv[2]);
            }
        break;

           case 4:
            {
               strncpy(portNum, argv[1],8);

                /* Make sure that argument contains nothing but digits */
               for (i = 0; i < strlen(portNum); i++)
               {
                   if (!isdigit(portNum[i]))
                   {
                       printf("\r\n Invalid port number \r\n");
                       return 1;
                   }
               }


               expected_length = atoi(argv[2]);
               expected_length  = expected_length * atoi(argv[3]);
               printf("\r\nExpected length                 :%d (%d x %d)\r\n",expected_length,atoi(argv[2]),atoi(argv[3]));
           }
       break;

       default:
       {   
           strcpy(portNum, MYPORT);
               expected_length=0;
       }
       break;
       }

       printf("\r\nWaiting on port number          :%s \r\n",portNum);

       tv.tv_sec = TIMEOUT_PERIOD_IN_SEC; /* Time out after the last packet reception */
       tv.tv_usec = 0;

       memset(&hints, 0, sizeof hints);
       hints.ai_family = AF_UNSPEC; // set to AF_INET to force IPv4
       hints.ai_socktype = SOCK_DGRAM;
       hints.ai_flags = AI_PASSIVE; // use my IP

       if ((rv = getaddrinfo(NULL, portNum, &hints, &servinfo)) != 0) {
           fprintf(stderr, "getaddrinfo: %s\n", gai_strerror(rv));
       return 1;
       }

    // loop through all the results and bind to the first we can
    for(p = servinfo; p != NULL; p = p->ai_next) {
        if ((sockfd = socket(p->ai_family, p->ai_socktype,
                p->ai_protocol)) == -1) {
            perror("listener: socket");
            continue;
        }

        if (bind(sockfd, p->ai_addr, p->ai_addrlen) == -1) {
            close(sockfd);
            perror("listener: bind");
            continue;
        }

        break;
    }

    if (p == NULL) {
        fprintf(stderr, "listener: failed to bind socket\n");
        return 2;
    }

    freeaddrinfo(servinfo);

    total_no_of_packets=0;

    while(flag)
    {

#ifdef DEBUG_ENABLE
        printf("listener: waiting to recvfrom...\n");
#endif /* DEBUG_ENABLE */

        addr_len = sizeof their_addr;

        if ((numbytes = recvfrom(sockfd, buf, MAXBUFLEN-1 , 0,
            (struct sockaddr *)&their_addr, &addr_len)) == -1)
        {
            perror("recvfrom");
            exit(1);
        }

        total_no_of_packets++;

#ifdef DEBUG_ENABLE
        printf("listener: got packet from %s\n",
        inet_ntop(their_addr.ss_family,
        get_in_addr((struct sockaddr *)&their_addr),
        s, sizeof s));
#endif /* DEBUG_ENABLE */

        if (0==length)
        {
            GetSystemTimeAsFileTime(&sysTime);
            startTime = sysTime.dwHighDateTime;
            startTime =  (startTime<<32) | sysTime.dwLowDateTime; /* number of 100-nanosecond intervals  */

        }

#ifdef DEBUG_ENABLE
        printf("listener: packet is %d bytes long\n", numbytes);
#endif /* DEBUG_ENABLE */
        length+=numbytes;

        #if 0
        GetSystemTimeAsFileTime(&sysTime);
        endTime =sysTime.dwHighDateTime;
        endTime =  (endTime<<32) | sysTime.dwLowDateTime; /* number of 100-nanosecond intervals  */
        #endif

        buf[numbytes] = '\0';

#ifdef DEBUG_ENABLE     
        printf("listener: packet contains \"%s\"\n", buf);
#endif /* DEBUG_ENABLE */

        FD_ZERO(&rfds);
        FD_SET(sockfd, &rfds);
        retval = select(sockfd+1, &rfds, NULL, NULL, &tv);

        if (retval == 0)
        {   
            GetSystemTimeAsFileTime(&sysTime);
                    endTime =sysTime.dwHighDateTime;
            endTime =  (endTime<<32) | sysTime.dwLowDateTime; /* number of 100-nanosecond intervals  */
                    timeDurationInMicSec  =(endTime - startTime) / (long long)10;

                     /* Subtract the last time-out value  */
                   if(timeDurationInMicSec)
                   {
                       timeDurationInMicSec -= ((long long)(TIMEOUT_PERIOD_IN_SEC *1000*1000));
                   }

                   printf("\r\n$Time taken                     :%ld micro sec\r\n",timeDurationInMicSec);

                   /* Convert to bits */
                   totalTxBits = length*8;

                   if(timeDurationInMicSec)
                   {
                       dataRate = (totalTxBits*1000*1000)/timeDurationInMicSec;
                   }

                   if(dataRate)
                   {
                       printf("$Number of packets recieved     :%lld\r\n",(total_no_of_packets));
                       printf("$Total number of bytes recieved :%lld\r\n",(length));

                       printf("\r\n$DataRate                       :%f bits per sec\n",dataRate);
                       printf("\r\n$DataRate                       :%f kbps (kilo bits per sec)\n",(dataRate/1024));

                       printf("\r\nNet throughput                  :%f mbps (mega bits per sec)\n",(dataRate/(1024*1024)));

                       if(0 != expected_length)
                       {
                           if(expected_length >= length)
                           {
                               printf("\r\nData loss                       :%lld bytes ( %f percentage)",(expected_length - length), ((float)((expected_length - length)*100))/(float)expected_length);
                           }
                       }

                   }
                   else
                   {
                       printf("$Error: Unable to calculate throughput.");
                   }

            break;
        }

    }

    close(sockfd);
    return 0;
}

现在介绍运行环境。

我使用Cygwin编译生成.exe文件后,在Windows XP上运行了上面的代码。它在那里工作得很好。 然而,当我在 Windows 7 机器上编译它时(再次使用 cygwin (setup_X86.exe 文件顺便说一句),它编译得很好,但在执行它时调试显示它只到达调试日志

"printf("listener: waiting to recvfrom...\n");

第 191 行。

我尝试使用 XP SP3 兼容性和管理员权限运行可执行文件。我尝试在网上查找,但没有找到解决方案。有谁知道我在编译过程中是否犯了错误?我做了一个简单的

gcc -o udpserver.exe udpserver.c

并且成功了。请让我知道我可以做些什么来进一步缩小问题范围。我对套接字编程和一般编程还很陌生。

提前致谢!

最佳答案

如果您要搜索要绑定(bind)的地址(例如,通过 getaddrinfo),您通常需要绑定(bind)到您找到的所有地址。否则,在具有多个适配器的计算机上,您的服务将仅在随机选择的单个适配器上可用;即使只有一个适配器,您也可能绑定(bind)到错误的协议(protocol)(如本例所示)。

我认为通常的方法是绑定(bind)到“任何”地址,即 IPv4 中的 0.0.0.0,如 documentation for bind 中所述。 :

If an application does not care what local address is assigned, specify the constant value INADDR_ANY for an IPv4 local address or the constant value in6addr_any for an IPv6 local address in the sa_data member of the name parameter.

关于c - 套接字编程代码在 XP 上执行但在 Windows 7 上失败,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32876609/

相关文章:

c++ - 使用 select() 从多个使用 UDP 套接字的对等方接收,同时从 STDIN 获取用户输入

windows-7 - 如何让 Microsoft Access 2007 32 位在 Windows 7 64 位上显示 64 位 ODBC 驱动程序?

java - 使用 Docker 和 Testcontainers 进行数据库集成测试

c++ - 使用 Microsoft Visual Studio 2010 IDE 进行精确的库链接顺序控制

c - 如何将具有数组的宏字符串化为#define a_macro {5,7,7,97}?

C++ 网络套接字、SCTP 和数据包大小

Python PyAudio 安装问题(使用 PortAudio)

c - dup2 没有切换到文件?

c - 二维数组和指针

c++ - 为什么 std::string 使 WSAGetLastError 返回零?