开发者社区> 史迪奇2号> 正文

[ZigBee] 16、Zigbee协议栈应用(二)——基于OSAL的无线控制LED闪烁分析(下)

简介:
+关注继续查看


 

 

说在前面:上一篇介绍了无线LED闪烁实现的OSAL部分,本篇介绍如何实现无线数据收发及数据处理:

 

上一篇是用SI跟着流程查看源码,我个人认为以架构的思维去了解代码能让人更清晰

 

 

::ZMain.c程序入口文件

这里chipcon_cstartup.s51是汇编的启动文件,ZMain.c相当于main文件,里面有main函数:

复制代码
 1 int main( void )
 2 {
 3     osal_int_disable( INTS_ALL );// Turn off interrupts         关中断
 4     HAL_BOARD_INIT();// Initialization for board related stuff such as LEDs
 5     zmain_vdd_check();// Make sure supply voltage is high enough to run   检查芯片是否上电正常
 6     InitBoard( OB_COLD );// Initialize board I/O  初始化I/O,LED,Timer等
 7     HalDriverInit();// Initialze HAL drivers 初始化硬件抽象层驱动模块
 8     osal_nv_init( NULL );// Initialize NV System 初始化flash存储器
 9     znpTestRF();// Initialize and check the ZNP RF Test Mode NV items. 
10     ZMacInit();// Initialize the MAC  初始化MAC层
11     zmain_ext_addr();// Determine the extended address  确定IEEE64位地址
12 
13 #if defined ZCL_KEY_ESTABLISH
14     zmain_cert_init();// Initialize the Certicom certificate information.
15 #endif
16 
17     zgInit();// Initialize basic NV items  初始化非易失变量
18 
19 #ifndef NONWK
20     afInit();// Since the AF isn't a task, call it's initialization routine
21 #endif
22 
23     osal_init_system();// Initialize the operating system     初始化OS(重点介绍1)
24     osal_int_enable( INTS_ALL );// Allow interrupts       使能中断
25     InitBoard( OB_READY );// Final board initialization      最终板载初始化
26     zmain_dev_info();// Display information about this device     显示设备信息(这里有LCD屏幕)
27 
28 #ifdef LCD_SUPPORTED/* Display the device info on the LCD 将信息显示在LCD上*/
29     zmain_lcd_init();      
30 #endif
31 
32 #ifdef WDT_IN_PM1
33     WatchDogEnable( WDTIMX );/* If WDT is used, this is a good place to enable it. */
34 #endif
35 
36     osal_start_znp(); // No Return from here    执行操作系统(重点介绍2)
37 
38     return 0;  // Shouldn't get here.
39 } // main()
复制代码

main主要是初始化,然后启动OS,进入大循环,根据任务优先级处理相应任务。

 

::OSAL_SampleApp.c任务数组及任务初始化文件

上篇讲到main函数核心有:

 

初始化最核心的是OSAL任务初始化:(这里的tasksArr是所有任务的索引,后文还会介绍)

