Ril分析三——客户端请求和响应处理与modem交互

　　　　Ril与modem的交互

一 客户端的请求处理

客户端请求从EventLoop通过dispatch传递到reference-ril.c中调用onRequest接口。
　　

　　　　

处理客户端请求：

static void onRequest (int request, void *data, size_t datalen, RIL_Token t) { switch (request) { case RIL_REQUEST_DIAL: requestDial(data, datalen, t); break; …… } }

 

二 AT Command发送

将客户端请求转化成AT命令：

 

static void requestDial(void *data, size_t datalen, RIL_Token t) { RIL_Dial *p_dial; char *cmd;
 //转化成AT命令
    p_dial = (RIL_Dial *)data; asprintf(&cmd, "ATD%s%s;", p_dial->address, clir);
 //发送AT命令
    ret = at_send_command(cmd, NULL); //请求处理完成回调
    RIL_onRequestComplete(t, RIL_E_SUCCESS, NULL, 0); }

发送AT Command：

static int at_send_command_full_nolock (const char *command, 　　　　　　　　　　　　　　　　　　　　　　ATCommandType type,……) { //将数据写入到mdoem设备文件节点中
　　err = writeline (command); //休眠等待写入的数据被读取
    while (sp_response->finalResponse == NULL && s_readerClosed == 0) { err = pthread_cond_wait(&s_commandcond, &s_commandmutex); } return err; }

将数据写入modem设备节点中：

static int writeline (const char *s) { //写入数据到设备文件描述符s_fd
    while (cur < len) { do { written = write (s_fd, s + cur, len - cur); } while (written < 0 && errno == EINTR); cur += written; }
 //返回行首
    do { written = write (s_fd, "\r" , 1); } while ((written < 0 && errno == EINTR) || (written == 0)); return 0; }

 

　　这样就将数据写入到设备文件描述符s_fd，将AT Command传递给Modem了；

　　在数据被读取之前处于休眠状态。数据写入被读取之后，方才返回。

　　那么s_fd代表的的设备是如何设置的，读数据又是怎么进行的呢。

三 Modem响应请求处理

　　通过AT Command将命令发给了Modem，等待Modem处理此请求，然后将结果返回来，

读取之后进行处理，然后表示此请求Complete，并且通知 Client。

过程如下：

　　　　

 

　　这个Serial Prot是什么，Reader Loop是什么呢。回到rild进程main函数中看看。

在rild进程的main函数中：

int main(int argc, char **argv) { //处理客户端请求的模块reference-ril.c 调用RIL_Init
    funcs_inst[0] = rilInit(&s_rilEnv, argc, s_argv); …… }

reference-ril初始化函数：

RIL_RadioFunctions *RIL_Init(const struct RIL_Env *env, int argc, char **argv) { //交互的接口
    s_rilenv = env; //提取modem设备端口或者路径 　　//此处是d 根据前面属性系统获取参数：rild.libargs=-d /dev/ttyS0 　　// getopt的使用 提取选项
    while ( -1 != (opt = getopt(argc, argv, "p:d:s:c:"))) { switch (opt) { case 'd': s_device_path = optarg; break; } } //创建线程s_tid_mainloop
　　ret = pthread_create(&s_tid_mainloop, &attr, mainLoop, NULL); //返回请求交互的接口
    return &s_callbacks; }

s_tid_mainloop线程的执行体：

static void *mainLoop(void *param) { at_set_on_reader_closed(onATReaderClosed); at_set_on_timeout(onATTimeout); for (;;) { fd = open (s_device_path, O_RDWR); s_closed = 0; ret = at_open(fd, onUnsolicited); RIL_requestTimedCallback(initializeCallback, NULL, &TIMEVAL_0); // Give initializeCallback a chance to dispatched, since // we don't presently have a cancellation mechanism
        sleep(1); waitForClose(); } }

这里打开了modem的设备文件描述符fd，传递给了at_open()：

int at_open(int fd, ATUnsolHandler h) { //与modem设备通信文件描述符
    s_fd = fd;
 //网络端传来事件请求处理onUnsolicited
    s_unsolHandler = h; s_readerClosed = 0;
 //创建线程s_tid_reader
    ret = pthread_create(&s_tid_reader, &attr, readerLoop, &attr); return 0; }

线程执行体readerLoop()：

static void *readerLoop(void *arg) { for (;;) { //从与modem通信设备端口读取数据
        line = readline(); if (line == NULL) { break; } //处理数据
 processLine(line); } onReaderClosed(); return NULL; }

来自Modem端数据处理：

static void processLine(const char *line) { if (sp_response == NULL) { //来自网络端事件
 handleUnsolicited(line); } else if (isFinalResponseSuccess(line)) { //客户端请求处理返回
        sp_response->success = 1; handleFinalResponse(line); 　　} 　　…… }

来自网络端事件：

static void handleUnsolicited(const char *line) { // 回调接口onUnsolicited
    if (s_unsolHandler != NULL) { s_unsolHandler(line, NULL); } }

客户端请求处理返回：

static void handleFinalResponse(const char *line) { //保存modem端响应请求所传递的数据
    sp_response->finalResponse = strdup(line);
 //发送signal 唤醒等待s_commandcond的线程——Event Loop
    pthread_cond_signal(&s_commandcond); }

 

整个数据流程图如下：

图片来自：http://blog.csdn.net/maxleng/article/details/5576637