wateras1 发表于 2016-5-21 21:50 以后你问问题就直接说下你是怎么做的吧，看代码很费解，多个终端节点向协调器发送数据时，对于事件定时器你 ...

我是终端串口接收到数据，然后调用回调函数引发发送函数事件。没用事件定时，终端发送采用点播的方式。

/********************************************************************* * INCLUDES */ #include #include #include "AF.h" #include "OnBoard.h" #include "OSAL_Tasks.h" #include "SerialApp.h" #include "ZDApp.h" #include "ZDObject.h" #include "ZDProfile.h" #include "hal_drivers.h" #include "hal_key.h" #if defined ( LCD_SUPPORTED )   #include "hal_lcd.h" #endif #include "hal_led.h" #include "hal_uart.h" /********************************************************************* * MACROS */ /********************************************************************* * CONSTANTS */ #if !defined( SERIAL_APP_PORT ) #define SERIAL_APP_PORT  0 #endif #if !defined( SERIAL_APP_BAUD )   //#define SERIAL_APP_BAUD  HAL_UART_BR_38400   #define SERIAL_APP_BAUD  HAL_UART_BR_115200 #endif // When the Rx buf space is less than this threshold, invoke the Rx callback. #if !defined( SERIAL_APP_THRESH ) #define SERIAL_APP_THRESH  64 #endif #if !defined( SERIAL_APP_RX_SZ ) #define SERIAL_APP_RX_SZ  128 #endif #if !defined( SERIAL_APP_TX_SZ ) #define SERIAL_APP_TX_SZ  128 #endif // Millisecs of idle time after a byte is received before invoking Rx callback. #if !defined( SERIAL_APP_IDLE ) #define SERIAL_APP_IDLE  6 #endif // Loopback Rx bytes to Tx for throughput testing. #if !defined( SERIAL_APP_LOOPBACK ) #define SERIAL_APP_LOOPBACK  FALSE #endif // This is the max byte count per OTA message. #if !defined( SERIAL_APP_TX_MAX ) #define SERIAL_APP_TX_MAX  80 #endif #define SERIAL_APP_RSP_CNT  4 // This list should be filled with Application specific Cluster IDs. const cId_t SerialApp_ClusterList[SERIALAPP_MAX_CLUSTERS] = {   SERIALAPP_CLUSTERID1,   SERIALAPP_CLUSTERID2,   SERIALAPP_CONNECTREQ_CLUSTER,               SERIALAPP_CONNECTRSP_CLUSTER             }; const SimpleDescriptionFormat_t SerialApp_SimpleDesc = {   SERIALAPP_ENDPOINT,              //  int   Endpoint;   SERIALAPP_PROFID,                //  uint16 AppProfId[2];   SERIALAPP_DEVICEID,              //  uint16 AppDeviceId[2];   SERIALAPP_DEVICE_VERSION,        //  int   AppDevVer:4;   SERIALAPP_FLAGS,                 //  int   AppFlags:4;   SERIALAPP_MAX_CLUSTERS,          //  byte  AppNumInClusters;   (cId_t *)SerialApp_ClusterList,  //  byte *pAppInClusterList;   SERIALAPP_MAX_CLUSTERS,          //  byte  AppNumOutClusters;   (cId_t *)SerialApp_ClusterList   //  byte *pAppOutClusterList; }; endPointDesc_t SerialApp_epDesc = {   SERIALAPP_ENDPOINT, &SerialApp_TaskID,   (SimpleDescriptionFormat_t *)&SerialApp_SimpleDesc,   noLatencyReqs }; /********************************************************************* * TYPEDEFS */ /********************************************************************* * GLOBAL VARIABLES */ devStates_t SampleApp_NwkState;    uint8 SerialApp_TaskID;           // Task ID for internal task/event processing. /********************************************************************* * EXTERNAL VARIABLES */ /********************************************************************* * EXTERNAL FUNCTIONS */ /********************************************************************* * LOCAL VARIABLES */ static uint8 SerialApp_MsgID; static afAddrType_t SerialApp_TxAddr; static uint8 SerialApp_TxSeq; static uint8 *SerialApp_TxBuf;//[SERIAL_APP_TX_MAX+1]; static uint8 SerialApp_TxLen; static afAddrType_t SerialApp_RxAddr; static uint8 SerialApp_RxSeq; static uint8 SerialApp_RspBuf[SERIAL_APP_RSP_CNT]; /********************************************************************* * LOCAL FUNCTIONS */ static void SerialApp_ProcessMSGCmd( afIncomingMSGPacket_t *pkt ); static void SerialApp_Send(void); static void SerialApp_Resp(void); static void SerialApp_CallBack(uint8 port, uint8 event); static void SerialApp_DeviceConnect(void);               static void SerialApp_DeviceConnectRsp(uint8*);          static void SerialApp_ConnectReqProcess(uint8*);            /********************************************************************* * @fn      SerialApp_Init * * @brief   This is called during OSAL tasks' initialization. * * @param   task_id - the Task ID assigned by OSAL. * * @return  none */ void SerialApp_Init( uint8 task_id ) {   halUARTCfg_t uartConfig;   SerialApp_TaskID = task_id;   SerialApp_RxSeq = 0xC3;   SampleApp_NwkState = DEV_INIT;            afRegister( (endPointDesc_t *)&SerialApp_epDesc );   RegisterForKeys( task_id );   uartConfig.configured           = TRUE;              // 2x30 don't care - see uart driver.   uartConfig.baudRate             = SERIAL_APP_BAUD;   uartConfig.flowControl          = FALSE;   uartConfig.flowControlThreshold = SERIAL_APP_THRESH; // 2x30 don't care - see uart driver.   uartConfig.rx.maxBufSize        = SERIAL_APP_RX_SZ;  // 2x30 don't care - see uart driver.   uartConfig.tx.maxBufSize        = SERIAL_APP_TX_SZ;  // 2x30 don't care - see uart driver.   uartConfig.idleTimeout          = SERIAL_APP_IDLE;   // 2x30 don't care - see uart driver.   uartConfig.intEnable            = TRUE;              // 2x30 don't care - see uart driver.   uartConfig.callBackFunc         = SerialApp_CallBack;   HalUARTOpen (SERIAL_APP_PORT, &uartConfig); #if defined ( LCD_SUPPORTED )   HalLcdWriteString( "SerialApp", HAL_LCD_LINE_2 ); #endif      ZDO_RegisterForZDOMsg( SerialApp_TaskID, End_Device_Bind_rsp );   ZDO_RegisterForZDOMsg( SerialApp_TaskID, Match_Desc_rsp ); } /********************************************************************* * @fn      SerialApp_ProcessEvent * * @brief   Generic Application Task event processor. * * @param   task_id  - The OSAL assigned task ID. * @param   events   - Bit map of events to process. * * @return  Event flags of all unprocessed events. */ UINT16 SerialApp_ProcessEvent( uint8 task_id, UINT16 events ) {   (void)task_id;  // Intentionally unreferenced parameter      if ( events & SYS_EVENT_MSG )   {     afIncomingMSGPacket_t *MSGpkt;     while ( (MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive( SerialApp_TaskID )) )     {       switch ( MSGpkt->hdr.event )       {       case AF_INCOMING_MSG_CMD:         SerialApp_ProcessMSGCmd( MSGpkt );         break;                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.             HalLedSet(HAL_LED_1, HAL_LED_MODE_ON);                          if(SampleApp_NwkState != DEV_ZB_COORD)               SerialApp_DeviceConnect();                       }         else         {           // Device is no longer in the network         }         break;       default:         break;       }       osal_msg_deallocate( (uint8 *)MSGpkt );     }     return ( events ^ SYS_EVENT_MSG );   }   if ( events & SERIALAPP_SEND_EVT )   {     SerialApp_Send();     return ( events ^ SERIALAPP_SEND_EVT );   }   return ( 0 );  // Discard unknown events. } /********************************************************************* * @fn      SerialApp_ProcessMSGCmd * * @brief   Data message processor callback. This function processes *          any incoming data - probably from other devices. Based *          on the cluster ID, perform the intended action. * * @param   pkt - pointer to the incoming message packet * * @return  TRUE if the 'pkt' parameter is being used and will be freed later, *          FALSE otherwise. */ void SerialApp_ProcessMSGCmd( afIncomingMSGPacket_t *pkt ) {   switch ( pkt->clusterId )   {           uint8 *pointer1;   // A message with a serial data block to be transmitted on the serial port.     case SERIALAPP_CLUSTERID1: //收到发送过来的数据通过串口输出到电脑显示    //len = pkt->cmd.Data[0];       pointer1=&pkt->cmd.Data[1];//?óê?êy?Y????￡????òêy?Y       HalUARTWrite(SERIAL_APP_PORT, pointer1, pkt->cmd.Data[0]);//HalUARTWrite(SERIAL_APP_PORT,pointer1,pkt.Data[0]);       break;     case SERIALAPP_CONNECTREQ_CLUSTER:       SerialApp_ConnectReqProcess((uint8*)pkt->cmd.Data);            case SERIALAPP_CONNECTRSP_CLUSTER:       SerialApp_DeviceConnectRsp((uint8*)pkt->cmd.Data);            default:       break;   } } /********************************************************************* * @fn      SerialApp_Send * * @brief   Send data OTA. * * @param   none * * @return  none */ static void SerialApp_Send(void) {    #if SERIAL_APP_LOOPBACK     if (SerialApp_TxLen < SERIAL_APP_TX_MAX)     {         SerialApp_TxLen += HalUARTRead(SERIAL_APP_PORT, SerialApp_TxBuf+SerialApp_TxLen+1,                                                       SERIAL_APP_TX_MAX-SerialApp_TxLen);     }        if (SerialApp_TxLen)     {       (void)SerialApp_TxAddr;       if (HalUARTWrite(SERIAL_APP_PORT, SerialApp_TxBuf+1, SerialApp_TxLen))       {         SerialApp_TxLen = 0;       }       else       {         osal_set_event(SerialApp_TaskID, SERIALAPP_SEND_EVT);       }     } #else          SerialApp_TxAddr.addrMode = (afAddrMode_t)Addr16Bit;   SerialApp_TxAddr.endPoint = SERIALAPP_ENDPOINT;   SerialApp_TxAddr.addr.shortAddr = 0x0000;      if(AF_DataRequest    (&SerialApp_TxAddr,                        (endPointDesc_t *)&SerialApp_epDesc,                        SERIALAPP_CLUSTERID1,                        SerialApp_TxLen+1, SerialApp_TxBuf,                        &SerialApp_MsgID, 0, AF_DEFAULT_RADIUS                        )== afStatus_SUCCESS)   {     //osal_mem_free(SerialApp_TxBuf);       SerialApp_TxLen = 0;   }   else   {      osal_set_event(SerialApp_TaskID,SERIALAPP_SEND_EVT);   } #endif } /********************************************************************* * @fn      SerialApp_Resp * * @brief   Send data OTA. * * @param   none * * @return  none */ static void SerialApp_Resp(void) {   if (afStatus_SUCCESS != AF_DataRequest(&SerialApp_RxAddr,                                          (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);   } } /********************************************************************* * @fn      SerialApp_CallBack * * @brief   Send data OTA. * * @param   port - UART port. * @param   event - the UART port event flag. * * @return  none */ static void SerialApp_CallBack(uint8 port, uint8 event) {     extern uint8 SerialApp_TaskID;      SerialApp_TxLen = Hal_UART_RxBufLen(SERIAL_APP_PORT);   SerialApp_TxBuf = osal_mem_alloc(SerialApp_TxLen+1);   SerialApp_TxBuf[0] = SerialApp_TxLen;      HalUARTRead(SERIAL_APP_PORT,SerialApp_TxBuf+1,SerialApp_TxLen);   if(!SerialApp_TxLen)     osal_mem_free(SerialApp_TxBuf);         osal_set_event(SerialApp_TaskID,SERIALAPP_SEND_EVT);    } /********************************************************************* *********************************************************************/ void  SerialApp_DeviceConnect()               { #if ZDO_COORDINATOR    #else      uint16 nwkAddr;   uint16 parentNwkAddr;   char buff[30] = {0};      HalLedBlink( HAL_LED_2, 3, 50, (1000 / 4) );      nwkAddr = NLME_GetShortAddr();   parentNwkAddr = NLME_GetCoordShortAddr();   sprintf(buff, "parent:%d   self:%d\r\n", parentNwkAddr, nwkAddr);   HalUARTWrite ( 0, (uint8*)buff, strlen(buff));      SerialApp_TxAddr.addrMode = (afAddrMode_t)Addr16Bit;   SerialApp_TxAddr.endPoint = SERIALAPP_ENDPOINT;   SerialApp_TxAddr.addr.shortAddr = parentNwkAddr;      buff[0] = HI_UINT16( nwkAddr );   buff[1] = LO_UINT16( nwkAddr );      if ( AF_DataRequest( &SerialApp_TxAddr, &SerialApp_epDesc,                        SERIALAPP_CONNECTREQ_CLUSTER,                        2,                        (uint8*)buff,                        &SerialApp_MsgID,                        0,                        AF_DEFAULT_RADIUS ) == afStatus_SUCCESS )   {   }   else   {     // Error occurred in request to send.   }    #endif    //ZDO_COORDINATOR } void SerialApp_DeviceConnectRsp(uint8 *buf) { #if ZDO_COORDINATOR    #else   SerialApp_TxAddr.addrMode = (afAddrMode_t)Addr16Bit;   SerialApp_TxAddr.endPoint = SERIALAPP_ENDPOINT;   SerialApp_TxAddr.addr.shortAddr = BUILD_UINT16(buf[1], buf[0]);      HalLedSet(HAL_LED_2, HAL_LED_MODE_ON);   HalUARTWrite ( 0, "< connect success>\n", 23); #endif } void SerialApp_ConnectReqProcess(uint8 *buf) {   uint16 nwkAddr;   char buff[30] = {0};      SerialApp_TxAddr.addrMode = (afAddrMode_t)Addr16Bit;   SerialApp_TxAddr.endPoint = SERIALAPP_ENDPOINT;   SerialApp_TxAddr.addr.shortAddr = BUILD_UINT16(buf[1], buf[0]);   nwkAddr = NLME_GetShortAddr();      sprintf(buff, "self:%d   child:%d\r\n", nwkAddr, SerialApp_TxAddr.addr.shortAddr);   HalUARTWrite ( 0, (uint8*)buff, strlen(buff));      buff[0] = HI_UINT16( nwkAddr );   buff[1] = LO_UINT16( nwkAddr );      if ( AF_DataRequest( &SerialApp_TxAddr, &SerialApp_epDesc,                        SERIALAPP_CONNECTRSP_CLUSTER,                        2,                        (uint8*)buff,                        &SerialApp_MsgID,                        0,                        AF_DEFAULT_RADIUS ) == afStatus_SUCCESS )   {   }   else   {     // Error occurred in request to send.   }      HalLedSet(HAL_LED_2, HAL_LED_MODE_ON);   HalUARTWrite ( 0, "< connect success>\n", 23); }复制代码

谢谢楼主