ON Semiconductor / mbed-os

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.

Dependents:   mbed-TFT-example-NCS36510 mbed-Accelerometer-example-NCS36510 mbed-Accelerometer-example-NCS36510

features/unsupported/USBHost/USBHostSerial/MtxCircBuffer.h@0:098463de4c5d, 2017-01-25 (annotated)

Committer:
group-onsemi
Date:
Wed Jan 25 20:34:15 2017 +0000
Revision:
0:098463de4c5d
Initial commit

Who changed what in which revision?

UserRevisionLine numberNew contents of line
group-onsemi 0:098463de4c5d 1 /* mbed USBHost Library
group-onsemi 0:098463de4c5d 2 * Copyright (c) 2006-2013 ARM Limited
group-onsemi 0:098463de4c5d 3 *
group-onsemi 0:098463de4c5d 4 * Licensed under the Apache License, Version 2.0 (the "License");
group-onsemi 0:098463de4c5d 5 * you may not use this file except in compliance with the License.
group-onsemi 0:098463de4c5d 6 * You may obtain a copy of the License at
group-onsemi 0:098463de4c5d 7 *
group-onsemi 0:098463de4c5d 8 * http://www.apache.org/licenses/LICENSE-2.0
group-onsemi 0:098463de4c5d 9 *
group-onsemi 0:098463de4c5d 10 * Unless required by applicable law or agreed to in writing, software
group-onsemi 0:098463de4c5d 11 * distributed under the License is distributed on an "AS IS" BASIS,
group-onsemi 0:098463de4c5d 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
group-onsemi 0:098463de4c5d 13 * See the License for the specific language governing permissions and
group-onsemi 0:098463de4c5d 14 * limitations under the License.
group-onsemi 0:098463de4c5d 15 */
group-onsemi 0:098463de4c5d 16
group-onsemi 0:098463de4c5d 17 #ifndef MTXCIRCBUFFER_H
group-onsemi 0:098463de4c5d 18 #define MTXCIRCBUFFER_H
group-onsemi 0:098463de4c5d 19
group-onsemi 0:098463de4c5d 20 #include "stdint.h"
group-onsemi 0:098463de4c5d 21 #include "rtos.h"
group-onsemi 0:098463de4c5d 22
group-onsemi 0:098463de4c5d 23 //Mutex protected circular buffer
group-onsemi 0:098463de4c5d 24 template<typename T, int size>
group-onsemi 0:098463de4c5d 25 class MtxCircBuffer {
group-onsemi 0:098463de4c5d 26 public:
group-onsemi 0:098463de4c5d 27
group-onsemi 0:098463de4c5d 28 MtxCircBuffer() {
group-onsemi 0:098463de4c5d 29 write = 0;
group-onsemi 0:098463de4c5d 30 read = 0;
group-onsemi 0:098463de4c5d 31 }
group-onsemi 0:098463de4c5d 32
group-onsemi 0:098463de4c5d 33 bool isFull() {
group-onsemi 0:098463de4c5d 34 mtx.lock();
group-onsemi 0:098463de4c5d 35 bool r = (((write + 1) % size) == read);
group-onsemi 0:098463de4c5d 36 mtx.unlock();
group-onsemi 0:098463de4c5d 37 return r;
group-onsemi 0:098463de4c5d 38 }
group-onsemi 0:098463de4c5d 39
group-onsemi 0:098463de4c5d 40 bool isEmpty() {
group-onsemi 0:098463de4c5d 41 mtx.lock();
group-onsemi 0:098463de4c5d 42 bool r = (read == write);
group-onsemi 0:098463de4c5d 43 mtx.unlock();
group-onsemi 0:098463de4c5d 44 return r;
group-onsemi 0:098463de4c5d 45 }
group-onsemi 0:098463de4c5d 46
group-onsemi 0:098463de4c5d 47 void flush() {
group-onsemi 0:098463de4c5d 48 write = 0;
group-onsemi 0:098463de4c5d 49 read = 0;
group-onsemi 0:098463de4c5d 50 }
group-onsemi 0:098463de4c5d 51
group-onsemi 0:098463de4c5d 52 void queue(T k) {
group-onsemi 0:098463de4c5d 53 mtx.lock();
group-onsemi 0:098463de4c5d 54 while (((write + 1) % size) == read) {
group-onsemi 0:098463de4c5d 55 mtx.unlock();
group-onsemi 0:098463de4c5d 56 Thread::wait(10);
group-onsemi 0:098463de4c5d 57 mtx.lock();
group-onsemi 0:098463de4c5d 58 }
group-onsemi 0:098463de4c5d 59 buf[write++] = k;
group-onsemi 0:098463de4c5d 60 write %= size;
group-onsemi 0:098463de4c5d 61 mtx.unlock();
group-onsemi 0:098463de4c5d 62 }
group-onsemi 0:098463de4c5d 63
group-onsemi 0:098463de4c5d 64 uint16_t available() {
group-onsemi 0:098463de4c5d 65 mtx.lock();
group-onsemi 0:098463de4c5d 66 uint16_t a = (write >= read) ? (write - read) : (size - read + write);
group-onsemi 0:098463de4c5d 67 mtx.unlock();
group-onsemi 0:098463de4c5d 68 return a;
group-onsemi 0:098463de4c5d 69 }
group-onsemi 0:098463de4c5d 70
group-onsemi 0:098463de4c5d 71 bool dequeue(T * c) {
group-onsemi 0:098463de4c5d 72 mtx.lock();
group-onsemi 0:098463de4c5d 73 bool empty = (read == write);
group-onsemi 0:098463de4c5d 74 if (!empty) {
group-onsemi 0:098463de4c5d 75 *c = buf[read++];
group-onsemi 0:098463de4c5d 76 read %= size;
group-onsemi 0:098463de4c5d 77 }
group-onsemi 0:098463de4c5d 78 mtx.unlock();
group-onsemi 0:098463de4c5d 79 return (!empty);
group-onsemi 0:098463de4c5d 80 }
group-onsemi 0:098463de4c5d 81
group-onsemi 0:098463de4c5d 82 private:
group-onsemi 0:098463de4c5d 83 volatile uint16_t write;
group-onsemi 0:098463de4c5d 84 volatile uint16_t read;
group-onsemi 0:098463de4c5d 85 volatile T buf[size];
group-onsemi 0:098463de4c5d 86 Mutex mtx;
group-onsemi 0:098463de4c5d 87 };
group-onsemi 0:098463de4c5d 88
group-onsemi 0:098463de4c5d 89 #endif