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