【正文】 buzzer_mask蜂鳴器設(shè)備操作掩碼dev_uart_mask串口發(fā)送命令掩碼pthread_cond_tcond_ledLED設(shè)備被喚醒條件變量cond_camera攝像頭設(shè)備被喚醒條件變量cond_buzzer蜂鳴器設(shè)備被喚醒條件變量cond_refresh內(nèi)存刷新線程被喚醒條件變量cond_uart_cmd串口發(fā)送命令線程被喚醒條件變量cond_sqlite數(shù)據(jù)庫線程被喚醒條件變量pthread_mutex_tmutex_global倉庫實(shí)時(shí)信息變量保護(hù)互斥鎖mutex_uart_cmd串口發(fā)送命令模塊互斥鎖mutex_ledLED模塊互斥鎖mutex_buzzer蜂鳴器模塊互斥鎖mutex_camera攝像頭模塊互斥鎖mutex_slinklist數(shù)據(jù)庫數(shù)據(jù)緩存鏈表互斥鎖intmsgid消息隊(duì)列IDstruct env_info_clien_addrall_info_RT實(shí)時(shí)倉庫信息全局變量3. 流程圖4. 詳細(xì)說明本線程主要用來接收從消息隊(duì)列里傳入的請求,主要是硬件設(shè)備的操作,包括A8與M0上的硬件資源的操作,同時(shí)也能接收CGI與QT修改倉庫各種上下限的值,本線程大部分完成的是一個(gè)數(shù)據(jù)的轉(zhuǎn)發(fā)過程,因?yàn)橥ㄐ诺慕Y(jié)構(gòu)在發(fā)送線程與設(shè)備之間已經(jīng)定義好了相應(yīng)的協(xié)議。include include extern unsigned char dev_led_mask。extern unsigned char dev_camera_mask。extern unsigned char dev_buzzer_mask。extern unsigned char dev_uart_mask。extern pthread_cond_t cond_led。extern pthread_cond_t cond_camera。extern pthread_cond_t cond_buzzer。extern pthread_cond_t cond_refresh。extern pthread_cond_t cond_uart_cmd。extern pthread_cond_t cond_sqlite。extern pthread_mutex_t mutex_global。extern pthread_mutex_t mutex_uart_cmd。extern pthread_mutex_t mutex_led。extern pthread_mutex_t mutex_buzzer。extern pthread_mutex_t mutex_camera。extern pthread_mutex_t mutex_slinklist。extern char cgi_status。extern int msgid。extern struct env_info_clien_addr all_info_RT。 extern dota_cache_list m0_cache_head, m0_cache_tail。struct setEnv{ int temMAX。 int temMIN。 int humMAX。 int humMIN。 int illMAX。 int illMIN。}。void *pthread_client_request (void *arg){ key_t key。 ssize_t msgsize。 struct msg msgbuf。 struct setEnv new。 int sto_no。 if ((key = ftok (/app, 39。g39。)) 0) { perror (ftok msgqueue)。 exit (1)。 } if ((msgid = msgget (key, IPC_CREAT | IPC_EXCL | 0666)) 0) { perror (msgget msgid)。 exit (1)。 } m0_cache_head = CreateEmptyCacheList ()。 m0_cache_tail = m0_cache_head。 unsigned char *m0_temp。 printf (pthread_client_request is ok\n)。 while (1) { bzero (amp。msgbuf, sizeof (msgbuf))。 msgsize = msgrcv (msgid, amp。msgbuf, sizeof (msgbuf) sizeof (long), 1L, 0)。 switch () { case 1L: { pthread_mutex_lock (amp。mutex_led)。 dev_led_mask = [0]。 pthread_cond_signal (amp。cond_led)。 pthread_mutex_unlock (amp。mutex_led)。 break。 } case 2L: { pthread_mutex_lock (amp。mutex_buzzer)。 dev_buzzer_mask = [0]。 pthread_cond_signal (amp。cond_buzzer)。 pthread_mutex_unlock (amp。mutex_buzzer)。 break。 } case 3L: { pthread_mutex_lock (amp。mutex_camera)。 dev_camera_mask = [0]。 pthread_cond_signal (amp。cond_camera)。 pthread_mutex_unlock (amp。mutex_camera)。 break。 } case 4L: { pthread_mutex_lock (amp。mutex_uart_cmd)。 m0_temp = (unsigned char *)malloc (sizeof (unsigned char))。 *m0_temp = [0]。 InsertCacheNode (amp。m0_cache_tail, m0_temp)。 pthread_mutex_unlock (amp。mutex_uart_cmd)。 pthread_cond_signal (amp。cond_uart_cmd)。 break。 } case 5L: { memcpy (amp。new, + 1, 24)。 sto_no = [0] 48。 printf (sto_no = %d temMAX = %d, temMIN = %d, humMAX = %d, hunMIN = %d, illMAX = %d, illMIN = %d\n, sto_no, , , , , , )。 pthread_mutex_lock (amp。mutex_global)。 if ( 0 amp。amp。 [sto_no].temperatureMIN) { [sto_no].temperatureMAX = 。 } if ( 0 amp。amp。 [sto_no].temperatureMAX) { [sto_no].temperatureMIN = 。 } if ( 0 amp。amp。 [sto_no].humidityMIN) { [sto_no].humidityMAX = 。 } if ( 0 amp。amp。 [sto_no].temperatureMAX) { [sto_no].humidityMIN = 。 } if ( 0 amp。amp。 [sto_no].illuminationMIN) { [sto_no].illuminationMAX = 。 } if ( 0 amp。amp。 [sto_no].illuminationMAX) { [sto_no].illuminationMIN = 。 } pthread_mutex_lock (amp。mutex_slinklist)。 sqlite_InsertLinknode (ENV_UPDATE, all_info_RT, sto_no, 0)。 pthread_mutex_unlock (amp。mutex_slinklist)。 pthread_cond_signal (amp。cond_sqlite)。 pthread_mutex_unlock (amp。mutex_global)。 pthread_cond_signal (amp。cond_refresh)。 break。 }if 1 case 10L: { int i = 0 , j = 0 。 for(i = 0 。 i 11。 i++) { recive_phone[i] = [i]。 } recive_phone[i] = 39。\039。 printf(**************************recive:%s\n,recive_phone)。 for(j = 0 。[i] != 39。\039。 amp。amp。 j 12。 i++, j++) { center_phone[j] = [i]。 } center_phone[j] = 39。\039。 printf(**************************center:%s\n,center_phone)。 printf(**************************num change over\n)。 break。 }endif if 1 case 11L: { char tmp[100] ={0}。strcpy(tmp,)。 char tmp1[100] = {0}。 char tmp2[100] = {0}。 int i = 0, j= 0。 for(i = 0 。 tmp[i] != 39。f39。 i++) { tmp1[i] = tmp[i]。 } tmp1[i] = 39。\039。 printf(tmp1 : %s\n,tmp1)。 i++。 for(j=0 。 tmp[i] != 39。\039。 i++, j++) { tmp2[j] = tmp[i]。 } tmp2[j] = 39。\039。 printf(tmp2 : %s\n,tmp2)。 system(mkdir /var/run/wpa_supplicant p)。 char ifcon[100] = ifconfig wlan0 。 strcat(ifcon,tmp1)。 printf(string : %s\n,ifcon)。 system(ifcon)。 char gw[100] = route add default gw 。 strcat(gw,tmp2)。 system(gw)。 printf(gw : %s\n,gw)。 system(wpa_supplicant B iwlan0 c /etc/)。 printf(wifi is ok\n)。 break。 }endif default : break。 } }}第七節(jié):紅外(按鍵模擬)模塊（1）互斥鎖名稱類型功能infrared_buzzerpthread_mutex_t按鍵模塊控制線程互斥鎖（2）條件變量名稱類型功能cond_infraredpthread_cond_t按鍵模塊控制線程被喚醒條件變量（3）其它名稱類型功能dev_infrared_maskunsigned char按鍵模塊（模擬紅外）操作掩碼dev_infrared_fdint 按鍵模塊（模擬紅外）設(shè)備節(jié)點(diǎn)3. 流程圖第八節(jié):蜂鳴器模塊控制蜂鳴器的打開、關(guān)閉狀態(tài)；（1）互斥鎖名稱類型功能mutex_buzzerpthread_mutex_t蜂鳴器模塊控制線程互斥鎖（2）條件變量名稱類型功能cond_buzzerpthread_cond_t蜂鳴器模塊控制線程被喚醒條件變量（3）其它名稱類型功能dev_bu