哎呀研究这个数据的发送和收发研究了2天了。今天终于把困扰我很久的一个问题给解决了。
问题:终端节点启动会为什么会自动的发送数据呢?
解决过程:这个过程可是异常的艰辛。要解决这个问题。咱们先聊聊这个整个
zigbee协议栈的工作流程。
程序肯定都是从main函数开始的,这个肯定也不例外。大家查看一下main函数主要就是关闭中断,检查电源电压是否够高,还有就是初始化了,什么物理层,mac层等等。。而我们在这里关注2个函数就好了。第一个是:osal_init_system();第二个:osal_start_system();
第一个osal_init_system()函数就是初始化与系统运行相关的一些东西如:初始化内存分配系统,初始化消息队列,初始化定时器,初始化电源管理系统,初始化第一块堆,最后一个就是我们要讲的一个非常重要的函数:osalInitTasks();初始化任务函数
void osalInitTasks( void )//系统任务初始化函数
{
uint8 taskID = 0;
//这个指针指向了所有任务空间的首地址
关于暑假的作文 tasksEvents = (uint16 *)osal_mem_alloc( sizeof( uint16 ) * tasksCnt);//这个tasksEvents指针总共有多少个数据空间,其实总共有多少任务就有多少个空间。
osal_memt( tasksEvents, 0, (sizeof( uint16 ) * tasksCnt));
macTaskInit( taskID++ ); //mac层的任务是0
nwk_init( taskID++ ); //网络层的任务是1
Hal_Init( taskID++ ); //物理层的任务号是2
#if defined( MT_TASK )
MT_TaskInit( taskID++ );//串口的任务
#endif
APS_Init( taskID++ );
#if defined ( ZIGBEE_FRAGMENTATION )
APSF_Init( taskID++ );
#endif
ZDApp_Init( taskID++ );
#if defined ( ZIGBEE_FREQ_AGILITY ) || defined ( ZIGBEE_PANID_CONFLICT )
ZDNwkMgr_Init( taskID++ );达成率
#endif
述廉报告GenericApp_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(;;) // Forever Loop
#endif
{
uint8 idx = 0;
osalTimeUpdate();
Hal_ProcessPoll(); // This replaces MT_SerialPoll() and osal_check_timer().
do {
if (tasksEvents[idx]) // Task is highest priority that is ready.
{
break;//当不是0 的时候就直接返回。
备孕前准备 }
} while (++idx < tasksCnt);
if (idx < tasksCnt)//说明有任务发生了,要去做
{
uint16 events;
halIntState_t intState;
HAL_ENTER_CRITICAL_SECTION(intState);
events = tasksEvents[idx]; //当是传感器的发送报道的时候传送的肯定是MY_REPORT_EVT
tasksEvents[idx] = 0; // Clear the Events for this task.
HAL_EXIT_CRITICAL_SECTION(intState);
events = (tasksArr[idx])( idx, events );//调用任务处理函数
HAL_ENTER_CRITICAL_SECTION(intState);
tasksEvents[idx] |= events; // Add back unprocesd events to the current task.
HAL_EXIT_CRITICAL_SECTION(intState);
梦幻西游副本攻略
}
#if defined( POWER_SAVING )
el // Complete pass through all task events with no activity?
{
osal_pwrmgr_powerconrve(); // Put the processor/system into sleep
}
#endif
}
在do while里面去检测(tasksEvents[idx]是不是0,也就是现在有没有事件发生事件,当然顺序就是从idx=0开始。也就是说从0开始。当有事件发生就跳出循环执行下面的语句。下面的语句很简单就是先获取这个事件。调去任务处理函数。传出来的events这个变量已经把刚做过的那个事件取消掉了。但是任然要把这个值给当前任务。因为这个任务里面可能还有其它事件。就这样循环把第一个任务的所有事件做完,接着做第二个任务的事件。。。知道把所有任务做一遍,然后不停的循环。这也即使操作系统的工作机制。
接下来我们要讲第三个比较重要的东西:events = (tasksArr[idx])( idx, events );
第三个:tasksArr[]数组。
下面来看看这个数组的定义:
const pTaskEventHandlerFn tasksArr[] = {
macEventLoop, //mac层的事件循环 你去追踪一下你就知道他没有被定义
nwk_event_loop,//网络层的事件循环 你去追踪一下你就知道他没有被定义
Hal_ProcessEvent,//物理层的事件处理事件
#if defined( MT_TASK )
MT_ProcessEvent,
#endif
APS_event_loop,
#if defined ( ZIGBEE_FRAGMENTATION )
APSF_ProcessEvent,
#endif
屋顶防水施工流程 ZDApp_event_loop,
#if defined ( ZIGBEE_FREQ_AGILITY ) || defined ( ZIGBEE_PANID_CONFLICT )
ZDNwkMgr_event_loop,
#endif
GenericApp_ProcessEvent //这个是应用程序自己定义的任务事件。
};
typedef unsigned short (*pTaskEventHandlerFn)( unsigned char task_id, unsigned short event );
可以看出来它里面都是回调函数,传递的参数那就是任务ID和事件的集合。这样大家就知道调去任务处理函数的机制了吧。
讲完上面的这3个函数哪里。那么我们再来讲讲数据的发送和接收就比较简单了。
点对点数据发送和接收的机制
由上面的操作系统和任务处理函数的运行机制。我们再来理解这个数据发送和接收的机制就很容易了。
准备工作:
首先我们的数据发送放在了应用层这个任务里面了。所以我们就知道需要2个函数了。
一个是应用层的初始化函数,应用层任务处理函数。我们可以在Enddevice.c定义,并且把GenericApp_Init(byte task_id)函数放在osalInitTasks( void )函数下,例如这样:
void osalInitTasks( void )
喜欢一个女生{
。。。。。
GenericApp_Init( taskID );//放在最后即可洿池
}
再把任务处理函数放在tasksArr[]数组下:例如:
const pTaskEventHandlerFn tasksArr[]={