/********************************************************************** @fn      RefNode_ProcessEvent** @brief   Generic Application Task event processor.** @param   task_id  - The OSAL assigned task ID.* @param   events - Bit map of events to process.** @return  none*/
uint16 RefNode_ProcessEvent( byte task_id, uint16 events )
{if ( events & SYS_EVENT_MSG ){afIncomingMSGPacket_t *MSGpkt;while ((MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive(RefNode_TaskID))){switch ( MSGpkt->hdr.event ){case KEY_CHANGE://LocationHandleKeys( ((keyChange_t *)MSGpkt)->state, ((keyChange_t *)MSGpkt)->keys );break;case AF_DATA_CONFIRM_CMD:break;case AF_INCOMING_MSG_CMD:processMSGCmd( MSGpkt );break;case ZDO_STATE_CHANGE:osal_start_timerEx( RefNode_TaskID, ANNCE_EVT, ANNCE_DELAY );break;default:break;}osal_msg_deallocate( (uint8 *)MSGpkt );}// Return unprocessed events.return ( events ^ SYS_EVENT_MSG );}if ( events & ANNCE_EVT ){/* Broadcast the X,Y location for any passive listeners in order to* register this node.*/afAddrType_t dstAddr;dstAddr.addrMode = afAddrBroadcast;dstAddr.addr.shortAddr = NWK_BROADCAST_SHORTADDR_DEVALL;dstAddr.endPoint = LOCATION_DONGLE_ENDPOINT;(void)AF_DataRequest( &dstAddr, (endPointDesc_t *)&epDesc,LOCATION_REFNODE_CONFIG, REFNODE_CONFIG_LEN, rspMsg,&transId, 0, AF_DEFAULT_RADIUS );return ( events ^ ANNCE_EVT );}return 0;  // Discard unknown events
}

  if ( events & ANNCE_EVT ){/* Broadcast the X,Y location for any passive listeners in order to* register this node.*/afAddrType_t dstAddr;dstAddr.addrMode = afAddrBroadcast;dstAddr.addr.shortAddr = NWK_BROADCAST_SHORTADDR_DEVALL;dstAddr.endPoint = LOCATION_DONGLE_ENDPOINT;(void)AF_DataRequest( &dstAddr, (endPointDesc_t *)&epDesc,LOCATION_REFNODE_CONFIG, REFNODE_CONFIG_LEN, rspMsg,&transId, 0, AF_DEFAULT_RADIUS );return ( events ^ ANNCE_EVT );}

      case AF_INCOMING_MSG_CMD:processMSGCmd( MSGpkt );break;

/********************************************************************** @fn      processMSGCmd** @brief   Data message processor callback.** @param   none** @return  none*/
static void processMSGCmd( afIncomingMSGPacket_t *pkt )
{switch ( pkt->clusterId ){case LOCATION_XY_RSSI_REQUEST:rssiRsp( pkt );break;case LOCATION_REFNODE_CONFIG:parseConfig( pkt->cmd.Data );break;case LOCATION_REFNODE_REQUEST_CONFIG:pkt->srcAddr.addrMode = afAddr16Bit;(void)AF_DataRequest( &pkt->srcAddr, (endPointDesc_t *)&epDesc,LOCATION_REFNODE_CONFIG, REFNODE_CONFIG_LEN, rspMsg,&transId, 0, AF_DEFAULT_RADIUS );break;case LOCATION_RSSI_BLAST:addBlast( pkt->srcAddr.addr.shortAddr, pkt->LinkQuality );break;default:break;}
}

void RefNode_Init( byte task_id )
{// Register the endpoint/interface description with the AF.afRegister( (endPointDesc_t *)&epDesc );// Register for all key events - This app will handle all key events.// RegisterForKeys( RefNode_TaskID );

static const endPointDesc_t epDesc =
{LOCATION_REFNODE_ENDPOINT,&RefNode_TaskID,(SimpleDescriptionFormat_t *)&RefNode_SimpleDesc,noLatencyReqs
};

  case LOCATION_RSSI_BLAST:addBlast( pkt->srcAddr.addr.shortAddr, pkt->LinkQuality );

/********************************************************************** @fn      addBlast** @brief   Add or initialize an RSSI blast for the given Network Address.** @param   uint16 - Network address of the Blind Node blasting.*          byte   - RSSI of the blast message received.** @return  none*/
static void addBlast( uint16 addr, byte rssi )
{blastAcc_t *ptr = blastPtr;while ( ptr ){if ( ptr->addr == addr ){break;}ptr = ptr->next;}if ( ptr ){ptr->acc += rssi;ptr->cnt++;}else{ptr = (blastAcc_t *)osal_mem_alloc( sizeof( blastAcc_t ) );if ( ptr ){ptr->next = blastPtr;blastPtr = ptr;ptr->addr = addr;ptr->acc = rssi;ptr->cnt = 1;}}
}

typedef struct _blastAcc_t
{struct _blastAcc_t *next;uint16 addr;uint16 acc;byte cnt;
} blastAcc_t;

  case LOCATION_XY_RSSI_REQUEST:rssiRsp( pkt );break;

/********************************************************************** @fn      rssiRsp** @brief   Respond to requester with average of their RSSI blasts.** @param   uint16 - Network address of the Blind Node requesting.*          byte   - Endpoint of the Blind Node requesting.*          byte   - RSSI of the blast message received.** @return  none*/
static void rssiRsp( afIncomingMSGPacket_t *pkt )
{blastAcc_t *ptr = blastPtr;blastAcc_t *prev = NULL;byte options, radius;while ( ptr ){if ( ptr->addr == pkt->srcAddr.addr.shortAddr ){break;}prev = ptr;ptr = ptr->next;}if ( ptr ){rspMsg[LOCATION_XY_RSSI_RSSI_IDX] =(ptr->acc + pkt->LinkQuality) / (ptr->cnt + 1);if ( prev ){prev->next = ptr->next;}else{blastPtr = ptr->next;}osal_mem_free( ptr );options = AF_SKIP_ROUTING;radius = 1;}else{rspMsg[LOCATION_XY_RSSI_RSSI_IDX] = pkt->LinkQuality;options = AF_TX_OPTIONS_NONE;radius = AF_DEFAULT_RADIUS;}pkt->srcAddr.addrMode = afAddr16Bit;(void)AF_DataRequest( &pkt->srcAddr, (endPointDesc_t *)&epDesc,LOCATION_XY_RSSI_RESPONSE, LOCATION_XY_RSSI_LEN,rspMsg, &transId, options, radius );
}/*********************************************************************
*********************************************************************/

 if ( ptr ){rspMsg[LOCATION_XY_RSSI_RSSI_IDX] =(ptr->acc + pkt->LinkQuality) / (ptr->cnt + 1);if ( prev ){prev->next = ptr->next;}else{blastPtr = ptr->next;}osal_mem_free( ptr );options = AF_SKIP_ROUTING;radius = 1;

   rspMsg[LOCATION_XY_RSSI_RSSI_IDX] = pkt->LinkQuality;options = AF_TX_OPTIONS_NONE;radius = AF_DEFAULT_RADIUS;

  pkt->srcAddr.addrMode = afAddr16Bit;(void)AF_DataRequest( &pkt->srcAddr, (endPointDesc_t *)&epDesc,LOCATION_XY_RSSI_RESPONSE, LOCATION_XY_RSSI_LEN,rspMsg, &transId, options, radius );

if ( events & BLINDNODE_BLAST_EVT )
{if ( blastCnt == 0 ){state = eBnBlastOff;finishCollection();}