zoukankan      html  css  js  c++  java
  • cc2530启动流程---广播发送数据

    //操作系统任务初始化
    void osalInitTasks( void )
    {
      uint8 taskID = 0;
    
      // 分配内存,返回指向缓冲区的指针
      tasksEvents = (uint16 *)osal_mem_alloc( sizeof( uint16 ) * tasksCnt);
      // 设置所分配的内存空间单元值为0
      osal_memset( tasksEvents, 0, (sizeof( uint16 ) * tasksCnt));
    
      // 任务优先级由高向低依次排列,高优先级对应taskID 的值反而小
      macTaskInit( taskID++ );  //macTaskInit(0) ,用户不需考虑
      nwk_init( taskID++ );     //nwk_init(1),用户不需考虑
      Hal_Init( taskID++ );     //Hal_Init(2) ,用户需考虑
    #if defined( MT_TASK )
      MT_TaskInit( taskID++ );
    #endif
      APS_Init( taskID++ );      //APS_Init(3) ,用户不需考虑
    #if defined ( ZIGBEE_FRAGMENTATION )
      APSF_Init( taskID++ );
    #endif
      ZDApp_Init( taskID++ );    //ZDApp_Init(4) ,用户需考虑
    #if defined ( ZIGBEE_FREQ_AGILITY ) || defined ( ZIGBEE_PANID_CONFLICT )
      ZDNwkMgr_Init( taskID++ );
    #endif
      //用户创建的任务
      SampleApp_Init( taskID );  // SampleApp_Init _Init(5) ,用户需考虑
    }
    
    //用户创建的任务
    void SampleApp_Init( uint8 task_id )
    { 
      SampleApp_TaskID = task_id;   //osal分配的任务ID随着用户添加任务的增多而改变
      SampleApp_NwkState = DEV_INIT;//设备状态设定为ZDO层中定义的初始化状态
      SampleApp_TransID = 0;        //消息发送ID(多消息时有顺序之分)
      
      // Device hardware initialization can be added here or in main() (Zmain.c).
      // If the hardware is application specific - add it here.
      // If the hardware is other parts of the device add it in main().
    
     #if defined ( BUILD_ALL_DEVICES )
      // The "Demo" target is setup to have BUILD_ALL_DEVICES and HOLD_AUTO_START
      // We are looking at a jumper (defined in SampleAppHw.c) to be jumpered
      // together - if they are - we will start up a coordinator. Otherwise,
      // the device will start as a router.
      if ( readCoordinatorJumper() )
        zgDeviceLogicalType = ZG_DEVICETYPE_COORDINATOR;
      else
        zgDeviceLogicalType = ZG_DEVICETYPE_ROUTER;
    #endif // BUILD_ALL_DEVICES
    
    //该段的意思是,如果设置了HOLD_AUTO_START宏定义,将会在启动芯片的时候会暂停启动
    //流程,只有外部触发以后才会启动芯片。其实就是需要一个按钮触发它的启动流程。  
    #if defined ( HOLD_AUTO_START )
      // HOLD_AUTO_START is a compile option that will surpress ZDApp
      //  from starting the device and wait for the application to
      //  start the device.
      ZDOInitDevice(0);
    #endif
    
      // Setup for the periodic message's destination address 设置发送数据的方式和目的地址寻址模式
      // Broadcast to everyone 发送模式:广播发送
      SampleApp_Periodic_DstAddr.addrMode = (afAddrMode_t)AddrBroadcast;//广播
      SampleApp_Periodic_DstAddr.endPoint = SAMPLEAPP_ENDPOINT; //指定端点号
      SampleApp_Periodic_DstAddr.addr.shortAddr = 0xFFFF;//指定目的网络地址为广播地址
    
      // Setup for the flash command's destination address - Group 1 组播发送
      SampleApp_Flash_DstAddr.addrMode = (afAddrMode_t)afAddrGroup; //组寻址
      SampleApp_Flash_DstAddr.endPoint = SAMPLEAPP_ENDPOINT; //指定端点号
      SampleApp_Flash_DstAddr.addr.shortAddr = SAMPLEAPP_FLASH_GROUP;//组号0x0001
    
      // Fill out the endpoint description. 定义本设备用来通信的APS层端点描述符
      SampleApp_epDesc.endPoint = SAMPLEAPP_ENDPOINT; //指定端点号
      SampleApp_epDesc.task_id = &SampleApp_TaskID;   //SampleApp 描述符的任务ID
      SampleApp_epDesc.simpleDesc
                = (SimpleDescriptionFormat_t *)&SampleApp_SimpleDesc;//SampleApp简单描述符
      SampleApp_epDesc.latencyReq = noLatencyReqs;    //延时策略
    
      // Register the endpoint description with the AF
      afRegister( &SampleApp_epDesc );    //向AF层登记描述符
    
      // Register for all key events - This app will handle all key events
      RegisterForKeys( SampleApp_TaskID ); // 登记所有的按键事件
    
      // By default, all devices start out in Group 1
      SampleApp_Group.ID = 0x0001;//组号
      osal_memcpy( SampleApp_Group.name, "Group 1", 7  );//设定组名
      aps_AddGroup( SAMPLEAPP_ENDPOINT, &SampleApp_Group );//把该组登记添加到APS中
    
    #if defined ( LCD_SUPPORTED )
      HalLcdWriteString( "SampleApp", HAL_LCD_LINE_1 ); //如果支持LCD,显示提示信息
    #endif
    }
    
    enum
    {
      AddrNotPresent = 0,      //间接传送
      AddrGroup = 1,           //组寻址
      Addr16Bit = 2,   //单点传送
      Addr64Bit = 3,
      AddrBroadcast = 15    //广播传送
    };
    
    
    
    //用户应用任务的事件处理函数 开始操作系统是不断查询是否有事件产生
    uint16 SampleApp_ProcessEvent( uint8 task_id, uint16 events )
    {
      afIncomingMSGPacket_t *MSGpkt;
      (void)task_id;  // Intentionally unreferenced parameter
    
      if ( events & SYS_EVENT_MSG ) //接收系统消息再进行判断
      {
        //接收属于本应用任务SampleApp的消息,以SampleApp_TaskID标记
        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://接收数据事件,调用函数AF_DataRequest()接收数据
              SampleApp_MessageMSGCB( MSGpkt );//调用回调函数对收到的数据进行处理
              break;
    
            // Received whenever the device changes state in the network
            case ZDO_STATE_CHANGE:
              //只要网络状态发生改变,就通过ZDO_STATE_CHANGE事件通知所有的任务。
              //同时完成对协调器,路由器,终端的设置
              SampleApp_NwkState = (devStates_t)(MSGpkt->hdr.status);
              //if ( (SampleApp_NwkState == DEV_ZB_COORD)//实验中协调器只接收数据所以取消发送事件
              if ( (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 );
              }
              else
              {
                // Device is no longer in the network
              }
              break;
    
            default:
              break;
          }
    
          // Release the memory 事件处理完了,释放消息占用的内存
          osal_msg_deallocate( (uint8 *)MSGpkt );
    
          // Next - if one is available 指针指向下一个放在缓冲区的待处理的事件,
          //返回while ( MSGpkt )重新处理事件,直到缓冲区没有等待处理事件为止
          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()处理完当前的周期性事件,然后启动定时器
        //开启下一个周期性事情,这样一种循环下去,也即是上面说的周期性事件了,
        //可以做为传感器定时采集、上传任务
        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;
    }
    
    //接收数据,参数为接收到的数据
    void SampleApp_MessageMSGCB( afIncomingMSGPacket_t *pkt )
    {
      uint16 flashTime;
      byte buf[3]; 
    
      switch ( pkt->clusterId ) //判断簇ID
      {
        case SAMPLEAPP_PERIODIC_CLUSTERID: //收到广播数据
          osal_memset(buf, 0 , 3);
          osal_memcpy(buf, pkt->cmd.Data, 2); //复制数据到缓冲区中
          
          if(buf[0]=='D' && buf[1]=='1')      //判断收到的数据是否为"D1"         
          {
              HalLedBlink(HAL_LED_1, 0, 50, 500);//如果是则Led1间隔500ms闪烁
    #if defined(ZDO_COORDINATOR) //协调器收到"D1"后,返回"D1"给终端,让终端Led1也闪烁
              SampleApp_SendPeriodicMessage();
    #endif
          }
          else
          {
              HalLedSet(HAL_LED_1, HAL_LED_MODE_ON);                   
          }
          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;
      }
    }
    
    //分析发送周期信息
    void SampleApp_SendPeriodicMessage( void )
    {
      byte SendData[3]="D1";
    
      // 调用AF_DataRequest将数据无线广播出去
      if( AF_DataRequest( &SampleApp_Periodic_DstAddr,//发送目的地址+端点地址和传送模式
                           &SampleApp_epDesc,//源(答复或确认)终端的描述(比如操作系统中任务ID等)源EP
                           SAMPLEAPP_PERIODIC_CLUSTERID, //被Profile指定的有效的集群号
                           2,       // 发送数据长度
                           SendData,// 发送数据缓冲区
                           &SampleApp_TransID,     // 任务ID号
                           AF_DISCV_ROUTE,      // 有效位掩码的发送选项
                           AF_DEFAULT_RADIUS ) == afStatus_SUCCESS )  //传送跳数,通常设置为AF_DEFAULT_RADIUS
      {
      }
      else
      {
        HalLedSet(HAL_LED_1, HAL_LED_MODE_ON);
        // Error occurred in request to send.
      }
    }

     操作系统初始化任务分配内存(tasksEvents)以及任务ID号taskID------》用户创建的任务void SampleApp_Init( uint8 task_id )---->开始操作系统,提取需要处理的事件events=tasksEvents[idx])-------->用户应用任务的事件处理函数SampleApp_ProcessEvent(uint8 task_id, uint16 events )------->SampleApp_MessageMSGCB( MSGpkt )以及SampleApp_SendPeriodicMessage();

     

  • 相关阅读:
    C
    大数模板
    51Nod 1040 最大公约数之和
    欧拉函数
    51Nod 1384 全排列
    B
    A
    B. Mancala (Codeforces Round #478 (Div. 2))
    I
    Requests 入门
  • 原文地址:https://www.cnblogs.com/yihujiu/p/5691716.html
Copyright © 2011-2022 走看看