Accept阻塞问题

colin8080

   
不是说Accept在监听socket阻塞的情况下是阻塞的吗，我专门搞了一个线程接收客户端连接，在接收前1个客户端连接的情况下是阻塞的，后来客户端连接超过2个时，accept不停的返回-1,搞得很多客户端都连接不上：Connection refused，奇怪！

struct sockaddr_in sAddr;
    int nListenSocket;
    int nFlag = 1;

    memset(&sAddr, 0, sizeof(sAddr));
    sAddr.sin_family = AF_INET;
    sAddr.sin_port = htons(nPort);
    sAddr.sin_addr.s_addr = inet_addr(sIp);

    nListenSocket = socket(AF_INET, SOCK_STREAM, 0);
    if (nListenSocket < 0)
    {
                nDebugLog(LOG_PRIORITY_ERROR, "New socket failed:%s!",strerror(errno));
        return -1;
    }

    setsockopt(nListenSocket, SOL_SOCKET, SO_REUSEADDR, (void *)&nFlag, sizeof(nFlag));

    if (bind(nListenSocket, (struct sockaddr *)&sAddr, sizeof(sAddr)) < 0)
    {
                nDebugLog(LOG_PRIORITY_ERROR, "Bind socket failed:%s!",strerror(errno));
        close(nListenSocket);
        return -1;
    }
       
        if (listen(nListenSocket, SOCKET_LISTEN_QUEUES) < 0)
        {
                nDebugLog(LOG_PRIORITY_ERROR, "Listen socket failed:%s!",strerror(errno));
        close(nListenSocket);
        return -1;
        }

hellioncu

代码贴完整点，估计除了第一次，后面调用accept的地方参数不对

colin8080

回复 2# hellioncu


    void * CheckAndProcessOnSockets(void *arg)
{
        INIT_CONFIG * pInitConfig = (INIT_CONFIG*)arg;
        struct sockaddr_in stSockAddr;
        int clientSocket;
        socklen_t len = sizeof(stSockAddr);
       
        while (1)
        {
                printf("Accept ready...\n");
                clientSocket = accept(pInitConfig->nListenSocket,(struct sockaddr *)&stSockAddr,&len);
                printf("Accept client:%d\n",clientSocket);
                if (clientSocket > 0)
                {
                        if (clientSocket > MAX_SOCKET_NUM)
                        {
                                nDebugLog(LOG_PRIORITY_ERROR, "Too Many Sockets, should start another process!");
                                close(clientSocket);
                                continue;
                        }
                        if (SetNonblock(clientSocket) < 0)
                        {
                                close(clientSocket);
                                continue;
                        }       
                        int nFlag = 1;
                        setsockopt(clientSocket, SOL_SOCKET, SO_KEEPALIVE, (void *)&nFlag, sizeof(nFlag));
                        struct linger l = {1,2};
                        setsockopt(clientSocket, SOL_SOCKET, SO_LINGER, (void *) &l, sizeof(l));
                        setsockopt(clientSocket, IPPROTO_TCP, TCP_NODELAY, &nFlag, sizeof(nFlag));
                       
                        m_sSocketContext[clientSocket].nSocketType = CONN_SOCKET;
                        m_sSocketContext[clientSocket].dwTimeLast = time(0);
                        memset(m_sSocketContext[clientSocket].sIP,0,sizeof(m_sSocketContext[clientSocket].sIP));
                        char* sTemp = inet_ntoa(stSockAddr.sin_addr);
                        memcpy(m_sSocketContext[clientSocket].sIP,sTemp,strlen(sTemp));       
                        m_sSocketContext[clientSocket].nPort = ntohs(stSockAddr.sin_port);
                        m_sSocketContext[clientSocket].ev.data.fd = clientSocket;
                        m_sSocketContext[clientSocket].ev.events = EPOLLIN | EPOLLET;
                        epoll_ctl(m_pIOWorkList[clientSocket%pInitConfig->nIOThreadNum].epoll_fd, EPOLL_CTL_ADD, clientSocket, &(m_sSocketContext[clientSocket].ev));
                }
        }       
}

void AcceptThreadInit()
{
        pthread_t tid;
    pthread_attr_t attr;
        pthread_attr_init(&attr);
        pthread_create(&tid, &attr, CheckAndProcessOnSockets, &m_cInitConfig);                       
}

hellioncu

colin8080 发表于 2015-06-29 12:28
回复 2# hellioncu

我猜得没错。
len = sizeof(stSockAddr);放到循环中accept前。

colin8080

回复 4# hellioncu


    还是那样，不能解决问题，我再看看！

gotojyh

不停返回-1时看一下pInitConfig->nListenSocket的值

tsh185

pInitConfig->nListenSocket   这个 值的问题， 这个值应该不是你创建的 那个 socket  fd 了

colin8080

找到原因，但是想不明白：

因为写日志的文件句柄用的没有初始化的指针FILE *fp,结果不但写日志不成功,而且accept也不能接收新的客户端。

yangchao1117

没看到 你写日志 文件指针和代码，可以附全代码  一起研究下。

colin8080

回复 9# yangchao1117


    我没有贴url的权限，上百度搜“redis3.0集群代理”，在CSDN上有下载。