zigbee协议栈应用与组网（三）：广播组网，无线数据传输

void SampleApp_MessageMSGCB( afIncomingMSGPacket_t *pkt )
{
  uint16 flashTime;

  switch ( pkt->clusterId )
  {
    case SAMPLEAPP_PERIODIC_CLUSTERID:
      //接收数据部分
      HalUARTWrite(0,"Rx:",sizeof("Rx:"));
      HalUARTWrite(0,pkt->cmd.Data,pkt->cmd.DataLength);
      //刚刚把pkt打成了pkkt，而且还加了双引号，结构收到的数据就是pkt->cmd.Data
      HalUARTWrite(0,"\n",1);
      //
      break;

    case SAMPLEAPP_FLASH_CLUSTERID:
      flashTime = BUILD_UINT16(pkt->cmd.Data[1], pkt->cmd.Data[2] );
      HalLedBlink( HAL_LED_4, 4, 50, (flashTime / 4) );
      break;
  }
}

typedef struct
{
  osal_event_hdr_t hdr;     /* OSAL Message header */ 消息头
  uint16 groupId;           /* Message‘s group ID - 0 if not set */ 消息组ID
  uint16 clusterId;         /* Message‘s cluster ID */ 消息族ID
  afAddrType_t srcAddr;     /* Source Address, if endpoint is STUBAPS_INTER_PAN_EP,
                               it‘s an InterPAN message */ 源地址类型
  uint16 macDestAddr;       /* MAC header destination short address */MAC物理地址
  uint8 endPoint;           /* destination endpoint */ MAC目标端点
  uint8 wasBroadcast;       /* TRUE if network destination was a broadcast address */ 广播地址
  uint8 LinkQuality;        /* The link quality of the received data frame */ 接收数据帧的链路质量
  uint8 correlation;        /* The raw correlation value of the received data frame */ 接收数据帧的相关的未加工的值
  int8  rssi;               /* The received RF power in units dBm */ dbm接受的射频功率
  uint8 SecurityUse;        /* deprecated */ 弃用
  uint32 timestamp;         /* receipt timestamp from MAC */ MAC收到时间标记
  uint8 nwkSeqNum;          /* network header frame sequence number */网络报头帧序列号
  afMSGCommandFormat_t cmd; /* Application Data */应用程序数据
} afIncomingMSGPacket_t;

typedef struct
{
  uint8   TransSeqNumber;
  uint16  DataLength;              // Number of bytes in TransData
  uint8  *Data;                     //这个就是数据啦！
} afMSGCommandFormat_t;

void SampleApp_SendPeriodicMessage( void )
{
  //
  uint8 data[10]="fudianheg";
  //
  if ( AF_DataRequest( &SampleApp_Periodic_DstAddr, &SampleApp_epDesc,
                       SAMPLEAPP_PERIODIC_CLUSTERID,//簇id
                       9,//发送数据长度
                       data,//数据缓冲区
                       //1,
                       //(uint8*)&SampleAppPeriodicCounter,
                       &SampleApp_TransID,
                       AF_DISCV_ROUTE,
                       AF_DEFAULT_RADIUS ) == afStatus_SUCCESS )
  {
  }
  else
  {
    // Error occurred in request to send.
  }
}

uint16 SampleApp_ProcessEvent( uint8 task_id, uint16 events )
{
  afIncomingMSGPacket_t *MSGpkt;
  (void)task_id;  // Intentionally unreferenced parameter

  if ( events & SYS_EVENT_MSG )
  {
    MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive( SampleApp_TaskID );
    while ( MSGpkt )
    {
      switch ( MSGpkt->hdr.event )
      {
        // Received when a key is pressed
        case KEY_CHANGE:
          SampleApp_HandleKeys( ((keyChange_t *)MSGpkt)->state, ((keyChange_t *)MSGpkt)->keys );
          break;

        // Received when a messages is received (OTA) for this endpoint
        case AF_INCOMING_MSG_CMD:
          SampleApp_MessageMSGCB( MSGpkt );
          break;

        // Received whenever the device changes state in the network
        case ZDO_STATE_CHANGE://网络状态改变，所有的节点都变化
          SampleApp_NwkState = (devStates_t)(MSGpkt->hdr.status);
          if ( //(SampleApp_NwkState == DEV_ZB_COORD)//协议器不用发送所以注释掉
             /*||*/ (SampleApp_NwkState == DEV_ROUTER)// ||也注释掉
              || (SampleApp_NwkState == DEV_END_DEVICE) )
          {
            // Start sending the periodic message in a regular interval.
            osal_start_timerEx( SampleApp_TaskID,
                              SAMPLEAPP_SEND_PERIODIC_MSG_EVT,
                              SAMPLEAPP_SEND_PERIODIC_MSG_TIMEOUT );
            //任务id，事件的编号（同一个人任务下可以有多个事件），以毫秒为单位发送的时间
          }
          else
          {
            // Device is no longer in the network
          }
          break;

        default:
          break;
      }

      // Release the memory
      osal_msg_deallocate( (uint8 *)MSGpkt );

      // Next - if one is available
      MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive( SampleApp_TaskID );
    }

    // return unprocessed events
    return (events ^ SYS_EVENT_MSG);
  }

  // Send a message out - This event is generated by a timer
  //  (setup in SampleApp_Init()).
  if ( events & SAMPLEAPP_SEND_PERIODIC_MSG_EVT )
  {
    // Send the periodic message
    SampleApp_SendPeriodicMessage();//这就是我们发送的数据

    // Setup to send message again in normal period (+ a little jitter)
    osal_start_timerEx( SampleApp_TaskID, SAMPLEAPP_SEND_PERIODIC_MSG_EVT,
        (SAMPLEAPP_SEND_PERIODIC_MSG_TIMEOUT + (osal_rand() & 0x00FF)) );

    // return unprocessed events
    return (events ^ SAMPLEAPP_SEND_PERIODIC_MSG_EVT);
  }

  // Discard unknown events
  return 0;
}