Andriy Makukha / Mbed 2 deprecated football_project_wo_output

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Dependencies:   mbed

Fork of football_project by MZJ

PhoneAppIO.cpp@11:d3aa5fca2330, 2015-04-23 (annotated)

Committer:
AntonLS
Date:
Thu Apr 23 06:36:57 2015 +0000
Revision:
11:d3aa5fca2330
Parent:
5:1b9734e68327
Child:
19:afcbb425b3cf
PhoneAppIO class working.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
AntonLS 5:1b9734e68327 1 /*
AntonLS 5:1b9734e68327 2 * Buffered IO of pending CharacteristicWrites meant to Nofify
AntonLS 11:d3aa5fca2330 3 * the phone/tablet application and reading of Characteristic
AntonLS 11:d3aa5fca2330 4 * set by the phone/tablet application. Started 20150416 ALS
AntonLS 5:1b9734e68327 5 *
AntonLS 5:1b9734e68327 6 */
AntonLS 5:1b9734e68327 7
AntonLS 5:1b9734e68327 8 #include "PhoneAppIO.h"
AntonLS 5:1b9734e68327 9
AntonLS 11:d3aa5fca2330 10 PhoneAppIO::PhoneAppIO( BLEDevice &ble, GattAttribute::Handle_t toPhoneHandle,
AntonLS 11:d3aa5fca2330 11 GattAttribute::Handle_t toConeHandle,
AntonLS 11:d3aa5fca2330 12 int txBufferSize, int rxBufferSize )
AntonLS 11:d3aa5fca2330 13 : mts::MTSBufferedIO( txBufferSize, rxBufferSize ),
AntonLS 11:d3aa5fca2330 14 bleP( &ble ), toPhoneHandle( toPhoneHandle ),
AntonLS 11:d3aa5fca2330 15 toConeHandle( toConeHandle )
AntonLS 5:1b9734e68327 16 {
AntonLS 11:d3aa5fca2330 17 loopbackMode = false;
AntonLS 11:d3aa5fca2330 18 bleWasntReady = false;
AntonLS 11:d3aa5fca2330 19
AntonLS 11:d3aa5fca2330 20 enableTxIrq();
AntonLS 11:d3aa5fca2330 21 enableRxIrq();
AntonLS 11:d3aa5fca2330 22
AntonLS 11:d3aa5fca2330 23 data = NULL;
AntonLS 11:d3aa5fca2330 24 bytesRead = 0;
AntonLS 11:d3aa5fca2330 25
AntonLS 11:d3aa5fca2330 26 memset( rx_buf, 0, TXRX_BUF_LEN );
AntonLS 11:d3aa5fca2330 27 rx_len = 0;
AntonLS 5:1b9734e68327 28 }
AntonLS 5:1b9734e68327 29
AntonLS 5:1b9734e68327 30 PhoneAppIO::~PhoneAppIO()
AntonLS 5:1b9734e68327 31 {
AntonLS 5:1b9734e68327 32 }
AntonLS 5:1b9734e68327 33
AntonLS 11:d3aa5fca2330 34 uint16_t PhoneAppIO::maybeHandleRead( const GattCharacteristicWriteCBParams *params ) // Called by onDataWritten() from BLE.
AntonLS 11:d3aa5fca2330 35 { // also writes to txPayload
AntonLS 11:d3aa5fca2330 36 bytesRead = 0;
AntonLS 5:1b9734e68327 37
AntonLS 11:d3aa5fca2330 38 if( params->charHandle == toConeHandle )
AntonLS 11:d3aa5fca2330 39 {
AntonLS 11:d3aa5fca2330 40 uint8_t buf[TXRX_BUF_LEN];
AntonLS 11:d3aa5fca2330 41 bytesRead = MIN( params->len, TXRX_BUF_LEN );
AntonLS 11:d3aa5fca2330 42
AntonLS 11:d3aa5fca2330 43 if( loopbackMode )
AntonLS 11:d3aa5fca2330 44 {
AntonLS 11:d3aa5fca2330 45 // Loopback data from Central.
AntonLS 11:d3aa5fca2330 46 updateCharacteristic( toPhoneHandle, params->data, bytesRead ); // Notifies. // TODO apply retries to this as well,
AntonLS 11:d3aa5fca2330 47 // but they might not be needed here.
AntonLS 11:d3aa5fca2330 48 }
AntonLS 11:d3aa5fca2330 49
AntonLS 11:d3aa5fca2330 50 bleP->readCharacteristicValue( toConeHandle, buf, &bytesRead );
AntonLS 11:d3aa5fca2330 51
AntonLS 11:d3aa5fca2330 52 // Copy data to accessible location for others and handleRead().
AntonLS 11:d3aa5fca2330 53 memset( txPayload, 0, TXRX_BUF_LEN );
AntonLS 11:d3aa5fca2330 54 memcpy( txPayload, buf, bytesRead );
AntonLS 11:d3aa5fca2330 55
AntonLS 11:d3aa5fca2330 56 // Buffer the data.
AntonLS 11:d3aa5fca2330 57 data = (char *)txPayload;
AntonLS 11:d3aa5fca2330 58 handleRead();
AntonLS 11:d3aa5fca2330 59 }
AntonLS 11:d3aa5fca2330 60
AntonLS 11:d3aa5fca2330 61 return bytesRead;
AntonLS 11:d3aa5fca2330 62 }
AntonLS 11:d3aa5fca2330 63
AntonLS 11:d3aa5fca2330 64 // Maybe write to RX characteristic (From cone to phone.)
AntonLS 11:d3aa5fca2330 65 uint16_t PhoneAppIO::maybeHandleWrite() // Called by toPhoneChk() from main loop.
AntonLS 5:1b9734e68327 66 {
AntonLS 11:d3aa5fca2330 67 uint16_t charsWritten = 0;
AntonLS 11:d3aa5fca2330 68
AntonLS 11:d3aa5fca2330 69 while( true )
AntonLS 11:d3aa5fca2330 70 {
AntonLS 11:d3aa5fca2330 71 if( !bleWasntReady )
AntonLS 11:d3aa5fca2330 72 {
AntonLS 11:d3aa5fca2330 73 char ch;
AntonLS 11:d3aa5fca2330 74
AntonLS 11:d3aa5fca2330 75 while( writing ); // Block.
AntonLS 11:d3aa5fca2330 76
AntonLS 11:d3aa5fca2330 77 if( 0 == txBuffer.read( ch ) ) break;
AntonLS 11:d3aa5fca2330 78
AntonLS 11:d3aa5fca2330 79 if( '\n' == ch ) continue; // Filter linefeeds.
AntonLS 11:d3aa5fca2330 80 rx_buf[rx_len++] = ch;
AntonLS 11:d3aa5fca2330 81 }
AntonLS 11:d3aa5fca2330 82 if( bleWasntReady || rx_len>=TXRX_BUF_LEN || rx_buf[rx_len-1]=='\r' || rx_buf[rx_len-1]=='\0' )
AntonLS 11:d3aa5fca2330 83 {
AntonLS 11:d3aa5fca2330 84 handleWrite();
AntonLS 11:d3aa5fca2330 85
AntonLS 11:d3aa5fca2330 86 if( bleWasntReady ) break; // Don't loop on not ready (Don't starve main loop.)
AntonLS 11:d3aa5fca2330 87
AntonLS 11:d3aa5fca2330 88 charsWritten = rx_len;
AntonLS 11:d3aa5fca2330 89
AntonLS 11:d3aa5fca2330 90 rx_len = 0;
AntonLS 11:d3aa5fca2330 91 break;
AntonLS 11:d3aa5fca2330 92 }
AntonLS 11:d3aa5fca2330 93 }
AntonLS 11:d3aa5fca2330 94
AntonLS 11:d3aa5fca2330 95 return charsWritten;
AntonLS 5:1b9734e68327 96 }
AntonLS 5:1b9734e68327 97
AntonLS 5:1b9734e68327 98 void PhoneAppIO::handleRead()
AntonLS 5:1b9734e68327 99 {
AntonLS 11:d3aa5fca2330 100 while( reading ); // Block.
AntonLS 11:d3aa5fca2330 101
AntonLS 11:d3aa5fca2330 102 int charsToBuf = rxBuffer.write( data, bytesRead );
AntonLS 5:1b9734e68327 103 if( charsToBuf != bytesRead )
AntonLS 5:1b9734e68327 104 {
AntonLS 11:d3aa5fca2330 105 ::printf( "[ERROR] ToPhoneCharacteristic Data Lost, tried %d, got %d\r\n", bytesRead, charsToBuf );
AntonLS 5:1b9734e68327 106 }
AntonLS 5:1b9734e68327 107 }
AntonLS 5:1b9734e68327 108
AntonLS 11:d3aa5fca2330 109 /** This method used to transfer data from the internal write buffer
AntonLS 11:d3aa5fca2330 110 * (txBuffer) to the physical interface, but we have an intermediate
AntonLS 11:d3aa5fca2330 111 * buffer (rx_buf) in case of failure, so it can be retried.
AntonLS 11:d3aa5fca2330 112 */
AntonLS 5:1b9734e68327 113 void PhoneAppIO::handleWrite()
AntonLS 5:1b9734e68327 114 {
AntonLS 11:d3aa5fca2330 115 bleWasntReady = updateCharacteristic( toPhoneHandle, rx_buf, rx_len ); // Notifies.
AntonLS 11:d3aa5fca2330 116 busy = bleWasntReady;
AntonLS 5:1b9734e68327 117 }
AntonLS 5:1b9734e68327 118
AntonLS 11:d3aa5fca2330 119 // I think we don't need to use these because I'm guessing
AntonLS 11:d3aa5fca2330 120 // all reads happen during main loop ble.waitForEvent()?
AntonLS 11:d3aa5fca2330 121
AntonLS 11:d3aa5fca2330 122 // For locking out read() during write() to prevent buffer state corruption.
AntonLS 11:d3aa5fca2330 123 void PhoneAppIO::disableTxIrq(){ writing = true; }
AntonLS 11:d3aa5fca2330 124 void PhoneAppIO::enableTxIrq() { writing = false; }
AntonLS 11:d3aa5fca2330 125
AntonLS 11:d3aa5fca2330 126 // For locking out write() during read() to prevent buffer state corruption.
AntonLS 11:d3aa5fca2330 127 void PhoneAppIO::disableRxIrq(){ reading = true; }
AntonLS 11:d3aa5fca2330 128 void PhoneAppIO::enableRxIrq() { reading = false; }
AntonLS 11:d3aa5fca2330 129
AntonLS 5:1b9734e68327 130 /* EOF */