Function loop

adapter/syscall/main_stack_thread_socket.c:75–212

}

void *loop(void *arg)
{
    /* kevent set */
    struct kevent kevSet;
    /* events */
    struct kevent events[MAX_EVENTS];
    /* kq */
    int kq;
    int sockfd;

    int thread_id;

    thread_id = *(int *)arg;
    printf("start thread %d\n", thread_id);

    sockfd = socket(AF_INET, SOCK_STREAM, 0);
    printf("thread %d, sockfd:%d\n", thread_id, sockfd);
    if (sockfd < 0) {
        printf("thread %d, ff_socket failed\n", thread_id);
        pthread_spin_unlock(&worker_lock);
        return NULL;
    }

    /* socket will init adapter,so unlock after socket */
    pthread_spin_unlock(&worker_lock);

    int on = 1;
    ioctl(sockfd, FIONBIO, &on);

    struct sockaddr_in my_addr;
    bzero(&my_addr, sizeof(my_addr));
    my_addr.sin_family = AF_INET;
    my_addr.sin_port = htons(80);
    my_addr.sin_addr.s_addr = htonl(INADDR_ANY);

    int ret = bind(sockfd, (const struct sockaddr *)&my_addr, sizeof(my_addr));
    if (ret < 0) {
        printf("thread %d, ff_bind failed\n", thread_id);
        close(sockfd);
        return NULL;
    }

    ret = listen(sockfd, MAX_EVENTS);
    if (ret < 0) {
        printf("thread %d, ff_listen failed\n", thread_id);
        close(sockfd);
        return NULL;
    }


    kq = kqueue();
    printf("thread %d, kq:%d\n", thread_id, kq);
    if (kq < 0) {
       printf("thread %d, ff_kqueue failed, errno:%d, %s\n", thread_id, errno, strerror(errno));
       close(sockfd);
       return NULL;
    }