复制代码
 1 /*********************************************************************
 2  * GLOBAL VARIABLES
 3  */
 4 
 5 // The order in this table must be identical to the task initialization calls below in osalInitTask.
 6 const pTaskEventHandlerFn tasksArr[] =
 7 {
 8     macEventLoop,
 9     nwk_event_loop,
10     Hal_ProcessEvent,
11 #if defined( MT_TASK )
12     MT_ProcessEvent,
13 #endif
14     APS_event_loop,
15 #if defined ( ZIGBEE_FRAGMENTATION )
16     APSF_ProcessEvent,
17 #endif
18     ZDApp_event_loop,
19 #if defined ( ZIGBEE_FREQ_AGILITY ) || defined ( ZIGBEE_PANID_CONFLICT )
20     ZDNwkMgr_event_loop,
21 #endif
22     SampleApp_ProcessEvent
23 };
24 
25 const uint8 tasksCnt = sizeof( tasksArr ) / sizeof( tasksArr[0] );
26 uint16 *tasksEvents;
27 
28 /*********************************************************************
29  * FUNCTIONS
30  *********************************************************************/
31 
32 /*********************************************************************
33  * @fn      osalInitTasks
34  *
35  * @brief   This function invokes the initialization function for each task.
36  *
37  * @param   void
38  *
39  * @return  none
40  */
41 void osalInitTasks( void )
42 {
43     uint8 taskID = 0;
44 
45     // 分配内存,返回指向缓冲区的指针
46     tasksEvents = (uint16 *)osal_mem_alloc( sizeof( uint16 ) * tasksCnt);
47     // 设置所分配的内存空间单元值为0
48     osal_memset( tasksEvents, 0, (sizeof( uint16 ) * tasksCnt));
49 
50     // 任务优先级由高向低依次排列,高优先级对应taskID 的值反而小
51     macTaskInit( taskID++ );  //macTaskInit(0) ,用户不需考虑
52     nwk_init( taskID++ );     //nwk_init(1),用户不需考虑
53     Hal_Init( taskID++ );     //Hal_Init(2) ,用户需考虑
54 #if defined( MT_TASK )
55     MT_TaskInit( taskID++ );
56 #endif
57     APS_Init( taskID++ );      //APS_Init(3) ,用户不需考虑
58 #if defined ( ZIGBEE_FRAGMENTATION )
59     APSF_Init( taskID++ );
60 #endif
61     ZDApp_Init( taskID++ );    //ZDApp_Init(4) ,用户需考虑
62 #if defined ( ZIGBEE_FREQ_AGILITY ) || defined ( ZIGBEE_PANID_CONFLICT )
63     ZDNwkMgr_Init( taskID++ );
64 #endif
65     //用户创建的任务
66     SampleApp_Init( taskID );  // SampleApp_Init _Init(5) ,用户需考虑
67 }
复制代码

 

::SampApp.c文件APP任务实现文件

承接上面66行,SampleApp_Init( uint8 task_id )负责初始化本工程定制化任务无线LED闪烁相关的初始化工作:

 SampleApp_Init( uint8 task_id )

 

上篇讲过OS启动后进入大循环,扫描当前优先级最高的任务执行!

