Contiki學(xué)習(xí)筆記：深入理解process_run函數(shù)

Jelline

摘要：

    process_run用于處理系統(tǒng)所有needspoll標(biāo)記為1的進(jìn)程及處理事件隊列的下一個事件。本文深入原碼，詳細(xì)分析，也包括do_poll和do_event函數(shù)。

一、運(yùn)行process_run

1. int main()
   
2. {
   
3.   dbg_setup_uart();
   
4.   usart_puts("Initialising\n");
   
5. 
   
6.   clock_init();
   
7.   process_init();
   
8.   process_start(&etimer_process, NULL);
   
9.   autostart_start(autostart_processes);
   
10. 
    
11.   while (1)
    
12.   {
    
13.     /*執(zhí)行完所有needspoll為1的進(jìn)程及處理完所有隊列*/
    
14.     do
    
15.     {
    
16.     }
    
17.     while (process_run() > 0);
    
18.   }
    
19.   return 0;
    
20. }

二、process_run剖析

process_run處理系統(tǒng)所有needspoll標(biāo)記為1的進(jìn)程及處理事件隊列的下一個事件，源代碼如下：

1. static volatile unsigned char poll_requested; //全局靜態(tài)變量，標(biāo)識系統(tǒng)是否有needspoll為1的進(jìn)程
   
2. 
   
3. int process_run(void)
   
4. {
   
5.   if (poll_requested) //進(jìn)程鏈表有needspoll為1的進(jìn)程
   
6.   {
   
7.     do_poll(); //見2.1
   
8.   }
   
9. 
   
10.   do_event(); //見2.2
    
11. 
    
12.   return nevents + poll_requested; //若和為1，則表示處理完系統(tǒng)的所有事件，并且沒有needspoll為1的進(jìn)程
    
13. }

    透過上述的源代碼，可以直觀看出needspoll標(biāo)記為1的進(jìn)程可以優(yōu)先執(zhí)行。并且每執(zhí)行一次process_run，將處理系統(tǒng)所有needspoll標(biāo)記為1的進(jìn)程，而只處理事件隊列的一個事件。

2.1 do_poll函數(shù)

    復(fù)位全局變量poll_requested，遍歷整個進(jìn)程鏈表，將needspoll標(biāo)記為1的進(jìn)程投入運(yùn)行，并將相應(yīng)的needspoll復(fù)位。源代碼如下：

1. static void do_poll(void)
   
2. {
   
3.   struct process *p;
   
4.   poll_requested = 0; //復(fù)位全局變量
   
5. 
   
6.   for (p = process_list; p != NULL; p = p->next) //處理所有needspoll為1的進(jìn)程
   
7.   {
   
8.     if (p->needspoll) //將needspoll為1的進(jìn)程投入執(zhí)行
   
9.     {
   
10.       p->state = PROCESS_STATE_RUNNING;
    
11.       p->needspoll = 0;
    
12.       call_process(p, PROCESS_EVENT_POLL, NULL);
    
13.     }
    
14.   }
    
15. }

    call_process函數(shù)剖析見博文《Contiki學(xué)習(xí)筆記：啟動一個進(jìn)程process_start 》第三部分。

2.2 do_event函數(shù)

    do_event處理事件隊列的一個事件，有兩種事件需特殊處理：PROCESS_BROADCAST和PROCESS_EVENT_INIT。前者是廣播事件，需處理所有進(jìn)程，后者是初始化事件，需將進(jìn)程狀態(tài)設(shè)為PROCESS_STATE_RUNNING，以確保該進(jìn)程被進(jìn)程了。源代碼如下：

1. static process_num_events_t nevents; /*事件隊列的總事件數(shù) */
   
2. static process_num_events_t fevent; /*指向下一個要傳遞的事件的位置*/
   
3. static struct event_data events[PROCESS_CONF_NUMEVENTS]; /*事件隊列，用數(shù)組存儲，邏輯上是環(huán)形隊列*/
   
4. 
   
5. static void do_event(void)
   
6. {
   
7.   /*以下3個變量恰為struct event_data的成員，用于暫存即將處理(fevent事件)的值*/
   
8.   static process_event_t ev;
   
9.   static process_data_t data;
   
10.   static struct process *receiver;
    
11. 
    
12.   static struct process *p;
    
13. 
    
14.   if (nevents > 0)
    
15.   {
    
16.     /*提取將要處理事件的成員變量*/
    
17.     ev = events[fevent].ev;
    
18.     data = events[fevent].data;
    
19.     receiver = events[fevent].p;
    
20.     
    
21.     fevent = (fevent + 1) % PROCESS_CONF_NUMEVENTS; //更新fevent(指向下一個待處理的事件，類型于微機(jī)的PC)
    
22.     --nevents; //事件隊列被組織成環(huán)形隊列，所以取余數(shù)
    
23. 
    
24.     if (receiver == PROCESS_BROADCAST) //如果事件是廣播事件PROCESS_BROADCAST，則處理所有進(jìn)程
    
25.     {
    
26.       for (p = process_list; p != NULL; p = p->next)
    
27.       {
    
28.         if (poll_requested)
    
29.         {
    
30.           do_poll();
    
31.         }
32.         call_process(p, ev, data); //jelline note: call the receiver process twice??
    
33.       }
    
34.     }
    
35.     else
    
36.     {
    
37.       if (ev == PROCESS_EVENT_INIT) //若事件是初始化，設(shè)置進(jìn)程狀態(tài)，確保進(jìn)程狀態(tài)為PROCESS_STATE_RUNNING
    
38.       {
    
39.         receiver->state = PROCESS_STATE_RUNNING;
    
40.       }
41.       call_process(receiver, ev, data);
    
42.     }
    
43.   }
    
44. }

call_process函數(shù)剖析見博文《Contiki學(xué)習(xí)筆記：啟動一個進(jìn)程process_start 》第三部分。