[求助] 关于zigbee多对一串口透传问题

进击的学霸 2016-5-21 21:22 楼主

目前大二，项目中需要用到zigbee。现在要用到的功能是zigbee一对多串口透传功能。在某宝上提供资料中的一对一例程上进行修改，功能大概实现了，串口持续发送数据，1秒一次的样子，同时上4个终端。可是5分钟左右就会死一个，过一会就全死了。至今不知道什么原因，贴上代码，各位大神给个建议

串口透传.zip (2016-5-21 21:22 上传)

12.11 MB, 下载次数: 915

回复评论（8）

沙发进击的学霸

/*********************************************************************
* INCLUDES
*/
#include <stdio.h>
#include <string.h>
#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);
}

点赞 2016-5-21 21:25

以后你问问题就直接说下你是怎么做的吧，看代码很费解，多个终端节点向协调器发送数据时，对于事件定时器你最好加一个随机数呀，你想搞死协调器吗?数据同时到的话，不丢包才怪，一般一对多可以采用组包的方式或者广播的也有采用，不过广播的话容易造成网络拥塞，我之前采用过自己定义路由表的方法，单播模拟广播的方法，相同数据量，发送间隔缩短可以达到几十ms，之前直接广播的话，需要几百ms,而且节点容易发包发着就挂了。