mbed official / SprintUSBModem

USB Host Library for Sprint Dongles

Dependencies:   Socket USBHostWANDongleSprint lwip-sys lwip

Dependents:   SprintUSBModemWebsocketTest SprintUSBModemHTTPClientTest SprintUSBModemNTPClientTest SprintUSBModemSMSTest ... more

Fork of SprintUSBModem_bleedingedge by Donatien Garnier

core/MtxCircBuffer.h@14:f6f17843e5ef, 2012-12-10 (annotated)

Committer:
donatien
Date:
Mon Dec 10 18:23:49 2012 +0000
Revision:
14:f6f17843e5ef
Parent:
0:8f57713b2147 
Separate USB/Sprint dev flows, fix regression in mbed rev. 41+ lib

Who changed what in which revision?

UserRevisionLine numberNew contents of line
donatien 0:8f57713b2147 1 /* MtxCircBuf.h */
donatien 0:8f57713b2147 2 /* Copyright (C) 2012 mbed.org, MIT License
donatien 0:8f57713b2147 3 *
donatien 0:8f57713b2147 4 * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
donatien 0:8f57713b2147 5 * and associated documentation files (the "Software"), to deal in the Software without restriction,
donatien 0:8f57713b2147 6 * including without limitation the rights to use, copy, modify, merge, publish, distribute,
donatien 0:8f57713b2147 7 * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
donatien 0:8f57713b2147 8 * furnished to do so, subject to the following conditions:
donatien 0:8f57713b2147 9 *
donatien 0:8f57713b2147 10 * The above copyright notice and this permission notice shall be included in all copies or
donatien 0:8f57713b2147 11 * substantial portions of the Software.
donatien 0:8f57713b2147 12 *
donatien 0:8f57713b2147 13 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
donatien 0:8f57713b2147 14 * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
donatien 0:8f57713b2147 15 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
donatien 0:8f57713b2147 16 * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
donatien 0:8f57713b2147 17 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
donatien 0:8f57713b2147 18 */
donatien 0:8f57713b2147 19
donatien 0:8f57713b2147 20 #ifndef MTXCIRCBUFFER_H
donatien 0:8f57713b2147 21 #define MTXCIRCBUFFER_H
donatien 0:8f57713b2147 22
donatien 0:8f57713b2147 23 #include "fwk.h"
donatien 0:8f57713b2147 24
donatien 0:8f57713b2147 25 #include "rtos.h"
donatien 0:8f57713b2147 26
donatien 0:8f57713b2147 27 //Mutex protected circualr buffer
donatien 0:8f57713b2147 28 template<typename T, int size>
donatien 0:8f57713b2147 29 class MtxCircBuffer
donatien 0:8f57713b2147 30 {
donatien 0:8f57713b2147 31 public:
donatien 0:8f57713b2147 32 MtxCircBuffer() //:
donatien 0:8f57713b2147 33 //mtx()
donatien 0:8f57713b2147 34 {
donatien 0:8f57713b2147 35 write = 0;
donatien 0:8f57713b2147 36 read = 0;
donatien 0:8f57713b2147 37 }
donatien 0:8f57713b2147 38
donatien 0:8f57713b2147 39 bool isFull()
donatien 0:8f57713b2147 40 {
donatien 0:8f57713b2147 41 mtx.lock();
donatien 0:8f57713b2147 42 bool r = (((write + 1) % size) == read);
donatien 0:8f57713b2147 43 mtx.unlock();
donatien 0:8f57713b2147 44 return r;
donatien 0:8f57713b2147 45 }
donatien 0:8f57713b2147 46
donatien 0:8f57713b2147 47 bool isEmpty()
donatien 0:8f57713b2147 48 {
donatien 0:8f57713b2147 49 mtx.lock();
donatien 0:8f57713b2147 50 bool r = (read == write);
donatien 0:8f57713b2147 51 mtx.unlock();
donatien 0:8f57713b2147 52 return r;
donatien 0:8f57713b2147 53 }
donatien 0:8f57713b2147 54
donatien 0:8f57713b2147 55 void queue(T k)
donatien 0:8f57713b2147 56 {
donatien 0:8f57713b2147 57 mtx.lock();
donatien 0:8f57713b2147 58 while (((write + 1) % size) == read) //if (isFull())
donatien 0:8f57713b2147 59 {
donatien 0:8f57713b2147 60 /*while((((write + 1) % size) == read))
donatien 0:8f57713b2147 61 {*/
donatien 0:8f57713b2147 62 mtx.unlock();
donatien 0:8f57713b2147 63 Thread::wait(10);
donatien 0:8f57713b2147 64 mtx.lock();
donatien 0:8f57713b2147 65 /*}*/
donatien 0:8f57713b2147 66 //read++;
donatien 0:8f57713b2147 67 //read %= size;
donatien 0:8f57713b2147 68 }
donatien 0:8f57713b2147 69 buf[write++] = k;
donatien 0:8f57713b2147 70 write %= size;
donatien 0:8f57713b2147 71 mtx.unlock();
donatien 0:8f57713b2147 72 }
donatien 0:8f57713b2147 73
donatien 0:8f57713b2147 74 uint16_t available()
donatien 0:8f57713b2147 75 {
donatien 0:8f57713b2147 76 mtx.lock();
donatien 0:8f57713b2147 77 uint16_t a = (write >= read) ? (write - read) : (size - read + write);
donatien 0:8f57713b2147 78 mtx.unlock();
donatien 0:8f57713b2147 79 return a;
donatien 0:8f57713b2147 80 }
donatien 0:8f57713b2147 81
donatien 0:8f57713b2147 82 bool dequeue(T * c)
donatien 0:8f57713b2147 83 {
donatien 0:8f57713b2147 84 mtx.lock();
donatien 0:8f57713b2147 85 bool empty = (read == write);
donatien 0:8f57713b2147 86 if (!empty)
donatien 0:8f57713b2147 87 {
donatien 0:8f57713b2147 88 *c = buf[read++];
donatien 0:8f57713b2147 89 read %= size;
donatien 0:8f57713b2147 90 }
donatien 0:8f57713b2147 91 mtx.unlock();
donatien 0:8f57713b2147 92 return (!empty);
donatien 0:8f57713b2147 93 }
donatien 0:8f57713b2147 94
donatien 0:8f57713b2147 95 private:
donatien 0:8f57713b2147 96 volatile uint16_t write;
donatien 0:8f57713b2147 97 volatile uint16_t read;
donatien 0:8f57713b2147 98 volatile T buf[size];
donatien 0:8f57713b2147 99 Mutex mtx;
donatien 0:8f57713b2147 100 };
donatien 0:8f57713b2147 101
donatien 0:8f57713b2147 102 #endif
donatien 0:8f57713b2147 103