viayie / talkroom Goto Github PK

/*修改lfd为非阻塞*/
int flag = 0;
if ((flag = fcntl(lfd, F_SETFL, O_NONBLOCK)) < 0) {
    printf("%s: fcntl nonblocking failed, %s\n", __func__, strerror(errno));
    return;
}

/*端口复用*/
int opt = 1;
setsockopt(lfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));

/*初始化lfd*/
//void eventset(struct myevent_s *ev, int fd, void (*call_back)(int, int, void *), void *arg);
//将lfd放置在将自定义结构体数组的最后
//acceptconn()是lfd的回调函数
//arg是回调函数acceptconn()的参数，指向lfd带的结构体中ptr指向的自定义结构体
eventset(&g_events[MAX_EVENTS], lfd, acceptconn, &g_events[MAX_EVENTS]);

/*将lfd挂在红黑树上，设定监听事件为读事件*/
eventadd(efd, EPOLLIN, &g_events[MAX_EVENTS]);

/*绑定*/
struct sockaddr_in servaddr;
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = INADDR_ANY;
servaddr.sin_port = htons(port);
Bind(lfd, (struct sockaddr *)&servaddr, sizeof(servaddr));

/*监听*/
Listen(lfd, 128);

return;