This thread has been locked.

If you have a related question, please click the "Ask a related question" button in the top right corner. The newly created question will be automatically linked to this question.

z-stack2.5.1a协议栈中,如何知道协调器删除其他已经加过网的节点是否成功

大家好,请教一个问题

z-stack2.5.1a协议栈中,在协调器中,删除已经加入网络的节点,协调器会发送一个删除命令给待删除的节点,节点收到后,会回应一个状态信息,这时候才能成功删除节点,如果相应的节点没有收到的话,就会删除不成功。

那么,问题来了,在协调器中通过什么判断是否收到节点的回应信息呢?

希望大神帮忙解答,万分感谢

  • 應該是要收到ZDP MGMT leave response

  • 发送ZDP_MgmtLeaveReq()后,节点回复 ZDP_MgmtLeaveRsp()
  • 增加注册回调函数ZDO_RegisterForZDOMsg(task_id, Mgmt_Leave_rsp);在GenericApp_Init里面。


    在 GenericApp_ProcessZDOMsgs进行处理:


      case  Mgmt_Leave_rsp:
          ZDO_ParseMgmtLeaveRsp( pMsg );

  • 感谢您的回答,但是还有个问题, 这个函数ZDO_ParseMgmtLeaveRsp( pMsg )是自己定义,然后自己定义如何解析这个回应消息的对吧,那这个pMsg是如何获取呢,麻烦您能告诉我一下么,谢谢

  • /******************************************************************************
      Filename:       GenericApp.c
      Revised:        $Date: 2014-09-07 13:36:30 -0700 (Sun, 07 Sep 2014) $
      Revision:       $Revision: 40046 $
    
      Description:    Generic Application (no Profile).
    
    
      Copyright 2004-2014 Texas Instruments Incorporated. All rights reserved.
    
      IMPORTANT: Your use of this Software is limited to those specific rights
      granted under the terms of a software license agreement between the user
      who downloaded the software, his/her employer (which must be your employer)
      and Texas Instruments Incorporated (the "License"). You may not use this
      Software unless you agree to abide by the terms of the License. The License
      limits your use, and you acknowledge, that the Software may not be modified,
      copied or distributed unless embedded on a Texas Instruments microcontroller
      or used solely and exclusively in conjunction with a Texas Instruments radio
      frequency transceiver, which is integrated into your product. Other than for
      the foregoing purpose, you may not use, reproduce, copy, prepare derivative
      works of, modify, distribute, perform, display or sell this Software and/or
      its documentation for any purpose.
    
      YOU FURTHER ACKNOWLEDGE AND AGREE THAT THE SOFTWARE AND DOCUMENTATION ARE
      PROVIDED �AS IS� WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESS OR IMPLIED,
      INCLUDING WITHOUT LIMITATION, ANY WARRANTY OF MERCHANTABILITY, TITLE,
      NON-INFRINGEMENT AND FITNESS FOR A PARTICULAR PURPOSE. IN NO EVENT SHALL
      TEXAS INSTRUMENTS OR ITS LICENSORS BE LIABLE OR OBLIGATED UNDER CONTRACT,
      NEGLIGENCE, STRICT LIABILITY, CONTRIBUTION, BREACH OF WARRANTY, OR OTHER
      LEGAL EQUITABLE THEORY ANY DIRECT OR INDIRECT DAMAGES OR EXPENSES
      INCLUDING BUT NOT LIMITED TO ANY INCIDENTAL, SPECIAL, INDIRECT, PUNITIVE
      OR CONSEQUENTIAL DAMAGES, LOST PROFITS OR LOST DATA, COST OF PROCUREMENT
      OF SUBSTITUTE GOODS, TECHNOLOGY, SERVICES, OR ANY CLAIMS BY THIRD PARTIES
      (INCLUDING BUT NOT LIMITED TO ANY DEFENSE THEREOF), OR OTHER SIMILAR COSTS.
    
      Should you have any questions regarding your right to use this Software,
      contact Texas Instruments Incorporated at www.TI.com.
    ******************************************************************************/
    
    /*********************************************************************
      This application isn't intended to do anything useful - it is
      intended to be a simple example of an application's structure.
    
      This application periodically sends a "Hello World" message to
      another "Generic" application (see 'txMsgDelay'). The application
      will also receive "Hello World" packets.
    
      This application doesn't have a profile, so it handles everything
      directly - by itself.
    
      Key control:
        SW1:  changes the delay between TX packets
        SW2:  initiates end device binding
        SW3:
        SW4:  initiates a match description request
    *********************************************************************/
    
    /*********************************************************************
     * INCLUDES
     */
    #include "OSAL.h"
    #include "AF.h"
    #include "ZDApp.h"
    #include "ZDObject.h"
    #include "ZDProfile.h"
    
    #include "GenericApp.h"
    #include "DebugTrace.h"
    
    #if !defined( WIN32 ) || defined( ZBIT )
      #include "OnBoard.h"
    #endif
    
    /* HAL */
    #include "hal_lcd.h"
    #include "hal_led.h"
    #include "hal_key.h"
    #include "hal_uart.h"
    
    /* RTOS */
    #if defined( IAR_ARMCM3_LM )
    #include "RTOS_App.h"
    #endif
    
    /*********************************************************************
     * MACROS
     */
    
    /*********************************************************************
     * CONSTANTS
     */
    
    /*********************************************************************
     * TYPEDEFS
     */
    
    /*********************************************************************
     * GLOBAL VARIABLES
     */
    // This list should be filled with Application specific Cluster IDs.
    const cId_t GenericApp_ClusterList[GENERICAPP_MAX_CLUSTERS] =
    {
      GENERICAPP_CLUSTERID
    };
    
    const SimpleDescriptionFormat_t GenericApp_SimpleDesc =
    {
      GENERICAPP_ENDPOINT,              //  int Endpoint;
      GENERICAPP_PROFID,                //  uint16 AppProfId[2];
      GENERICAPP_DEVICEID,              //  uint16 AppDeviceId[2];
      GENERICAPP_DEVICE_VERSION,        //  int   AppDevVer:4;
      GENERICAPP_FLAGS,                 //  int   AppFlags:4;
      GENERICAPP_MAX_CLUSTERS,          //  byte  AppNumInClusters;
      (cId_t *)GenericApp_ClusterList,  //  byte *pAppInClusterList;
      GENERICAPP_MAX_CLUSTERS,          //  byte  AppNumInClusters;
      (cId_t *)GenericApp_ClusterList   //  byte *pAppInClusterList;
    };
    
    // This is the Endpoint/Interface description.  It is defined here, but
    // filled-in in GenericApp_Init().  Another way to go would be to fill
    // in the structure here and make it a "const" (in code space).  The
    // way it's defined in this sample app it is define in RAM.
    endPointDesc_t GenericApp_epDesc;
    
    /*********************************************************************
     * EXTERNAL VARIABLES
     */
    
    /*********************************************************************
     * EXTERNAL FUNCTIONS
     */
    
    /*********************************************************************
     * LOCAL VARIABLES
     */
    byte GenericApp_TaskID;   // Task ID for internal task/event processing
                              // This variable will be received when
                              // GenericApp_Init() is called.
    
    devStates_t GenericApp_NwkState;
    
    byte GenericApp_TransID;  // This is the unique message ID (counter)
    
    afAddrType_t GenericApp_DstAddr;
    
    // Number of recieved messages
    static uint16 rxMsgCount;
    
    // Time interval between sending messages
    static uint32 txMsgDelay = GENERICAPP_SEND_MSG_TIMEOUT;
    
    /*********************************************************************
     * LOCAL FUNCTIONS
     */
    static void GenericApp_ProcessZDOMsgs( zdoIncomingMsg_t *inMsg );
    static void GenericApp_HandleKeys( byte shift, byte keys );
    static void GenericApp_MessageMSGCB( afIncomingMSGPacket_t *pckt );
    static void GenericApp_SendTheMessage( void );
    
    #if defined( IAR_ARMCM3_LM )
    static void GenericApp_ProcessRtosMessage( void );
    #endif
    
    /*********************************************************************
     * NETWORK LAYER CALLBACKS
     */
    
    /*********************************************************************
     * PUBLIC FUNCTIONS
     */
    
    /*********************************************************************
     * @fn      GenericApp_Init
     *
     * @brief   Initialization function for the Generic App Task.
     *          This is called during initialization and should contain
     *          any application specific initialization (ie. hardware
     *          initialization/setup, table initialization, power up
     *          notificaiton ... ).
     *
     * @param   task_id - the ID assigned by OSAL.  This ID should be
     *                    used to send messages and set timers.
     *
     * @return  none
     */
    void GenericApp_Init( uint8 task_id )
    {
      GenericApp_TaskID = task_id;
      GenericApp_NwkState = DEV_INIT;
      GenericApp_TransID = 0;
    
      // 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().
    
      GenericApp_DstAddr.addrMode = (afAddrMode_t)AddrNotPresent;
      GenericApp_DstAddr.endPoint = 0;
      GenericApp_DstAddr.addr.shortAddr = 0;
    
      // Fill out the endpoint description.
      GenericApp_epDesc.endPoint = GENERICAPP_ENDPOINT;
      GenericApp_epDesc.task_id = &GenericApp_TaskID;
      GenericApp_epDesc.simpleDesc
                = (SimpleDescriptionFormat_t *)&GenericApp_SimpleDesc;
      GenericApp_epDesc.latencyReq = noLatencyReqs;
    
      // Register the endpoint description with the AF
      afRegister( &GenericApp_epDesc );
    
      // Register for all key events - This app will handle all key events
      RegisterForKeys( GenericApp_TaskID );
    
      // Update the display
    #if defined ( LCD_SUPPORTED )
      HalLcdWriteString( "GenericApp", HAL_LCD_LINE_1 );
    #endif
    
      ZDO_RegisterForZDOMsg( GenericApp_TaskID, End_Device_Bind_rsp );
      ZDO_RegisterForZDOMsg( GenericApp_TaskID, Match_Desc_rsp );
    
    #if defined( IAR_ARMCM3_LM )
      // Register this task with RTOS task initiator
      RTOS_RegisterApp( task_id, GENERICAPP_RTOS_MSG_EVT );
    #endif
    }
    
    /*********************************************************************
     * @fn      GenericApp_ProcessEvent
     *
     * @brief   Generic Application Task event processor.  This function
     *          is called to process all events for the task.  Events
     *          include timers, messages and any other user defined events.
     *
     * @param   task_id  - The OSAL assigned task ID.
     * @param   events - events to process.  This is a bit map and can
     *                   contain more than one event.
     *
     * @return  none
     */
    uint16 GenericApp_ProcessEvent( uint8 task_id, uint16 events )
    {
      afIncomingMSGPacket_t *MSGpkt;
      afDataConfirm_t *afDataConfirm;
    
      // Data Confirmation message fields
      byte sentEP;
      ZStatus_t sentStatus;
      byte sentTransID;       // This should match the value sent
      (void)task_id;  // Intentionally unreferenced parameter
    
      if ( events & SYS_EVENT_MSG )
      {
        MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive( GenericApp_TaskID );
        while ( MSGpkt )
        {
          switch ( MSGpkt->hdr.event )
          {
            case ZDO_CB_MSG:
              GenericApp_ProcessZDOMsgs( (zdoIncomingMsg_t *)MSGpkt );
              break;
    
            case KEY_CHANGE:
              GenericApp_HandleKeys( ((keyChange_t *)MSGpkt)->state, ((keyChange_t *)MSGpkt)->keys );
              break;
    
            case AF_DATA_CONFIRM_CMD:
              // This message is received as a confirmation of a data packet sent.
              // The status is of ZStatus_t type [defined in ZComDef.h]
              // The message fields are defined in AF.h
              afDataConfirm = (afDataConfirm_t *)MSGpkt;
    
              sentEP = afDataConfirm->endpoint;
              (void)sentEP;  // This info not used now
              sentTransID = afDataConfirm->transID;
              (void)sentTransID;  // This info not used now
    
              sentStatus = afDataConfirm->hdr.status;
              // Action taken when confirmation is received.
              if ( sentStatus != ZSuccess )
              {
                // The data wasn't delivered -- Do something
              }
              break;
    
            case AF_INCOMING_MSG_CMD:
              GenericApp_MessageMSGCB( MSGpkt );
              break;
    
            case ZDO_STATE_CHANGE:
              GenericApp_NwkState = (devStates_t)(MSGpkt->hdr.status);
              if ( (GenericApp_NwkState == DEV_ZB_COORD) ||
                   (GenericApp_NwkState == DEV_ROUTER) ||
                   (GenericApp_NwkState == DEV_END_DEVICE) )
              {
                // Start sending "the" message in a regular interval.
                osal_start_timerEx( GenericApp_TaskID,
                                    GENERICAPP_SEND_MSG_EVT,
                                    txMsgDelay );
              }
              break;
    
            default:
              break;
          }
    
          // Release the memory
          osal_msg_deallocate( (uint8 *)MSGpkt );
    
          // Next
          MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive( GenericApp_TaskID );
        }
    
        // return unprocessed events
        return (events ^ SYS_EVENT_MSG);
      }
    
      // Send a message out - This event is generated by a timer
      //  (setup in GenericApp_Init()).
      if ( events & GENERICAPP_SEND_MSG_EVT )
      {
        // Send "the" message
        GenericApp_SendTheMessage();
    
        // Setup to send message again
        osal_start_timerEx( GenericApp_TaskID,
                            GENERICAPP_SEND_MSG_EVT,
                            txMsgDelay );
    
        // return unprocessed events
        return (events ^ GENERICAPP_SEND_MSG_EVT);
      }
    
    #if defined( IAR_ARMCM3_LM )
      // Receive a message from the RTOS queue
      if ( events & GENERICAPP_RTOS_MSG_EVT )
      {
        // Process message from RTOS queue
        GenericApp_ProcessRtosMessage();
    
        // return unprocessed events
        return (events ^ GENERICAPP_RTOS_MSG_EVT);
      }
    #endif
    
      // Discard unknown events
      return 0;
    }
    
    /*********************************************************************
     * Event Generation Functions
     */
    
    /*********************************************************************
     * @fn      GenericApp_ProcessZDOMsgs()
     *
     * @brief   Process response messages
     *
     * @param   none
     *
     * @return  none
     */
    static void GenericApp_ProcessZDOMsgs( zdoIncomingMsg_t *inMsg )
    {
      switch ( inMsg->clusterID )
      {
        case End_Device_Bind_rsp:
          if ( ZDO_ParseBindRsp( inMsg ) == ZSuccess )
          {
            // Light LED
            HalLedSet( HAL_LED_4, HAL_LED_MODE_ON );
          }
    #if defined( BLINK_LEDS )
          else
          {
            // Flash LED to show failure
            HalLedSet ( HAL_LED_4, HAL_LED_MODE_FLASH );
          }
    #endif
          break;
    
        case Match_Desc_rsp:
          {
            ZDO_ActiveEndpointRsp_t *pRsp = ZDO_ParseEPListRsp( inMsg );
            if ( pRsp )
            {
              if ( pRsp->status == ZSuccess && pRsp->cnt )
              {
                GenericApp_DstAddr.addrMode = (afAddrMode_t)Addr16Bit;
                GenericApp_DstAddr.addr.shortAddr = pRsp->nwkAddr;
                // Take the first endpoint, Can be changed to search through endpoints
                GenericApp_DstAddr.endPoint = pRsp->epList[0];
    
                // Light LED
                HalLedSet( HAL_LED_4, HAL_LED_MODE_ON );
              }
              osal_mem_free( pRsp );
            }
          }
          break;
      }
    }
    
    /*********************************************************************
     * @fn      GenericApp_HandleKeys
     *
     * @brief   Handles all key events for this device.
     *
     * @param   shift - true if in shift/alt.
     * @param   keys - bit field for key events. Valid entries:
     *                 HAL_KEY_SW_4
     *                 HAL_KEY_SW_3
     *                 HAL_KEY_SW_2
     *                 HAL_KEY_SW_1
     *
     * @return  none
     */
    static void GenericApp_HandleKeys( uint8 shift, uint8 keys )
    {
      zAddrType_t dstAddr;
    
      // Shift is used to make each button/switch dual purpose.
      if ( shift )
      {
        if ( keys & HAL_KEY_SW_1 )
        {
        }
        if ( keys & HAL_KEY_SW_2 )
        {
        }
        if ( keys & HAL_KEY_SW_3 )
        {
        }
        if ( keys & HAL_KEY_SW_4 )
        {
        }
      }
      else
      {
        if ( keys & HAL_KEY_SW_1 )
        {
    #if defined( SWITCH1_BIND )
          // We can use SW1 to simulate SW2 for devices that only have one switch,
          keys |= HAL_KEY_SW_2;
    #elif defined( SWITCH1_MATCH )
          // or use SW1 to simulate SW4 for devices that only have one switch
          keys |= HAL_KEY_SW_4;
    #else
          // Normally, SW1 changes the rate that messages are sent
          if ( txMsgDelay > 100 )
          {
            // Cut the message TX delay in half
            txMsgDelay /= 2;
          }
          else
          {
            // Reset to the default
            txMsgDelay = GENERICAPP_SEND_MSG_TIMEOUT;
          }
    #endif
        }
    
        if ( keys & HAL_KEY_SW_2 )
        {
          HalLedSet ( HAL_LED_4, HAL_LED_MODE_OFF );
    
          // Initiate an End Device Bind Request for the mandatory endpoint
          dstAddr.addrMode = Addr16Bit;
          dstAddr.addr.shortAddr = 0x0000; // Coordinator
          ZDP_EndDeviceBindReq( &dstAddr, NLME_GetShortAddr(),
                                GenericApp_epDesc.endPoint,
                                GENERICAPP_PROFID,
                                GENERICAPP_MAX_CLUSTERS, (cId_t *)GenericApp_ClusterList,
                                GENERICAPP_MAX_CLUSTERS, (cId_t *)GenericApp_ClusterList,
                                FALSE );
        }
    
        if ( keys & HAL_KEY_SW_3 )
        {
        }
    
        if ( keys & HAL_KEY_SW_4 )
        {
          HalLedSet ( HAL_LED_4, HAL_LED_MODE_OFF );
          // Initiate a Match Description Request (Service Discovery)
          dstAddr.addrMode = AddrBroadcast;
          dstAddr.addr.shortAddr = NWK_BROADCAST_SHORTADDR;
          ZDP_MatchDescReq( &dstAddr, NWK_BROADCAST_SHORTADDR,
                            GENERICAPP_PROFID,
                            GENERICAPP_MAX_CLUSTERS, (cId_t *)GenericApp_ClusterList,
                            GENERICAPP_MAX_CLUSTERS, (cId_t *)GenericApp_ClusterList,
                            FALSE );
        }
      }
    }
    
    /*********************************************************************
     * LOCAL FUNCTIONS
     */
    
    /*********************************************************************
     * @fn      GenericApp_MessageMSGCB
     *
     * @brief   Data message processor callback.  This function processes
     *          any incoming data - probably from other devices.  So, based
     *          on cluster ID, perform the intended action.
     *
     * @param   none
     *
     * @return  none
     */
    static void GenericApp_MessageMSGCB( afIncomingMSGPacket_t *pkt )
    {
      switch ( pkt->clusterId )
      {
        case GENERICAPP_CLUSTERID:
          rxMsgCount += 1;  // Count this message
          HalLedSet ( HAL_LED_4, HAL_LED_MODE_BLINK );  // Blink an LED
    #if defined( LCD_SUPPORTED )
          HalLcdWriteString( (char*)pkt->cmd.Data, HAL_LCD_LINE_1 );
          HalLcdWriteStringValue( "Rcvd:", rxMsgCount, 10, HAL_LCD_LINE_2 );
    #elif defined( WIN32 )
          WPRINTSTR( pkt->cmd.Data );
    #endif
          break;
      }
    }
    
    /*********************************************************************
     * @fn      GenericApp_SendTheMessage
     *
     * @brief   Send "the" message.
     *
     * @param   none
     *
     * @return  none
     */
    static void GenericApp_SendTheMessage( void )
    {
      char theMessageData[] = "Hello World";
    
      if ( AF_DataRequest( &GenericApp_DstAddr, &GenericApp_epDesc,
                           GENERICAPP_CLUSTERID,
                           (byte)osal_strlen( theMessageData ) + 1,
                           (byte *)&theMessageData,
                           &GenericApp_TransID,
                           AF_DISCV_ROUTE, AF_DEFAULT_RADIUS ) == afStatus_SUCCESS )
      {
        // Successfully requested to be sent.
      }
      else
      {
        // Error occurred in request to send.
      }
    }
    
    #if defined( IAR_ARMCM3_LM )
    /*********************************************************************
     * @fn      GenericApp_ProcessRtosMessage
     *
     * @brief   Receive message from RTOS queue, send response back.
     *
     * @param   none
     *
     * @return  none
     */
    static void GenericApp_ProcessRtosMessage( void )
    {
      osalQueue_t inMsg;
    
      if ( osal_queue_receive( OsalQueue, &inMsg, 0 ) == pdPASS )
      {
        uint8 cmndId = inMsg.cmnd;
        uint32 counter = osal_build_uint32( inMsg.cbuf, 4 );
    
        switch ( cmndId )
        {
          case CMD_INCR:
            counter += 1;  /* Increment the incoming counter */
                           /* Intentionally fall through next case */
    
          case CMD_ECHO:
          {
            userQueue_t outMsg;
    
            outMsg.resp = RSP_CODE | cmndId;  /* Response ID */
            osal_buffer_uint32( outMsg.rbuf, counter );    /* Increment counter */
            osal_queue_send( UserQueue1, &outMsg, 0 );  /* Send back to UserTask */
            break;
          }
    
          default:
            break;  /* Ignore unknown command */
        }
      }
    }
    #endif
    
    /*********************************************************************
     */
    
    static void GenericApp_ProcessZDOMsgs( zdoIncomingMsg_t *inMsg )

  • 感谢您 的回答,我可能描述不够清楚,下面再详细描述一下:
    我发现这个函数的定义
    /*
    * ZDO_ParseMgmtLeaveRsp - Parse the Mgmt_Leave_rsp message.
    * Parameter: a - pointer to the message to parse [zdoIncomingMsg_t *]
    *
    * returns the status field of the message.
    */
    #define ZDO_ParseMgmtLeaveRsp(a) ((uint8)(*(a->asdu)));

    然后我找到这个结构体zdoIncomingMsg_t的定义,
    typedef struct
    {
    osal_event_hdr_t hdr;
    zAddrType_t srcAddr;
    uint8 wasBroadcast;
    cId_t clusterID;
    uint8 SecurityUse;
    uint8 TransSeq;
    uint8 asduLen;
    uint16 macDestAddr;
    uint8 *asdu;
    uint16 macSrcAddr;
    } zdoIncomingMsg_t;

    不明白这里的 *asdu这个指针的具体含义,其实我的最终意思就是想知道 ZDO_ParseMgmtLeaveRsp(pMsg)这函数里面的参数pMsg包含什么内容
  • asdu 代表了具体的数据,

    你使用ZDO_ParseMgmtLeaveRsp()



    ZDO_ParseMgmtLeaveRsp - Parse the Mgmt_Leave_rsp message.
    * Parameter: a - pointer to the message to parse [zdoIncomingMsg_t *]
    *
    * returns the status field of the message.
    */
    #define ZDO_ParseMgmtLeaveRsp(a) ((uint8)(*(a->asdu)))
    这个返回的是一个状态。


    具体使用如下:

    status =ZDO_ParseMgmtLeaveRsp(inMsg->asdu)


    if(status == ZSuccess)
    {

    ........
    }
  • asdu这个指针的具体含义是APS service data unit