Redisソースシリーズ28:サーバSocketがクライアントを受信した接続要求処理手順

1138 ワード

int anetAccept(char *err, int serversock, char *ip, int *port)
{
	//         

    int fd;
    struct sockaddr_in sa;
    unsigned int saLen;

    while(1) 
	{
        saLen = sizeof(sa);
        fd = accept(serversock, (struct sockaddr*)&sa, &saLen);
        if (fd == -1) {
            if (errno == EINTR)
                continue;
            else {
                anetSetError(err, "accept: %s
", strerror(errno)); return ANET_ERR; } } break; } if (ip) strcpy(ip,inet_ntoa(sa.sin_addr)); if (port) *port = ntohs(sa.sin_port); return fd;

 
 if ((flags = fcntl(fd, F_GETFL)) == -1) {
        anetSetError(err, "fcntl(F_GETFL): %s
", strerror(errno)); return ANET_ERR; } if (fcntl(fd, F_SETFL, flags | O_NONBLOCK) == -1) { anetSetError(err, "fcntl(F_SETFL,O_NONBLOCK): %s
", strerror(errno)); return ANET_ERR; }

 
int yes = 1;
    if (setsockopt(fd, IPPROTO_TCP, TCP_NODELAY, &yes, sizeof(yes)) == -1)