分类： 嵌入式
2019-06-14 16:50:01
原文地址：lwip协议栈中超时定时器实现原理 作者：feng_yn
lwip协议栈中超时定时器实现原理
1，超时定时器存在的目的：
tcpip协议中存在很多需要定时处理的任务，包括一次性超时处理和周期性超时处理。
以tcp传输为例，每条连接总共需要建立七个定时器，依次为：
1）“连接建立”定时器。
如果建立连接启动后75秒内没收到响应，则中止建立。
2）“重传”定时器
在tcp发送某个数据段时设定，如果定时器超时了还没接收到对端的确认，则重传数据段。重传定时器值是动态计算的，与 RTT的估算密切相关，且还取决于该报文已被重传的次数。
3）“延迟ACK”定时器
tcp收到必须确认但无需马上发出确认的数据时设定， 如果在200ms内，有数据要在该连接上发送，延迟的ACK随数据一并发 送会对端，若200ms后仍未发出，则定时器超时，此时需要发送一个立即确认。
4）“持续”定时器
在连接对端通知接收窗口为0（缓存无足够空间），阻止发送端继续发送数据时设定。发送端停止发送数据，启动持续定时 器，超时后向对端发送1字节的数据，判断对端接收窗是否已打开。
5）“保活”定时器
定时器在tcp控制块的so_options字段设置了SOF_KEEPALIVE选项时生效。如果连接的空闲时间超过2小时，保活定时器超 时，此时向对端发送连接探测报文，强迫对端响应。如果收到响应，tcp可确认对端主机工作正常，如果收到RST复位响应，可确 认对端主机已重启，如果连续若干次保活测试都未收到响应，则tcp假定对端主机已崩溃，但无法区分是主机故障还是线路故障。
6）“FIN_WAIT_2”定时器
7）“TIME_WAIT”定时器（也称2MSL定时器）
2，lwip中超时定时器设计架构：
这里不讨论各个定时器与tcp协议有关的超时如何处理，只讲超时定时器本身的设计。
在lwip中，超时定时器代码实现在 src/core/timers.c中
超时定时器是按链表的形式进行组织的，并且按时间长短进行排序，时间最短的永远在最前面。定时器使用结构体struct sys_timeo进行定义，结构体定义如下：
struct sys_timeo {
struct sys_timeo *next; //指向下一个定时器
u32_t time; //定时值（ms），在加入链表时这个值会进行调整
sys_timeout_handler h; //定时器回调函数
void *arg; //回调函数传入参数
#if LWIP_DEBUG_TIMERNAMES
const char* handler_name; //回调函数名称，调试用
#endif /* LWIP_DEBUG_TIMERNAMES */
};
添加超时定时器，函数如下：
void sys_timeout(u32_t msecs, sys_timeout_handler handler, void *arg)
{
struct sys_timeo *timeout, *t;
/* 每个定时器都从对应的内存池中分配数据结构 */
timeout = (struct sys_timeo *)memp_malloc(MEMP_SYS_TIMEOUT);
if (timeout == NULL) {
LWIP_ASSERT("sys_timeout: timeout != NULL, pool MEMP_SYS_TIMEOUT is empty", timeout != NULL);
return;
}
timeout->next = NULL;
timeout->h = handler;
timeout->arg = arg;
timeout->time = msecs;
#if LWIP_DEBUG_TIMERNAMES
timeout->handler_name = handler_name;
LWIP_DEBUGF(TIMERS_DEBUG, ("sys_timeout: %p msecs=%"U32_F" handler=%s arg=%p\n",
(void *)timeout, msecs, handler_name, (void *)arg));
#endif /* LWIP_DEBUG_TIMERNAMES */
/* 如果创建的是第一个定时器，则不用特殊处理，next_timeout是一个全局指针，指向定时器链表中第一个定时器 */
if (next_timeout == NULL) {
next_timeout = timeout;
return;
}
/* 从第二个定时器开始就要添加到链表中，添加原则是定时最短的定时器始终在前面，如果新添加的定时器时长小于当前链首
定时器，则新添加的定时器成为链首，旧的链首定时器的定时值要减去新链首定时器定时值，这样旧定时器时长不变，如果新
添加的定时器大于等于当前链首定时器的时长，则要在整个链表里逐个比较，最终将其插入到比其短的定时器之后，比其长的
定时器之前，当然其后定时器的定时值也要进行调整，其前的定时器无需调整 */
if (next_timeout->time > msecs) {
next_timeout->time -= msecs;
timeout->next = next_timeout;
next_timeout = timeout;
} else {
for(t = next_timeout; t != NULL; t = t->next) {
timeout->time -= t->time;
if (t->next == NULL || t->next->time > timeout->time) {
if (t->next != NULL) {
t->next->time -= timeout->time;
}
timeout->next = t->next;
t->next = timeout;
break;
}
}
}
}
链表中定时器总是按时长升序进行排列，其定时值调整算法为：
Timer(x). time = Timer(x-1).time + Timer(x-2).time + ......
假如有4个定时器，如下：
Timer1.time = 10
Timer2.time = 5
Timer3.time = 20
Timer4time = 10
按1-4顺序都添加到链表中后，定时器值如下：
Timer1.time = 5
Timer2.time = 5
Timer3.time = 10
Timer4.time = 0
链接关系变为：
Timer2.next = Timer1
Timer1.next = Timer4
Timer4.next = Timer3
Timer3.next = NULL
此时，全局指针变量next_timeout指向Timer2。
3，lwip中超时定时器应用：
不管是否有os支持，超时定时器都可以使用。lwip中如下两个函数可以实现对超时的处理：
void sys_check_timeouts(void)
裸机应用程序在外部周期性调用该函数，每次进来检查定时器链表上定时最短的定时器是否到期，如果没有到期，直接退出该函数，否则，执行该定时器回调函数，并从链表上删除该定时器，然后继续检查下一个定时器，直到没有一个定时器到期退出
void sys_timeouts_mbox_fetch(sys_mbox_t *mbox, void **msg)
这个函数可在os线程中循环调用，主要是等待mbox消息，并可阻塞，如果等待mbox时超时，则会同时执行超时事件处理，即调用定时器回调函数，如果一直没有mbox消息，则会永久性地循环将所有超时定时器检查一遍，一举两得。
lwip中tcpip线程就是靠这种方法，即处理了上层及底层的mbox消息，同时处理了所有需要定时处理的事件。
