//接收一个新的连接connection*connection_accept(server*srv, server_socket*srv_socket) {/*accept everything*//*search an empty place*/intcnt;

sock_addr cnt_addr;

socklen_t cnt_len;/*accept it and register the fd*//**

* check if we can still open a new connections

*

* see #1216*///如果正在使用的连接数大于最大连接数 就返回NULLif(srv->conns->used>=srv->max_conns) {returnNULL;

}

cnt_len=sizeof(cnt_addr);if(-1==(cnt=accept(srv_socket->fd, (structsockaddr*)&cnt_addr,&cnt_len))) {switch(errno) {caseEAGAIN:#ifEWOULDBLOCK != EAGAINcaseEWOULDBLOCK:#endifcaseEINTR:/*we were stopped _before_ we had a connection*/caseECONNABORTED:/*this is a FreeBSD thingy*//*we were stopped _after_ we had a connection*/break;caseEMFILE:/*out of fds*/break;default:

log_error_write(srv, __FILE__, __LINE__,"ssd","accept failed:", strerror(errno), errno);

}returnNULL;

}else{

connection*con;//当前使用的fd数量+1srv->cur_fds++;/*ok, we have the connection, register it*///打开的connection+1(这个成员貌似没有用)srv->con_opened++;//获取一个新的connectioncon=connections_get_new_connection(srv);//保存接收到的fdcon->fd=cnt;//索引为-1con->fde_ndx=-1;#if0gettimeofday(&(con->start_tv), NULL);#endif//注册函数指针和connection指针fdevent_register(srv->ev, con->fd, connection_handle_fdevent, con);//状态为可以接收请求connection_set_state(srv, con, CON_STATE_REQUEST_START);//保存接收连接的时间con->connection_start=srv->cur_ts;//保存目标地址con->dst_addr=cnt_addr;

buffer_copy_string(con->dst_addr_buf, inet_ntop_cache_get_ip(srv,&(con->dst_addr)));//保存server_socket指针con->srv_socket=srv_socket;//设置一下接收来的FD, 设置为非阻塞if(-1==(fdevent_fcntl_set(srv->ev, con->fd))) {

log_error_write(srv, __FILE__, __LINE__,"ss","fcntl failed:", strerror(errno));returnNULL;

}

#ifdef USE_OPENSSL/*connect FD to SSL*/if(srv_socket->is_ssl) {if(NULL==(con->ssl=SSL_new(srv_socket->ssl_ctx))) {

log_error_write(srv, __FILE__, __LINE__,"ss","SSL:",

ERR_error_string(ERR_get_error(), NULL));returnNULL;

}

SSL_set_accept_state(con->ssl);

con->conf.is_ssl=1;if(1!=(SSL_set_fd(con->ssl, cnt))) {

log_error_write(srv, __FILE__, __LINE__,"ss","SSL:",

ERR_error_string(ERR_get_error(), NULL));returnNULL;

}

}#endifreturncon;

}

}