123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823 |
- /**************************************************************************************************
- Filename: TransmitApp.c
- Revised: $Date: 2012-03-05 09:54:49 -0800 (Mon, 05 Mar 2012) $
- Revision: $Revision: 29619 $
- Description: Transmit Application (no Profile).
- Copyright 2004-2012 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 will send a data packet to another
- tranmitApp device as fast as it can. The receiving
- transmitApp device will calculate the following transmit
- rate statistics:
- - Number bytes in the last second
- - Number of seconds running
- - Average number of bytes per second
- - Number of packets received.
- The application will send one message and as soon as it
- receives the confirmation for that message it will send
- the next message.
- If you would like a delay between messages
- define TRANSMITAPP_DELAY_SEND and set the delay amount
- in TRANSMITAPP_SEND_DELAY.
- TransmitApp_MaxDataLength defines the message size
- Set TRANSMITAPP_TX_OPTIONS to AF_MSG_ACK_REQUEST to send
- the message expecting an APS ACK, this will decrease your
- throughput. Set TRANSMITAPP_TX_OPTIONS to 0 for no
- APS ACK.
- This applications doesn't have a profile, so it handles
- everything directly - itself.
- Key control:
- SW1: Starts and stops the transmitting
- SW2: initiates end device binding
- SW3: Resets the display totals
- SW4: initiates a match description request
- Notes:
- This application was intended to be used to test the maximum
- throughput between 2 devices in a network - between routers
- coordinators.
- Although not recommended, it can be used between
- an end device and a router (or coordinator), but you must
- enable the delay feature (TRANSMITAPP_DELAY_SEND and
- TRANSMITAPP_SEND_DELAY). If you don't include the delay, the
- end device can't receive messages because it will stop polling.
- Also, the delay must be greater than RESPONSE_POLL_RATE (default 100 MSec).
- *********************************************************************/
- /*********************************************************************
- * INCLUDES
- */
- #include "OSAL.h"
- #include "AF.h"
- #include "ZDObject.h"
- #include "ZDProfile.h"
- #include "TransmitApp.h"
- #include "OnBoard.h"
- #include "DebugTrace.h"
- /* HAL */
- #include "hal_lcd.h"
- #include "hal_led.h"
- #include "hal_key.h"
- #include "hal_uart.h"
- /*********************************************************************
- * MACROS
- */
- /*********************************************************************
- * CONSTANTS
- */
- //#define TRANSMITAPP_RANDOM_LEN
- #define TRANSMITAPP_STATE_WAITING 0
- #define TRANSMITAPP_STATE_SENDING 1
- #if !defined ( RTR_NWK )
- // Use these 2 lines to add a delay between each packet sent
- // - default for end devices
- #define TRANSMITAPP_DELAY_SEND
- #define TRANSMITAPP_SEND_DELAY (RESPONSE_POLL_RATE * 2) // in MSecs
- #endif
- // Send with or without APS ACKs
- //#define TRANSMITAPP_TX_OPTIONS (AF_DISCV_ROUTE | AF_ACK_REQUEST)
- #define TRANSMITAPP_TX_OPTIONS AF_DISCV_ROUTE
- #define TRANSMITAPP_INITIAL_MSG_COUNT 2
- #define TRANSMITAPP_TRANSMIT_TIME 4 // 4 MS
- #define TRANSMITAPP_DISPLAY_TIMER (2 * 1000)
- #if defined ( TRANSMITAPP_FRAGMENTED )
- #define TRANSMITAPP_MAX_DATA_LEN 225
- #else
- #define TRANSMITAPP_MAX_DATA_LEN 102
- #endif
- /*********************************************************************
- * TYPEDEFS
- */
- /*********************************************************************
- * GLOBAL VARIABLES
- */
- // This is the buffer that is sent out as data.
- byte TransmitApp_Msg[ TRANSMITAPP_MAX_DATA_LEN ];
- // This is the Cluster ID List and should be filled with Application
- // specific cluster IDs.
- const cId_t TransmitApp_ClusterList[TRANSMITAPP_MAX_CLUSTERS] =
- {
- TRANSMITAPP_CLUSTERID_TESTMSG // MSG Cluster ID
- };
- const SimpleDescriptionFormat_t TransmitApp_SimpleDesc =
- {
- TRANSMITAPP_ENDPOINT, // int Endpoint;
- TRANSMITAPP_PROFID, // uint16 AppProfId[2];
- TRANSMITAPP_DEVICEID, // uint16 AppDeviceId[2];
- TRANSMITAPP_DEVICE_VERSION, // int AppDevVer:4;
- TRANSMITAPP_FLAGS, // int AppFlags:4;
- TRANSMITAPP_MAX_CLUSTERS, // byte AppNumInClusters;
- (cId_t *)TransmitApp_ClusterList, // byte *pAppInClusterList;
- TRANSMITAPP_MAX_CLUSTERS, // byte AppNumInClusters;
- (cId_t *)TransmitApp_ClusterList // byte *pAppInClusterList;
- };
- // This is the Endpoint/Interface description. It is defined here, but
- // filled-in in TransmitApp_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 TransmitApp_epDesc;
- /*********************************************************************
- * EXTERNAL VARIABLES
- */
- /*********************************************************************
- * EXTERNAL FUNCTIONS
- */
- /*********************************************************************
- * LOCAL VARIABLES
- */
- // Task ID for event processing - received when TransmitApp_Init() is called.
- byte TransmitApp_TaskID;
- devStates_t TransmitApp_NwkState;
- static byte TransmitApp_TransID; // This is the unique message ID (counter)
- afAddrType_t TransmitApp_DstAddr;
- byte TransmitApp_State;
- // Shadow of the OSAL system clock used for calculating actual time expired.
- static uint32 clkShdw;
- // Running total count of test messages recv/sent since beginning current run.
- static uint32 rxTotal, txTotal;
- // Running count of test messages recv/sent since last display / update - 1 Hz.
- static uint32 rxAccum, txAccum;
- static byte timerOn;
- static byte timesToSend;
- uint16 pktCounter;
- // Max Data Request Length
- uint16 TransmitApp_MaxDataLength;
- /*********************************************************************
- * LOCAL FUNCTIONS
- */
- void TransmitApp_ProcessZDOMsgs( zdoIncomingMsg_t *inMsg );
- void TransmitApp_HandleKeys( byte shift, byte keys );
- void TransmitApp_MessageMSGCB( afIncomingMSGPacket_t *pckt );
- void TransmitApp_SendTheMessage( void );
- void TransmitApp_ChangeState( void );
- /*********************************************************************
- * NETWORK LAYER CALLBACKS
- */
- /*********************************************************************
- * PUBLIC FUNCTIONS
- */
- void TransmitApp_DisplayResults( void );
- /*********************************************************************
- * @fn TransmitApp_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 TransmitApp_Init( byte task_id )
- {
- #if !defined ( TRANSMITAPP_FRAGMENTED )
- afDataReqMTU_t mtu;
- #endif
- uint16 i;
- TransmitApp_TaskID = task_id;
- TransmitApp_NwkState = DEV_INIT;
- TransmitApp_TransID = 0;
- pktCounter = 0;
- TransmitApp_State = TRANSMITAPP_STATE_WAITING;
- // 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().
- TransmitApp_DstAddr.addrMode = (afAddrMode_t)AddrNotPresent;
- TransmitApp_DstAddr.endPoint = 0;
- TransmitApp_DstAddr.addr.shortAddr = 0;
- // Fill out the endpoint description.
- TransmitApp_epDesc.endPoint = TRANSMITAPP_ENDPOINT;
- TransmitApp_epDesc.task_id = &TransmitApp_TaskID;
- TransmitApp_epDesc.simpleDesc
- = (SimpleDescriptionFormat_t *)&TransmitApp_SimpleDesc;
- TransmitApp_epDesc.latencyReq = noLatencyReqs;
- // Register the endpoint/interface description with the AF
- afRegister( &TransmitApp_epDesc );
- // Register for all key events - This app will handle all key events
- RegisterForKeys( TransmitApp_TaskID );
- // Update the display
- #if defined ( LCD_SUPPORTED )
- HalLcdWriteString( "TransmitApp", HAL_LCD_LINE_2 );
- #endif
- // Set the data length
- #if defined ( TRANSMITAPP_FRAGMENTED )
- TransmitApp_MaxDataLength = TRANSMITAPP_MAX_DATA_LEN;
- #else
- mtu.kvp = FALSE;
- mtu.aps.secure = FALSE;
- TransmitApp_MaxDataLength = afDataReqMTU( &mtu );
- #endif
- // Generate the data
- for (i=0; i<TransmitApp_MaxDataLength; i++)
- {
- TransmitApp_Msg[i] = (uint8) i;
- }
- ZDO_RegisterForZDOMsg( TransmitApp_TaskID, End_Device_Bind_rsp );
- ZDO_RegisterForZDOMsg( TransmitApp_TaskID, Match_Desc_rsp );
- }
- /*********************************************************************
- * @fn TransmitApp_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 TransmitApp_ProcessEvent( byte task_id, UINT16 events )
- {
- afIncomingMSGPacket_t *MSGpkt;
- afDataConfirm_t *afDataConfirm;
- (void)task_id; // Intentionally unreferenced parameter
- // Data Confirmation message fields
- ZStatus_t sentStatus;
- byte sentEP;
- if ( events & SYS_EVENT_MSG )
- {
- MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive( TransmitApp_TaskID );
- while ( MSGpkt )
- {
- switch ( MSGpkt->hdr.event )
- {
- case ZDO_CB_MSG:
- TransmitApp_ProcessZDOMsgs( (zdoIncomingMsg_t *)MSGpkt );
- break;
- case KEY_CHANGE:
- TransmitApp_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;
- sentStatus = afDataConfirm->hdr.status;
- if ( (ZSuccess == sentStatus) &&
- (TransmitApp_epDesc.endPoint == sentEP) )
- {
- #if !defined ( TRANSMITAPP_RANDOM_LEN )
- txAccum += TransmitApp_MaxDataLength;
- #endif
- if ( !timerOn )
- {
- osal_start_timerEx( TransmitApp_TaskID,TRANSMITAPP_RCVTIMER_EVT,
- TRANSMITAPP_DISPLAY_TIMER);
- clkShdw = osal_GetSystemClock();
- timerOn = TRUE;
- }
- }
- // Action taken when confirmation is received: Send the next message.
- TransmitApp_SetSendEvt();
- break;
- case AF_INCOMING_MSG_CMD:
- TransmitApp_MessageMSGCB( MSGpkt );
- break;
- case ZDO_STATE_CHANGE:
- TransmitApp_NwkState = (devStates_t)(MSGpkt->hdr.status);
- break;
- default:
- break;
- }
- // Release the memory
- osal_msg_deallocate( (uint8 *)MSGpkt );
- // Next
- MSGpkt = (afIncomingMSGPacket_t *)osal_msg_receive( TransmitApp_TaskID );
- }
- // Squash compiler warnings until values are used.
- (void)sentStatus;
- (void)sentEP;
- // Return unprocessed events
- return (events ^ SYS_EVENT_MSG);
- }
- // Send a message out
- if ( events & TRANSMITAPP_SEND_MSG_EVT )
- {
- if ( TransmitApp_State == TRANSMITAPP_STATE_SENDING )
- {
- TransmitApp_SendTheMessage();
- }
- // Return unprocessed events
- return (events ^ TRANSMITAPP_SEND_MSG_EVT);
- }
- // Timed wait from error
- if ( events & TRANSMITAPP_SEND_ERR_EVT )
- {
- TransmitApp_SetSendEvt();
- // Return unprocessed events
- return (events ^ TRANSMITAPP_SEND_ERR_EVT);
- }
- // Receive timer
- if ( events & TRANSMITAPP_RCVTIMER_EVT )
- {
- // Setup to display the next result
- osal_start_timerEx( TransmitApp_TaskID, TRANSMITAPP_RCVTIMER_EVT,
- TRANSMITAPP_DISPLAY_TIMER );
- TransmitApp_DisplayResults();
- return (events ^ TRANSMITAPP_RCVTIMER_EVT);
- }
- // Discard unknown events
- return 0;
- }
- /*********************************************************************
- * Event Generation Functions
- */
- /*********************************************************************
- * @fn TransmitApp_ProcessZDOMsgs()
- *
- * @brief Process response messages
- *
- * @param none
- *
- * @return none
- */
- void TransmitApp_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 )
- {
- TransmitApp_DstAddr.addrMode = (afAddrMode_t)Addr16Bit;
- TransmitApp_DstAddr.addr.shortAddr = pRsp->nwkAddr;
- // Take the first endpoint, Can be changed to search through endpoints
- TransmitApp_DstAddr.endPoint = pRsp->epList[0];
- // Light LED
- HalLedSet( HAL_LED_4, HAL_LED_MODE_ON );
- }
- osal_mem_free( pRsp );
- }
- }
- break;
- }
- }
- /*********************************************************************
- * @fn TransmitApp_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:
- * EVAL_SW4
- * EVAL_SW3
- * EVAL_SW2
- * EVAL_SW1
- *
- * @return none
- */
- void TransmitApp_HandleKeys( byte shift, byte 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 )
- {
- TransmitApp_ChangeState();
- }
- 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(),
- TransmitApp_epDesc.endPoint,
- TRANSMITAPP_PROFID,
- TRANSMITAPP_MAX_CLUSTERS, (cId_t *)TransmitApp_ClusterList,
- TRANSMITAPP_MAX_CLUSTERS, (cId_t *)TransmitApp_ClusterList,
- FALSE );
- }
- if ( keys & HAL_KEY_SW_3 )
- {
- rxTotal = txTotal = 0;
- rxAccum = txAccum = 0;
- TransmitApp_DisplayResults();
- }
- 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,
- TRANSMITAPP_PROFID,
- TRANSMITAPP_MAX_CLUSTERS, (cId_t *)TransmitApp_ClusterList,
- TRANSMITAPP_MAX_CLUSTERS, (cId_t *)TransmitApp_ClusterList,
- FALSE );
- }
- }
- }
- /*********************************************************************
- * LOCAL FUNCTIONS
- */
- /*********************************************************************
- * @fn TransmitApp_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
- */
- void TransmitApp_MessageMSGCB( afIncomingMSGPacket_t *pkt )
- {
- uint16 i;
- uint8 error = FALSE;
- switch ( pkt->clusterId )
- {
- case TRANSMITAPP_CLUSTERID_TESTMSG:
- #if !defined ( TRANSMITAPP_RANDOM_LEN )
- if (pkt->cmd.DataLength != TransmitApp_MaxDataLength)
- {
- error = TRUE;
- }
- #endif
- for (i=4; i<pkt->cmd.DataLength; i++)
- {
- if (pkt->cmd.Data[i] != i%256)
- error = TRUE;
- }
- if (error)
- {
- // Display error LED
- HalLedSet(HAL_LED_1, HAL_LED_MODE_ON);
- }
- else
- {
- if ( !timerOn )
- {
- osal_start_timerEx( TransmitApp_TaskID, TRANSMITAPP_RCVTIMER_EVT,
- TRANSMITAPP_DISPLAY_TIMER );
- clkShdw = osal_GetSystemClock();
- timerOn = TRUE;
- }
- rxAccum += pkt->cmd.DataLength;
- }
- break;
- // Could receive control messages in the future.
- default:
- break;
- }
- }
- /*********************************************************************
- * @fn TransmitApp_SendTheMessage
- *
- * @brief Send "the" message.
- *
- * @param none
- *
- * @return none
- */
- void TransmitApp_SendTheMessage( void )
- {
- uint16 len;
- uint8 tmp;
- do {
- // put the sequence number in the message
- tmp = HI_UINT8( TransmitApp_TransID );
- tmp += (tmp <= 9) ? ('0') : ('A' - 0x0A);
- TransmitApp_Msg[2] = tmp;
- tmp = LO_UINT8( TransmitApp_TransID );
- tmp += (tmp <= 9) ? ('0') : ('A' - 0x0A);
- TransmitApp_Msg[3] = tmp;
- len = TransmitApp_MaxDataLength;
- #if defined ( TRANSMITAPP_RANDOM_LEN )
- len = (uint8)(osal_rand() & 0x7F);
- if( len > TransmitApp_MaxDataLength || len == 0 )
- len = TransmitApp_MaxDataLength;
- else if ( len < 4 )
- len = 4;
- #endif
-
- tmp = AF_DataRequest( &TransmitApp_DstAddr, &TransmitApp_epDesc,
- TRANSMITAPP_CLUSTERID_TESTMSG,
- len, TransmitApp_Msg,
- &TransmitApp_TransID,
- TRANSMITAPP_TX_OPTIONS,
- AF_DEFAULT_RADIUS );
- #if defined ( TRANSMITAPP_RANDOM_LEN )
- if ( tmp == afStatus_SUCCESS )
- {
- txAccum += len;
- }
- #endif
- if ( timesToSend )
- {
- timesToSend--;
- }
- } while ( (timesToSend != 0) && (afStatus_SUCCESS == tmp) );
- if ( afStatus_SUCCESS == tmp )
- {
- pktCounter++;
- }
- else
- {
- // Error, so wait (10 mSec) and try again.
- osal_start_timerEx( TransmitApp_TaskID, TRANSMITAPP_SEND_ERR_EVT, 10 );
- }
- }
- /*********************************************************************
- * @fn TransmitApp_ChangeState
- *
- * @brief Toggle the Sending/Waiting state flag
- *
- * @param none
- *
- * @return none
- */
- void TransmitApp_ChangeState( void )
- {
- if ( TransmitApp_State == TRANSMITAPP_STATE_WAITING )
- {
- TransmitApp_State = TRANSMITAPP_STATE_SENDING;
- TransmitApp_SetSendEvt();
- timesToSend = TRANSMITAPP_INITIAL_MSG_COUNT;
- }
- else
- {
- TransmitApp_State = TRANSMITAPP_STATE_WAITING;
- }
- }
- /*********************************************************************
- * @fn TransmitApp_SetSendEvt
- *
- * @brief Set the event flag
- *
- * @param none
- *
- * @return none
- */
- void TransmitApp_SetSendEvt( void )
- {
- #if defined( TRANSMITAPP_DELAY_SEND )
- // Adds a delay to sending the data
- osal_start_timerEx( TransmitApp_TaskID,
- TRANSMITAPP_SEND_MSG_EVT, TRANSMITAPP_SEND_DELAY );
- #else
- // No Delay - just send the data
- osal_set_event( TransmitApp_TaskID, TRANSMITAPP_SEND_MSG_EVT );
- #endif
- }
- /*********************************************************************
- * @fn TransmitApp_DisplayResults
- *
- * @brief Display the results and clear the accumulators
- *
- * @param none
- *
- * @return none
- */
- void TransmitApp_DisplayResults( void )
- {
- #ifdef LCD_SUPPORTED
- #define LCD_W 16
- uint32 rxShdw, txShdw, tmp;
- byte lcd_buf[LCD_W+1];
- byte idx;
- #endif
- // The OSAL timers are not real-time, so calculate the actual time expired.
- uint32 msecs = osal_GetSystemClock() - clkShdw;
- clkShdw = osal_GetSystemClock();
- rxTotal += rxAccum;
- txTotal += txAccum;
- #if defined ( LCD_SUPPORTED )
- rxShdw = (rxAccum * 1000 + msecs/2) / msecs;
- txShdw = (txAccum * 1000 + msecs/2) / msecs;
- osal_memset( lcd_buf, ' ', LCD_W );
- lcd_buf[LCD_W] = NULL;
- idx = 4;
- tmp = (rxShdw >= 100000) ? 99999 : rxShdw;
- do
- {
- lcd_buf[idx--] = (uint8) ('0' + (tmp % 10));
- tmp /= 10;
- } while ( tmp );
- idx = LCD_W-1;
- tmp = rxTotal;
- do
- {
- lcd_buf[idx--] = (uint8) ('0' + (tmp % 10));
- tmp /= 10;
- } while ( tmp );
- HalLcdWriteString( (char*)lcd_buf, HAL_LCD_LINE_1 );
- osal_memset( lcd_buf, ' ', LCD_W );
- idx = 4;
- tmp = (txShdw >= 100000) ? 99999 : txShdw;
- do
- {
- lcd_buf[idx--] = (uint8) ('0' + (tmp % 10));
- tmp /= 10;
- } while ( tmp );
- idx = LCD_W-1;
- tmp = txTotal;
- do
- {
- lcd_buf[idx--] = (uint8) ('0' + (tmp % 10));
- tmp /= 10;
- } while ( tmp );
- HalLcdWriteString( (char*)lcd_buf, HAL_LCD_LINE_2 );
- #elif defined( MT_TASK )
- DEBUG_INFO( COMPID_APP, SEVERITY_INFORMATION, 3,
- rxAccum, (uint16)msecs, (uint16)rxTotal );
- #else
- (void)msecs; // Not used when no output
- #endif
- if ( (rxAccum == 0) && (txAccum == 0) )
- {
- osal_stop_timerEx( TransmitApp_TaskID, TRANSMITAPP_RCVTIMER_EVT );
- timerOn = FALSE;
- }
- rxAccum = txAccum = 0;
- }
- /*********************************************************************
- *********************************************************************/
|