【转】ZIGBee组网流程-第2页回答

1楼-- · 2019-07-21 11:59

节点2 在收到空中的信号后，如何传递给与其相连的串口终端？
节点 2 从空中捕获到信号后，在应用层上首先收到信息的就是 SerialApp_ProcessEvent 这个函数了，它收到一个 AF_INCOMING_MSG_CMD 的事件，并通知 SerialApp_ProcessMSGCmd，执行以下代码：
UINT16 SerialApp_ProcessEvent( uint8 task_id, UINT16 events )  //当有事件传递到应用层的时候，执行此处
{
  ......
while ( (MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive( SerialApp_TaskID )) )
{
   switch ( MSGpkt->hdr.event )
   {
      ......
      case AF_INCOMING_MSG_CMD:    //在这个实验中，使用串口通讯时，触发的事件，从空中捕获到信号。
SerialApp_ProcessMSGCmd( MSGpkt );  //处理这个消息
         break;
   ......
   }
}
}
void SerialApp_ProcessMSGCmd( afIncomingMSGPacket_t *pkt )  //对从空中捕获到的信号进行处理
{
  uint8 stat;
  uint8 seqnb;
  uint8 delay;
  switch ( pkt->clusterId )
  {
// A message with a serial data block to be transmitted on the serial port.
  case SERIALAPP_CLUSTERID1: //节点一发送过来的信息的 CLUSTERID(信息簇ID)号为 SERIALAPP_CLUSTERID1
// Store the address for sending and retrying.
osal_memcpy(&SerialApp_RxAddr, &(pkt->srcAddr), sizeof( afAddrType_t ));
seqnb = pkt->cmd.Data[0];
  // Keep message if not a repeat packet
if ( (seqnb > SerialApp_RxSeq) ||                   // Normal
      ((seqnb < 0x80 ) && ( SerialApp_RxSeq > 0x80)) ) // Wrap-around
{
   // Transmit the data on the serial port.
   if ( HalUARTWrite( SERIAL_APP_PORT, pkt->cmd.Data+1, (pkt->cmd.DataLength-1) ) )  //通过串口发送数据到PC机
   {
      // Save for next incoming message
      SerialApp_RxSeq = seqnb;
      stat = OTA_SUCCESS;
   }
   else
   {
      stat = OTA_SER_BUSY;
   }
}
else
{
   stat = OTA_DUP_MSG;
}
// Select approproiate OTA flow-control delay.
delay = (stat == OTA_SER_BUSY) ? SERIALAPP_NAK_DELAY : SERIALAPP_ACK_DELAY;
// Build & send OTA response message.
SerialApp_RspBuf[0] = stat;
SerialApp_RspBuf[1] = seqnb;
SerialApp_RspBuf[2] = LO_UINT16( delay );
SerialApp_RspBuf[3] = HI_UINT16( delay );
osal_set_event( SerialApp_TaskID, SERIALAPP_RESP_EVT );  //受到数据后，向节点1发送一个响应事件,跳到SerialApp_ProcessEvent()
osal_stop_timerEx(SerialApp_TaskID, SERIALAPP_RESP_EVT);
break;
......
  }
}
UINT16 SerialApp_ProcessEvent( uint8 task_id, UINT16 events )
{
......
if ( events & SERIALAPP_RESP_EVT ) //串口响应事件，表示成功接受来自节点1的数据，
  {
SerialApp_Resp();    //向节点1发送  成功接受的response
return ( events ^ SERIALAPP_RESP_EVT );
  }
......
}
static void SerialApp_Resp(void)
{
  if (afStatus_SUCCESS != AF_DataRequest(&SerialApp_RxAddr,       //通过AF_DataRequest函数，讲接收成功响应从空中发送出去
                                       (endPointDesc_t *)&SerialApp_epDesc,
                                       SERIALAPP_CLUSTERID2,
                                       SERIAL_APP_RSP_CNT, SerialApp_RspBuf,
                                       &SerialApp_MsgID, 0, AF_DEFAULT_RADIUS))
  {
osal_set_event(SerialApp_TaskID, SERIALAPP_RESP_EVT); //如果发送失败，重新发送
  }
}