背景：
Orthanc是本专栏中介绍过的一款新型DICOM服务器，具有轻量级、支持REST的特性，可将任意运行Windows和Linux系统的计算机变成DICOM服务器，即miniPACS。Orthanc内嵌多种模块，数据库管理简单，且不依赖于第三方软件。因此通过剖析Orthanc源码可以学习到搭建DICOM系统中的各个环节，例如SQLite嵌入型数据库、GoogleLog日志库、DCMTK医学DICOM库，以及近期要介绍的开源Web Server，Mongoose。
上一篇博文中简单的分析了Mongoose中连接请求触发的事件序列，调试输出结果大致上符合Fossa官网给出的*NS_ACCEPT->(NS_RECV->NS_SEND->NS_POLL…)->NS_CLOSE 流程，但是实际运行时刻由于网络环境实时变化，因此输出的调试日志中偶尔会出现多次NS_ACCEPT或者多次NS_POLL等等。博文末尾提到要想了解事件触发的真正原因，需要分析ns_poll_server函数源码，接下来通过分析Mongoose和Fossa的设计来对事件触发有一个更全面的了解。*
Mongoose事件
官方说明文档中对于Mongoose的描述是：
Mongosoe has single-threaded, event-driven, asynchronous, non-blocking core. 这个内核就是Fossa。这其中单线程（single-threaded）指的就是主线程中的mg_poll_server循环。
mg_poll_server函数内部遍历所有的有效连接，通过 select 异步方式监控各连接套接字来完成一次IO迭代操作。如此反复直至处理完毕。每当select返回，针对状态发生变化的套接字（有数据要发送或接收）进行IO操作。但是mg_poll_server本身并不完成循环遍历，需要外部循环调用mg_poll_server来实现实时监控连接状态。
查看代码的话发现mg_poll_server内部就是简单的调用了ns_mgr_poll函数，那么我们看一下Fossa对该函数的描述：
Fossa是一个支持多种协议的网络库，实现了非阻塞、异步IO处理，提供基于事件的API。Fossa的使用方式是，先声明并初始化事件处理程序，创建连接；最后通过循环调用ns_mgr_poll函数实现事件监控。ns_mgr_poll迭代遍历所有套接字，接收新连接、发送和接收数据、关闭连接，并根据 具体事件 调用相应的 事件处理函数。
Fossa中要求每个连接需要绑定事件处理函数，即event handler function，由用户自定义实现。事件处理是Fossa应用的核心元素——设定了程序的功能。Mongoose就是对Fossa的一次封装，规定了各种事件的默认处理程序，因此直接复制粘贴Mongoose官方文档中的示例代码就可以开启一个简单的Web Server，具体代码如下：
#include “mongoose.h”int main(void) {struct mg_server *server = mg_create_server(NULL, NULL);mg_set_option(server, “document_root”, “.”); // Serve current directorymg_set_option(server, “listening_port”, “8080”); // Open port 8080for (;;) {mg_poll_server(server, 1000); // Infinite loop, Ctrl-C to stop}mg_destroy_server(&server);return 0;}
上述代码中并未像Fossa官网所述，给出用户自定义的事件处理函数却能顺利开启Web Server（ 详情可参考博文DICOM：剖析Orthanc中的Web Server, Mongoose ），这恰恰说明了Mongoose在对Fossa进行封装时给出了默认的事件处理函数，即mg_ev_handler，在该函数内部规定了Fossa中各种事件的处理流程，由于代码过长此处就不贴出来了，详情可参考Link:mg_ ev_handler。所以在使用Mongoose时主要关注的是自定义事件，另外Mongoose对Fossa的事件进行了简单的再封装，以MG_开头来标记事件，诸如MG_AUTH、MG_REQUEST、MG_CONNECT、MG_REPLY。
Fossa标志
由上面介绍了解到Mongoose重点是对Fossa的自定义事件进行二次封装，其主要贡献是设计了Fossa事件的默认处理流程函数，即上面提到的mg_ev_handler。因此要想解决上一篇博文中的疑问事件真正触发的原因是什么？ 。通过分析mg_ev_handler源码只能是了解了Fossa事件的触发机制，并未真正了解原因。因此要想解决疑惑，需要分析Fossa的处理核心，即ns_mgr_poll 。在Fossa中对于每一个连接都包含相应的flag bit field，即标志位、状态位或特征位。而flag bit目的就是用于区别连接（这里的连接是名词，代表所有与Fossa相关的请求。在Fossa中将连接分为三类，即Inbound、Outbound和Listening）整个生命周期所处的不同阶段，对每个阶段用一个flag来表示。 ns_mgr_poll正是根据flag bit来分情况处理各种连接，比如添加新连接、开始读取数据、开始发送数据、关闭连接等等；也正是由于flag bit将连接的各个阶段区分开来，才使得能够将不同阶段的处理进行模式化，也就是事件化 。
所以要想搞清楚之前博文中事件的触发流程，根本是需要了解Fossa和Mongoose是如何用flag bit来表示连接的各个阶段的。Fossa官方文档指出每个连接都有标志位域。Fossa针对不同协议定义了多种标志，其中一些标志由Fossa来设置，部分标志需要由外部用户自定义的事件处理函数来设置（以此来完成用户与Fossa的交互）。下面列举主要的标志：
以上标志位都是由外部用户自定义的事件处理函数来设置的，下面看一下Fossa内部设置的标志位，
根据标志位名称大致猜测出标志位是跟连接建立过程 或连接具体状态 相关，由此可知标志位域（flag bit field） 关乎http web server的处理流程，是Fossa和Mongoose开源库内部的核心逻辑，所以需要Fossa内部自己实现。 ——开源库中往往都会将协议规定的流程化部分自己实现，只将可定制化部分交由用户自定义。
找准了问题入手的方向，，下面就以Mongoose官方文档为例进行实例测试：
实例测试
为了方便查看，再一次将官方安装说明中的代码贴在此处，如下：
#include “mongoose.h”int main(void) {struct mg_server *server = mg_create_server(NULL, NULL);mg_set_option(server, “document_root”, “.”); // Serve current directorymg_set_option(server, “listening_port”, “8080”); // Open port 8080for (;;) {mg_poll_server(server, 1000); // Infinite loop, Ctrl-C to stop}mg_destroy_server(&server);return 0;}
另外为了跟踪Fossa的ns_mgr_poll函数中各阶段标志位的情况，对mongoose.c中的ns_mgr_poll代码修改，添加相应的调试输出信息。具体修改如下：
time_t ns_mgr_poll(struct ns_mgr *mgr, int milli) {int loop=0;struct ns_connection *conn, *tmp_conn;struct timeval tv;fd_set read_set, write_set;sock_t max_fd = INVALID_SOCKET;time_t current_time = time(NULL);FD_ZERO(&read_set);FD_ZERO(&write_set);ns_add_to_set(mgr->ctl[1], &read_set, &max_fd);for (conn = mgr->active_connections; conn != NULL; conn = tmp_conn) {printf(“The for loop in adding sock or conn section is %d times\n”,loop++);//Just for debuggingtmp_conn = conn->next;if (!(conn->flags & (NSF_LISTENING | NSF_CONNECTING))) {printf(“For the Flag –%d– ,For the sock –%d–,Call user ev_handler for NS_POLL\n”,conn->flags,(conn->sock!=NULL?conn->sock:-1));//Just for debuggingns_call(conn, NS_POLL, ¤t_time);}if (!(conn->flags & NSF_WANT_WRITE)) {//DBG((“%p read_set”, conn));printf(“For the Flag –%d–,For the sock –%d–, call ns_add_to_set function!\n”,conn->flags,(conn->sock!=NULL?conn->sock:-1));//Just for debuggingns_add_to_set(conn->sock, &read_set, &max_fd);}if (((conn->flags & NSF_CONNECTING) && !(conn->flags & NSF_WANT_READ)) ||(conn->send_iobuf.len > 0 && !(conn->flags & NSF_CONNECTING) &&!(conn->flags & NSF_BUFFER_BUT_DONT_SEND))) {//DBG((“%p write_set”, conn));printf(“For the Flag –%d–2–,For the sock –%d– call ns_add_to_set function!\n”,conn->flags,(conn->sock!=NULL?conn->sock:-1));//Just for debuggingns_add_to_set(conn->sock, &write_set, &max_fd);}if (conn->flags & NSF_CLOSE_IMMEDIATELY) {printf(“For the Flag –%d–, For the sock –%d– call ns_close_conn function!\n”,conn->flags,(conn->sock!=NULL?conn->sock:-1));//Just for debuggingns_close_conn(conn);}}tv.tv_sec = milli / 1000;tv.tv_usec = (milli % 1000) * 1000;loop=0;if (select((int) max_fd + 1, &read_set, &write_set, NULL, &tv) > 0) {// select() might have been waiting for a long time, reset current_time// now to prevent last_io_time being set to the past.current_time = time(NULL);// Read wakeup messagesif (mgr->ctl[1] != INVALID_SOCKET &&FD_ISSET(mgr->ctl[1], &read_set)) {struct ctl_msg ctl_msg;int len = (int) recv(mgr->ctl[1], (char *) &ctl_msg, sizeof(ctl_msg), 0);send(mgr->ctl[1], ctl_msg.message, 1, 0);if (len >= (int) sizeof(ctl_msg.callback) && ctl_msg.callback != NULL) {struct ns_connection *c;for (c = ns_next(mgr, NULL); c != NULL; c = ns_next(mgr, c)) {ctl_msg.callback(c, NS_POLL, ctl_msg.message);}}};for (conn = mgr->active_connections; conn != NULL; conn = tmp_conn) {printf(“The for loop in select section is %d times\n”,loop++);tmp_conn = conn->next;if (FD_ISSET(conn->sock, &read_set)) {if (conn->flags & NSF_LISTENING) {printf(“For the Flag –%d–, For the sock –%d–, NSF_LISTENING!\n”,conn->flags,(conn->sock!=NULL?conn->sock:-1));//Just for debuggingif (conn->flags & NSF_UDP) {printf(“For the Flag –%d–,For the sock –%d–, call ns_handler_udp function!\n”,conn->flags,(conn->sock!=NULL?conn->sock:-1));//Just for debuggingns_handle_udp(conn);} else {// We’re not looping here, and accepting just one connection at// a time. The reason is that eCos does not respect non-blocking// flag on a listening socket and hangs in a loop.printf(“For the Flag –%d–,For the sock –%d– call accept_conn function!\n”,conn->flags,(conn->sock!=NULL?conn->sock:-1));//Just for debuggingaccept_conn(conn);}} else {conn->last_io_time = current_time;printf(“For the Flag –%d–,For the sock –%d– call ns_read_from_socket function!\n”,conn->flags,(conn->sock!=NULL?conn->sock:-1));//Just for debuggingns_read_from_socket(conn);}}if (FD_ISSET(conn->sock, &write_set)) {if (conn->flags & NSF_CONNECTING) {printf(“For the Flag –%d–,For the sock –%d– call ns_read_from_socket function!\n”,conn->flags,(conn->sock!=NULL?conn->sock:-1));//Just for debuggingns_read_from_socket(conn);} else if (!(conn->flags & NSF_BUFFER_BUT_DONT_SEND)) {conn->last_io_time = current_time;printf(“For the Flag –%d–,For the sock –%d– call ns_write_to_socket function!\n”,conn->flags,(conn->sock!=NULL?conn->sock:-1));//Just for debuggingns_write_to_socket(conn);}}}}loop=0;for (conn = mgr->active_connections; conn != NULL; conn = tmp_conn) {printf(“The for loop in the close section is %d times\n”,loop++);tmp_conn = conn->next;if ((conn->flags & NSF_CLOSE_IMMEDIATELY) ||(conn->send_iobuf.len == 0 &&(conn->flags & NSF_FINISHED_SENDING_DATA))) {printf(“For the Flag –%d–2–,For the sock –%d– call ns_close_conn function!\n”,conn->flags,(conn->sock!=NULL?conn->sock:-1));//Just for debuggingns_close_conn(conn);}}return current_time;}
【注】：代码中的printf输出语句就是为了方便调试添加的，待测试完毕请自行删除，以免影响Mongoose服务器性能。
测试结果明天的希望，让我们忘了今天的痛苦