其中若osal_run_task执行了本工程定制化任务的消息,通过调用tasksArr[idx](上面 OSAL_SampleApp.c中讲的任务数组就相当于调用了SampleApp_ProcessEvent函数,将消息传送给任务处理函数:

复制代码
 1 //用户应用任务的事件处理函数
 2 uint16 SampleApp_ProcessEvent( uint8 task_id, uint16 events )
 3 {
 4     afIncomingMSGPacket_t *MSGpkt;
 5     (void)task_id;  // Intentionally unreferenced parameter
 6 
 7     if ( events & SYS_EVENT_MSG ) //接收系统消息再进行判断
 8     {
 9         //接收属于本应用任务SampleApp的消息,以SampleApp_TaskID标记
10         MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive( SampleApp_TaskID );
11         while ( MSGpkt )
12         {
13             switch ( MSGpkt->hdr.event )
14             {
15             // Received when a key is pressed
16             case KEY_CHANGE://按键事件
17                 SampleApp_HandleKeys( ((keyChange_t *)MSGpkt)->state, ((keyChange_t *)MSGpkt)->keys );
18                 break;
19 
20             // Received when a messages is received (OTA) for this endpoint
21             case AF_INCOMING_MSG_CMD://接收数据事件,调用函数AF_DataRequest()接收数据
22                 SampleApp_MessageMSGCB( MSGpkt );//调用回调函数对收到的数据进行处理(1、数据发送函数)
23                 break;
24 
25             // Received whenever the device changes state in the network
26             case ZDO_STATE_CHANGE:
27                 //只要网络状态发生改变,就通过ZDO_STATE_CHANGE事件通知所有的任务。
28                 //同时完成对协调器,路由器,终端的设置
29                 SampleApp_NwkState = (devStates_t)(MSGpkt->hdr.status);
30                 //if ( (SampleApp_NwkState == DEV_ZB_COORD)//实验中协调器只接收数据所以取消发送事件
31                 if ( (SampleApp_NwkState == DEV_ROUTER) || (SampleApp_NwkState == DEV_END_DEVICE) )
32                 {
33                     // Start sending the periodic message in a regular interval.
34                     //这个定时器只是为发送周期信息开启的,设备启动初始化后从这里开始
35                     //触发第一个周期信息的发送,然后周而复始下去
36                     osal_start_timerEx( SampleApp_TaskID,
37                                         SAMPLEAPP_SEND_PERIODIC_MSG_EVT,
38                                         SAMPLEAPP_SEND_PERIODIC_MSG_TIMEOUT );
39                 }
40                 else
41                 {
42                     // Device is no longer in the network
43                 }
44                 break;
45 
46             default:
47                 break;
48             }
49 
50             // Release the memory 事件处理完了,释放消息占用的内存
51             osal_msg_deallocate( (uint8 *)MSGpkt );
52 
53             // Next - if one is available 指针指向下一个放在缓冲区的待处理的事件,
54             //返回while ( MSGpkt )重新处理事件,直到缓冲区没有等待处理事件为止
55             MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive( SampleApp_TaskID );
56         }
57 
58         // return unprocessed events 返回未处理的事件
59         return (events ^ SYS_EVENT_MSG);
60     }
61 
62     // Send a message out - This event is generated by a timer
63     //  (setup in SampleApp_Init()).
64     if ( events & SAMPLEAPP_SEND_PERIODIC_MSG_EVT )
65     {
66         // Send the periodic message 处理周期性事件,
67         //利用SampleApp_SendPeriodicMessage()处理完当前的周期性事件,然后启动定时器
68         //开启下一个周期性事情,这样一种循环下去,也即是上面说的周期性事件了,
69         //可以做为传感器定时采集、上传任务
70         SampleApp_SendPeriodicMessage();
71 
72         // Setup to send message again in normal period (+ a little jitter)
73         osal_start_timerEx( SampleApp_TaskID, SAMPLEAPP_SEND_PERIODIC_MSG_EVT,
74                             (SAMPLEAPP_SEND_PERIODIC_MSG_TIMEOUT + (osal_rand() & 0x00FF)) );
75 
76         // return unprocessed events 返回未处理的事件
77         return (events ^ SAMPLEAPP_SEND_PERIODIC_MSG_EVT);
78     }
79 
80     // Discard unknown events
81     return 0;
82 }
复制代码

 

接收函数:

复制代码
 1 //接收数据,参数为接收到的数据
 2 void SampleApp_MessageMSGCB( afIncomingMSGPacket_t *pkt )
 3 {
 4     uint16 flashTime;
 5     byte buf[3];
 6 
 7     switch ( pkt->clusterId ) //判断簇ID
 8     {
 9     case SAMPLEAPP_PERIODIC_CLUSTERID: //收到广播数据
10         osal_memset(buf, 0 , 3);
11         osal_memcpy(buf, pkt->cmd.Data, 2); //复制数据到缓冲区中
12 
13         if(buf[0] == 'D' && buf[1] == '1')  //判断收到的数据是否为"D1"
14         {
15             HalLedBlink(HAL_LED_1, 0, 50, 500);//如果是则Led1间隔500ms闪烁
16 #if defined(ZDO_COORDINATOR) //协调器收到"D1"后,返回"D1"给终端,让终端Led1也闪烁
17             SampleApp_SendPeriodicMessage();
18 #endif
19         }
20         else
21         {
22             HalLedSet(HAL_LED_1, HAL_LED_MODE_ON);
23         }
24         break;
25 
26     case SAMPLEAPP_FLASH_CLUSTERID: //收到组播数据
27         flashTime = BUILD_UINT16(pkt->cmd.Data[1], pkt->cmd.Data[2] );
28         HalLedBlink( HAL_LED_4, 4, 50, (flashTime / 4) );
29         break;
30     }
31 }
复制代码

 

发送函数:

复制代码
 1 //分析发送周期信息
 2 void SampleApp_SendPeriodicMessage( void )
 3 {
 4     byte SendData[3] = "D1";
 5 
 6     // 调用AF_DataRequest将数据无线广播出去
 7     if( AF_DataRequest( &SampleApp_Periodic_DstAddr,//发送目的地址+端点地址和传送模式
 8                         &SampleApp_epDesc,//源(答复或确认)终端的描述(比如操作系统中任务ID等)源EP
 9                         SAMPLEAPP_PERIODIC_CLUSTERID, //被Profile指定的有效的集群号
10                         2,       // 发送数据长度
11                         SendData,// 发送数据缓冲区
12                         &SampleApp_TransID,     // 任务ID号
13                         AF_DISCV_ROUTE,      // 有效位掩码的发送选项
14                         AF_DEFAULT_RADIUS ) == afStatus_SUCCESS )  //传送跳数,通常设置为AF_DEFAULT_RADIUS
15     {
16     }
17     else
18     {
19         HalLedSet(HAL_LED_1, HAL_LED_MODE_ON);
20         // Error occurred in request to send.
21     }
22 }
复制代码

 

 

 

Zigbee系列文章:

[ZigBee] 1、 ZigBee简介

[ZigBee] 2、 ZigBee开发环境搭建

[ZigBee] 3、ZigBee基础实验——GPIO输出控制实验-控制Led亮灭

[ZigBee] 4、ZigBee基础实验——中断

[ZigBee] 5、ZigBee基础实验——图文与代码详解定时器1(16位定时器)(长文)

[ZigBee] 6、ZigBee基础实验——定时器3和定时器4(8 位定时器)

[ZigBee] 7、ZigBee之UART剖析(ONLY串口发送)

[ZigBee] 8、ZigBee之UART剖析·二(串口收发)

[ZigBee] 9、ZigBee之AD剖析——AD采集CC2530温度串口显示

[ZigBee] 10、ZigBee之睡眠定时器

[ZigBee] 11、ZigBee之睡眠定时器二

[ZigBee] 12、ZigBee之看门狗定时器——饿了就咬人的GOOD DOG

[ZigBee] 13、ZigBee基础阶段性回顾与加深理解——用定时器1产生PWM来控制LED亮度(七色灯)

[ZigBee] 14、Zigbee无线通信前奏——BasicRF 简单无线点对点传输协议

[ZigBee] 15、Zigbee协议栈应用(一)——Zigbee协议栈介绍及简单例子(长文,OSAL及Zigbee入门知识)

 



本文转自beautifulzzzz博客园博客,原文链接:http://www.cnblogs.com/zjutlitao/p/5727859.html,如需转载请自行联系原作者

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
框架协议签订仅12天,阿里云宁波市工业互联网中心应用推广论坛成功举办
7月10日,继阿里巴巴集团与宁波市人民政府签署战略合作框架协议仅12天后,在阿里云宁波市工业互联网中心应用推广论坛上,阿里云与宁波市江北区人民政府联合宣布,阿里云宁波市工业互联网中心正式落户宁波文创港。
102 0
《工业控制网络安全技术与实践》一3.2.3 工业控制网络协议安全漏洞
本文讲的是工业控制网络安全技术与实践一3.2.3 工业控制网络协议安全漏洞,本节书摘来华章计算机《工业控制网络安全技术与实践》一书中的第3章,第3.2.3节,姚 羽 祝烈煌 武传坤 编著 译更多章节内容可以访问云栖社区“华章计算机”公众号查看。
1426 0
Java基础-23总结多线程,线程实现Runnable接口,线程名字获取和设置,线程控制,线程安全,同步线程
你需要的是什么,直接评论留言。 获取更多资源加微信公众号“Java帮帮” (是公众号,不是微信好友哦) 还有“Java帮帮”今日头条号,技术文章与新闻,每日更新,欢迎阅读 学习交流请加Java帮帮交流QQ群553841695 分享是一种美德,分享更快乐! 1:多线程(理解) (1)多线程:一个应用程序有多条执行路径 进程:正
2895 0
ZT:实时操作系统µC/OS II下TCP/IP协议栈的实现
实时操作系统µC/OS II下TCP/IP协议栈的实现 摘要: 结合ez80和ARM7两种系统上的具体实现,说明了如何在嵌入式实时操作系统µC/OSII上移植实现LwIP这套TCP/IP协议栈,使µC/OS II成为支持网络的RTOS。
839 0
858
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载