您好,欢迎访问三七文档
当前位置:首页 > 商业/管理/HR > 项目/工程管理 > 2、自己理解zigbee有关的数据的发送和接收
哎呀研究这个数据的发送和收发研究了2天了。今天终于把困扰我很久的一个问题给解决了。问题:终端节点启动会为什么会自动的发送数据呢?解决过程:这个过程可是异常的艰辛。要解决这个问题。咱们先聊聊这个整个zigbee协议栈的工作流程。程序肯定都是从main函数开始的,这个肯定也不例外。大家查看一下main函数主要就是关闭中断,检查电源电压是否够高,还有就是初始化了,什么物理层,mac层等等。。而我们在这里关注2个函数就好了。第一个是:osal_init_system();第二个:osal_start_system();第一个osal_init_system()函数就是初始化与系统运行相关的一些东西如:初始化内存分配系统,初始化消息队列,初始化定时器,初始化电源管理系统,初始化第一块堆,最后一个就是我们要讲的一个非常重要的函数:osalInitTasks();初始化任务函数voidosalInitTasks(void)//系统任务初始化函数{uint8taskID=0;//这个指针指向了所有任务空间的首地址tasksEvents=(uint16*)osal_mem_alloc(sizeof(uint16)*tasksCnt);//这个tasksEvents指针总共有多少个数据空间,其实总共有多少任务就有多少个空间。osal_memset(tasksEvents,0,(sizeof(uint16)*tasksCnt));macTaskInit(taskID++);//mac层的任务是0nwk_init(taskID++);//网络层的任务是1Hal_Init(taskID++);//物理层的任务号是2#ifdefined(MT_TASK)MT_TaskInit(taskID++);//串口的任务#endifAPS_Init(taskID++);#ifdefined(ZIGBEE_FRAGMENTATION)APSF_Init(taskID++);#endifZDApp_Init(taskID++);#ifdefined(ZIGBEE_FREQ_AGILITY)||defined(ZIGBEE_PANID_CONFLICT)ZDNwkMgr_Init(taskID++);#endifGenericApp_Init(taskID);//应用程序的初始化。并且得到这个任务的ID号。}大家可以看到有2个非常重要的变量:taskID,tasksEvents[sizeof(tasksArr)/sizeof(tasksArr[0]);第1个taskID被初始化为0,然后赋值给mac层,以后就赋值一次加1,所以每一个任务都会得到属于自己taskID的值。而那个值就是自己在系统中对应的任务号。而有必要谈一下就是每一个任务对应下面可以有16个事件,但是有一个事件被系统给强制应用了,就是SYS_EVENT_MSG=0x8000.其它15个事件就可以自己定义了。SYS_EVENT_MSG:消息等待事件。比如自己这一层,或者说这个任务有对应的消息传来。就会把这个事件给置位。或者干脆说这个事件是一直被置位的,而你在你的任务处理函数中可以选择是否检测这个事件。如果你检测了,而又想得到属于自己层的消息你可以调用函数MSGpkt=(afIncomingMSGPacket_t*)osal_msg_receive(GenericApp_TaskID);来获取自己的消息,在通过判断MSGpkt-hdr.event这个事件类型来判断进行相应的处理。第2个taskEvents[]这个数组的容量其实等于你总任务的个数。而每一个对应的变量存放的就是这个任务里面对应的事件。比如taskEvents[0]=0x8000;就是任务0里面的消息等待事件。这里有个东西提一下,这个16为的数每一位表示一个事件,一般不进行组合,所以最多有16个事件。这个函数的目地就是给每一个任务分配任务ID然后创建一个任务数组存放各自任务现在对应的事件。第二个函数osal_start_system();这个函数才是操作系统的核心。里面有个死循环for(;;)for(;;)//ForeverLoop#endif{uint8idx=0;osalTimeUpdate();Hal_ProcessPoll();//ThisreplacesMT_SerialPoll()andosal_check_timer().do{if(tasksEvents[idx])//Taskishighestprioritythatisready.{break;//当不是0的时候就直接返回。}}while(++idxtasksCnt);if(idxtasksCnt)//说明有任务发生了,要去做{uint16events;halIntState_tintState;HAL_ENTER_CRITICAL_SECTION(intState);events=tasksEvents[idx];//当是传感器的发送报道的时候传送的肯定是MY_REPORT_EVTtasksEvents[idx]=0;//CleartheEventsforthistask.HAL_EXIT_CRITICAL_SECTION(intState);events=(tasksArr[idx])(idx,events);//调用任务处理函数HAL_ENTER_CRITICAL_SECTION(intState);tasksEvents[idx]|=events;//Addbackunprocessedeventstothecurrenttask.HAL_EXIT_CRITICAL_SECTION(intState);}#ifdefined(POWER_SAVING)else//Completepassthroughalltaskeventswithnoactivity?{osal_pwrmgr_powerconserve();//Puttheprocessor/systemintosleep}#endif}在dowhile里面去检测(tasksEvents[idx]是不是0,也就是现在有没有事件发生事件,当然顺序就是从idx=0开始。也就是说从0开始。当有事件发生就跳出循环执行下面的语句。下面的语句很简单就是先获取这个事件。调去任务处理函数。传出来的events这个变量已经把刚做过的那个事件取消掉了。但是任然要把这个值给当前任务。因为这个任务里面可能还有其它事件。就这样循环把第一个任务的所有事件做完,接着做第二个任务的事件。。。知道把所有任务做一遍,然后不停的循环。这也即使操作系统的工作机制。接下来我们要讲第三个比较重要的东西:events=(tasksArr[idx])(idx,events);第三个:tasksArr[]数组。下面来看看这个数组的定义:constpTaskEventHandlerFntasksArr[]={macEventLoop,//mac层的事件循环你去追踪一下你就知道他没有被定义nwk_event_loop,//网络层的事件循环你去追踪一下你就知道他没有被定义Hal_ProcessEvent,//物理层的事件处理事件#ifdefined(MT_TASK)MT_ProcessEvent,#endifAPS_event_loop,#ifdefined(ZIGBEE_FRAGMENTATION)APSF_ProcessEvent,#endifZDApp_event_loop,#ifdefined(ZIGBEE_FREQ_AGILITY)||defined(ZIGBEE_PANID_CONFLICT)ZDNwkMgr_event_loop,#endifGenericApp_ProcessEvent//这个是应用程序自己定义的任务事件。};typedefunsignedshort(*pTaskEventHandlerFn)(unsignedchartask_id,unsignedshortevent);可以看出来它里面都是回调函数,传递的参数那就是任务ID和事件的集合。这样大家就知道调去任务处理函数的机制了吧。讲完上面的这3个函数哪里。那么我们再来讲讲数据的发送和接收就比较简单了。点对点数据发送和接收的机制由上面的操作系统和任务处理函数的运行机制。我们再来理解这个数据发送和接收的机制就很容易了。准备工作:首先我们的数据发送放在了应用层这个任务里面了。所以我们就知道需要2个函数了。一个是应用层的初始化函数,应用层任务处理函数。我们可以在Enddevice.c定义,并且把GenericApp_Init(bytetask_id)函数放在osalInitTasks(void)函数下,例如这样:voidosalInitTasks(void){。。。。。GenericApp_Init(taskID);//放在最后即可}再把任务处理函数放在tasksArr[]数组下:例如:constpTaskEventHandlerFntasksArr[]={。。。GenericApp_ProcessEvent//放在最后即可};运行:运行的时候不是我们已经讲了吗。因为有个事件是一定有的就是SYS_EVENT_MSG消息等待事件。所以我们的策略就是,在任务处理函数里面检测SYS_EVENT_MSG这个事件,然后获取对应的消息。找到你想要的事件来启动数据的发送。对应代码:UINT16GenericApp_ProcessEvent(bytetask_id,UINT16events){afIncomingMSGPacket_t*MSGpkt;if(events&SYS_EVENT_MSG){MSGpkt=(afIncomingMSGPacket_t*)osal_msg_receive(GenericApp_TaskID);while(MSGpkt){switch(MSGpkt-hdr.event){caseZDO_STATE_CHANGE://ZDO改变了设备的网络状态这样做会不会意味着只能进行一次发送呢?/*需要修改的地方*/GenericApp_NwkState=(devStates_t)(MSGpkt-hdr.status);//读取节点的设备类型if(GenericApp_NwkState==DEV_END_DEVICE)//对节点设备判定,如果是终端节点,执行下一行。{④GenericApp_SendTheMessage();//实现90无线数据的发送。}/**/break;default:break;}osal_msg_deallocate((uint8*)MSGpkt);MSGpkt=(afIncomingMSGPacket_t*)osal_msg_receive(GenericApp_TaskID);//循环的接收设备的消息。知道通过switch是网络状态的改变}return(events^SYS_EVENT_MSG);}return0;}所以我们需要关心的就是这四行语句:来查看消息等待事件是否发生。发生做下面代码。获取消息。在下面while循环里检测消息的事件类型当消息事件类型是网络状态的改变时。也就是刚加入zigbee无线网的时候。下面的就是检测是不是端点设备如果是做④④调去数据发送函数完成发送。接下来我们就看看数据发送函数吧:/*消息发送*/voidGenericApp_SendTheMessage(void){unsignedintx,y;unsignedchartheMessageData[4]=LED;//用于存放要发送的数据/*定义一个afAddrType_t类型的变量你,因为数据发送函数AF_DataRequest的第一个参数就是这种类型的变量。afAddrType_t类型定义如下:typedefstruct{union{uint16shortAddr;//短地址,也是网络地址常用ZLongAddr_textAddr;//)
本文标题:2、自己理解zigbee有关的数据的发送和接收
链接地址:https://www.777doc.com/doc-4408643 .html