9.3.2 RIL_startEventLoop分析
最后更新于：2022-04-02 05:53:33
第一个关键点是RIL_startEventLoop函数，这个函数实际上是由libRil.so实现的，它的代码在Ril.cpp中，代码如下所示：
**Ril.cpp**
~~~
extern "C" void RIL_startEventLoop(void){
intret;
pthread_attr_t attr;
s_started= 0;
pthread_mutex_lock(&s_startupMutex);
pthread_attr_init (&attr);
pthread_attr_setdetachstate(&attr,PTHREAD_CREATE_DETACHED);
//创建工作线程eventLoop
ret =pthread_create(&s_tid_dispatch, &attr, eventLoop, NULL);
/*
工作线程eventLoop运行后会设置s_started为1，并触发s_startupCond。
这几个语句的目的是保证在RIL_startEventLoop返回前，工作线程一定是已经创建并运行了
*/
while(s_started == 0) {
pthread_cond_wait(&s_startupCond, &s_startupMutex);
}
pthread_mutex_unlock(&s_startupMutex);
if(ret < 0) {
return;
}
}
~~~
从上面代码中可知，RIL_startEventLoop会等待工作线程创建并运行成功。这个线程为什么会如此重要呢？下面就来了解一下工作线程eventLoop。
1. 工作线程eventLoop
工作线程eventLoop的代码如下所示：
**Ril.cpp**
~~~
static void * eventLoop(void *param) {
intret;
intfiledes[2];
//①初始化请求队列
ril_event_init();
//下面这几个操作告诉RIL_startEventLoop函数本线程已经创建并成功运行了。
pthread_mutex_lock(&s_startupMutex);
s_started = 1;
pthread_cond_broadcast(&s_startupCond);
pthread_mutex_unlock(&s_startupMutex);
//创建匿名管道
ret =pipe(filedes);
......
s_fdWakeupRead = filedes[0];
s_fdWakeupWrite = filedes[1];
//设置管道读端口的属性为非阻塞
fcntl(s_fdWakeupRead, F_SETFL, O_NONBLOCK);
//②下面这两句话将匿名管道的读写端口加入到event队列中。
ril_event_set (&s_wakeupfd_event, s_fdWakeupRead, true,
processWakeupCallback, NULL);
rilEventAddWakeup (&s_wakeupfd_event);
//③进入事件等待循环中，等待外界触发事件并做对应的处理。
ril_event_loop();
returnNULL;
}
~~~
工作线程的工作并不复杂，主要有三个关键点。
（1）ril_event_init的分析
工作线程，顾名思义就是用来干活的。要让它干活，是否得有一些具体的任务呢？它是如何管理这些任务的呢？对这两问题的回答是：
- 工作线程使用了一个叫ril_event的结构体，来描述一个任务，并且它将多个任务按时间顺序组织起来，保存在任务队列中。这个时间顺序是指该任务的执行时间，由外界设定，可以是未来的某时间。
r
il_event_init函数就是用来初始化相关队列和管理结构的，代码如下所示：
在代码中，“任务”也称为“事件”，如没有特殊说明必要，这两者以后不再做区分。
**Ril.cpp**
~~~
void ril_event_init()
{
MUTEX_INIT();//初始化一个mutex对象listMutex
FD_ZERO(&readFds);//初始化readFds，看来Ril会使用select来做多路IO复用
//下面的timer_list和pending_list分别是两个队列
init_list(&timer_list);//初始化timer_list，任务插入的时候按时间排序
init_list(&pending_list);//初始化pendling_list，保存每次需要执行的任务
/*
watch_table（监控表）定义如下：
static struct ril_event * watch_table[MAX_FD_EVENTS];
其中MAX_FD_EVENTS的值为8。监控表主要用来保存那些FD已经加入到readFDs中的
任务。
*/
memset(watch_table, 0, sizeof(watch_table));
}
~~~
此ril_event_init函数没什么新鲜的内容。任务在代码中的对等物Ril_event结构的代码，如下所示：
**Ril_event.h**
~~~
struct ril_event {
structril_event *next;
structril_event *prev;//next和prev将ril_event组织成了一个双向链表
intfd; //该任务对应的文件描述符，以后简称FD。
intindex; //这个任务在监控表中的索引
/*
是否永久保存在监控表中，一个任务处理完毕后将根据这个persist参数来判断
是否需要从监控表中移除。
*/
boolpersist;
structtimeval timeout; //该任务的执行时间
ril_event_cb func; //任务函数
void*param; //传给任务函数的参数
};
~~~
ril_event_init刚初始化完任务队列，下面就有地方添加任务了。
（2）任务加入队列
下面这两行代码初始化一个FD为s_wakeupfd_event的任务，并将其加入到监控表中：
~~~
/*
s_wakeupfd_event定义为一个静态的ril_event，ril_event_set函数将初始化它的
FD为管道的读端，任务函数ril_event_cb对应为processWakeupCallback，
并设置persist为true
*/
ril_event_set (&s_wakeupfd_event, s_fdWakeupRead,true,
processWakeupCallback, NULL);
//来看这个函数：
rilEventAddWakeup (&s_wakeupfd_event);
~~~
rilEventAddWakeup比较有意思，来看这个函数;
**Ril.cpp**
~~~
static void rilEventAddWakeup(struct ril_event*ev) {
ril_event_add(ev);//ev指向一条任务
triggerEvLoop();
}
//直接看ril_event_add函数和triggerEvLoop函数。
void ril_event_add(struct ril_event * ev)
{
......
MUTEX_ACQUIRE();//锁保护
for (int i =0; i < MAX_FD_EVENTS; i++) {
//从监控表中找到第一个空闲的索引，然后把这个任务加到监控表中，
//index表示这个任务在监控中的索引
if(watch_table[i] == NULL) {
watch_table[i] = ev;
ev->index = i;
......
//将任务的FD加入到readFds中，这是select使用的标准方法
FD_SET(ev->fd, &readFds);
if (ev->fd >= nfds) nfds = ev->fd+1;
......
break;
}
}
MUTEX_RELEASE();
......
}
//再来看triggerEvLoop函数，这个更简单了:
static void triggerEvLoop() {
intret;
/*
s_tid_dispatch是工作线程eventLoop的线程ID，pthread_self返回调用线程的线程ID。
由于这里调用triggerEvLoop的就是eventLoop自己，所以不会走if 分支。但是可以看看
里面的内容。
*/
if(!pthread_equal(pthread_self(), s_tid_dispatch)) {
do{
//s_fdWakeupWrite为匿名管道的写端口，看来触发eventLoop工作的条件就是
//往这个端口写一点数据了。
ret = write (s_fdWakeupWrite, " ", 1);
}while (ret < 0 && errno == EINTR);
}
}
~~~
一般的线程间通信使用同步对象来触发，而rild是通过往匿名管道写数据来触发工作线程工作的。
（3）ril_event_loop的分析
来看最后一个关键函数ril_event_loop，其代码如下所示：
**Ril.cpp**
~~~
void ril_event_loop()
{
int n;
fd_setrfds;
structtimeval tv;
structtimeval * ptv;
for(;;) {
memcpy(&rfds, &readFds,sizeof(fd_set));
/*
根据timer_list来计算select函数的等待时间，timer_list已经
按任务的执行时间排好序了。
*/
if(-1 == calcNextTimeout(&tv)) {
ptv = NULL;
}else {
ptv = &tv;
}
......;
//调用select进行多路IO复用
n= select(nfds, &rfds, NULL, NULL, ptv);
......
//将timer_list中那些执行时间已到的任务移到pending_list队列。
processTimeouts();
//从监控表中转移那些有数据要读的任务到pending_list队列，如果任务的persisit不为
//true，则同时从监控表中移除这些任务
processReadReadies(&rfds, n);
//遍历pending_list，执行任务的任务函数。
firePending();
}
}
~~~
根据对ril_event_Loop函数的分析可知，Rild支持两种类型的任务：
- 定时任务。它的执行由执行时间决定，和监控表没有关系，在Ril.cpp中由ril_timer_add函数添加。
- 非定时任务，也叫Wakeup Event。这些任务的FD将加入到select的读集合（readFDs）中，并且在监控表中存放了对应的任务信息。它们触发的条件是这些FD可读。对于管道和Socket来说，FD可读意味着接收缓冲区中有数据，这时调用recv不会因为没有数据而阻塞。
对于处于listen端的socket来说，FD可读表示有客户端连接上了，此时需要调用accept接受连接。
2. RIL_startEventLoop小结
总结一下RIL_startEventLoop的工作。从代码中看，这个函数将启动一个比较重要的工作线程eventLoop，该线程主要用来完成一些任务处理，而目前还没有给它添加任务。
';