Leon Wehmeier / Mbed OS fiasco_max32630

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:   SoftSerial MAX14690 Buffer

Fork of rtos_threading_with_callback by mbed_example

BufferedSerial/BufferedSerial.cpp@3:d7ec6dc025b0, 2018-03-30 (annotated)

Committer:
lwehmeier
Date:
Fri Mar 30 10:32:10 2018 +0000
Revision:
3:d7ec6dc025b0
implemented basic GPS read support, freed serial connection for uart jpg camera module

Who changed what in which revision?

UserRevisionLine numberNew contents of line
lwehmeier 3:d7ec6dc025b0 1 /**
lwehmeier 3:d7ec6dc025b0 2 * @file BufferedSerial.cpp
lwehmeier 3:d7ec6dc025b0 3 * @brief Software Buffer - Extends mbed Serial functionallity adding irq driven TX and RX
lwehmeier 3:d7ec6dc025b0 4 * @author sam grove
lwehmeier 3:d7ec6dc025b0 5 * @version 1.0
lwehmeier 3:d7ec6dc025b0 6 * @see
lwehmeier 3:d7ec6dc025b0 7 *
lwehmeier 3:d7ec6dc025b0 8 * Copyright (c) 2013
lwehmeier 3:d7ec6dc025b0 9 *
lwehmeier 3:d7ec6dc025b0 10 * Licensed under the Apache License, Version 2.0 (the "License");
lwehmeier 3:d7ec6dc025b0 11 * you may not use this file except in compliance with the License.
lwehmeier 3:d7ec6dc025b0 12 * You may obtain a copy of the License at
lwehmeier 3:d7ec6dc025b0 13 *
lwehmeier 3:d7ec6dc025b0 14 * http://www.apache.org/licenses/LICENSE-2.0
lwehmeier 3:d7ec6dc025b0 15 *
lwehmeier 3:d7ec6dc025b0 16 * Unless required by applicable law or agreed to in writing, software
lwehmeier 3:d7ec6dc025b0 17 * distributed under the License is distributed on an "AS IS" BASIS,
lwehmeier 3:d7ec6dc025b0 18 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
lwehmeier 3:d7ec6dc025b0 19 * See the License for the specific language governing permissions and
lwehmeier 3:d7ec6dc025b0 20 * limitations under the License.
lwehmeier 3:d7ec6dc025b0 21 */
lwehmeier 3:d7ec6dc025b0 22
lwehmeier 3:d7ec6dc025b0 23 #include "BufferedSerial.h"
lwehmeier 3:d7ec6dc025b0 24 #include <stdarg.h>
lwehmeier 3:d7ec6dc025b0 25
lwehmeier 3:d7ec6dc025b0 26 BufferedSerial::BufferedSerial(PinName tx, PinName rx, uint32_t buf_size, uint32_t tx_multiple, const char* name)
lwehmeier 3:d7ec6dc025b0 27 : RawSerial(tx, rx) , _rxbuf(buf_size), _txbuf((uint32_t)(tx_multiple*buf_size))
lwehmeier 3:d7ec6dc025b0 28 {
lwehmeier 3:d7ec6dc025b0 29 //attach(this, &BufferedSerial::rxIrq, Serial::RxIrq);
lwehmeier 3:d7ec6dc025b0 30 this->_buf_size = buf_size;
lwehmeier 3:d7ec6dc025b0 31 this->_tx_multiple = tx_multiple;
lwehmeier 3:d7ec6dc025b0 32 return;
lwehmeier 3:d7ec6dc025b0 33 }
lwehmeier 3:d7ec6dc025b0 34
lwehmeier 3:d7ec6dc025b0 35 BufferedSerial::~BufferedSerial(void)
lwehmeier 3:d7ec6dc025b0 36 {
lwehmeier 3:d7ec6dc025b0 37 //printf("destructor buffered serial\r\n");
lwehmeier 3:d7ec6dc025b0 38 RawSerial::attach(NULL, RawSerial::RxIrq);
lwehmeier 3:d7ec6dc025b0 39 RawSerial::attach(NULL, RawSerial::TxIrq);
lwehmeier 3:d7ec6dc025b0 40
lwehmeier 3:d7ec6dc025b0 41 return;
lwehmeier 3:d7ec6dc025b0 42 }
lwehmeier 3:d7ec6dc025b0 43
lwehmeier 3:d7ec6dc025b0 44 int BufferedSerial::readable(void)
lwehmeier 3:d7ec6dc025b0 45 {
lwehmeier 3:d7ec6dc025b0 46 return _rxbuf.available(); // note: look if things are in the buffer
lwehmeier 3:d7ec6dc025b0 47 }
lwehmeier 3:d7ec6dc025b0 48
lwehmeier 3:d7ec6dc025b0 49 int BufferedSerial::writeable(void)
lwehmeier 3:d7ec6dc025b0 50 {
lwehmeier 3:d7ec6dc025b0 51 return 1; // buffer allows overwriting by design, always true
lwehmeier 3:d7ec6dc025b0 52 }
lwehmeier 3:d7ec6dc025b0 53
lwehmeier 3:d7ec6dc025b0 54 int BufferedSerial::getc(void)
lwehmeier 3:d7ec6dc025b0 55 {
lwehmeier 3:d7ec6dc025b0 56 return _rxbuf;
lwehmeier 3:d7ec6dc025b0 57 }
lwehmeier 3:d7ec6dc025b0 58
lwehmeier 3:d7ec6dc025b0 59 int BufferedSerial::putc(int c)
lwehmeier 3:d7ec6dc025b0 60 {
lwehmeier 3:d7ec6dc025b0 61 _txbuf = (char)c;
lwehmeier 3:d7ec6dc025b0 62 BufferedSerial::prime();
lwehmeier 3:d7ec6dc025b0 63
lwehmeier 3:d7ec6dc025b0 64 return c;
lwehmeier 3:d7ec6dc025b0 65 }
lwehmeier 3:d7ec6dc025b0 66
lwehmeier 3:d7ec6dc025b0 67 int BufferedSerial::puts(const char *s)
lwehmeier 3:d7ec6dc025b0 68 {
lwehmeier 3:d7ec6dc025b0 69 if (s != NULL) {
lwehmeier 3:d7ec6dc025b0 70 const char* ptr = s;
lwehmeier 3:d7ec6dc025b0 71
lwehmeier 3:d7ec6dc025b0 72 while(*(ptr) != 0) {
lwehmeier 3:d7ec6dc025b0 73 _txbuf = *(ptr++);
lwehmeier 3:d7ec6dc025b0 74 }
lwehmeier 3:d7ec6dc025b0 75 _txbuf = '\n'; // done per puts definition
lwehmeier 3:d7ec6dc025b0 76 BufferedSerial::prime();
lwehmeier 3:d7ec6dc025b0 77
lwehmeier 3:d7ec6dc025b0 78 return (ptr - s) + 1;
lwehmeier 3:d7ec6dc025b0 79 }
lwehmeier 3:d7ec6dc025b0 80 return 0;
lwehmeier 3:d7ec6dc025b0 81 }
lwehmeier 3:d7ec6dc025b0 82
lwehmeier 3:d7ec6dc025b0 83 int BufferedSerial::printf(const char* format, ...)
lwehmeier 3:d7ec6dc025b0 84 {
lwehmeier 3:d7ec6dc025b0 85 char buffer[this->_buf_size];
lwehmeier 3:d7ec6dc025b0 86 memset(buffer,0,this->_buf_size);
lwehmeier 3:d7ec6dc025b0 87 int r = 0;
lwehmeier 3:d7ec6dc025b0 88
lwehmeier 3:d7ec6dc025b0 89 va_list arg;
lwehmeier 3:d7ec6dc025b0 90 va_start(arg, format);
lwehmeier 3:d7ec6dc025b0 91 r = vsprintf(buffer, format, arg);
lwehmeier 3:d7ec6dc025b0 92 // this may not hit the heap but should alert the user anyways
lwehmeier 3:d7ec6dc025b0 93 if(r > this->_buf_size) {
lwehmeier 3:d7ec6dc025b0 94 error("%s %d buffer overwrite (max_buf_size: %d exceeded: %d)!\r\n", __FILE__, __LINE__,this->_buf_size,r);
lwehmeier 3:d7ec6dc025b0 95 va_end(arg);
lwehmeier 3:d7ec6dc025b0 96 return 0;
lwehmeier 3:d7ec6dc025b0 97 }
lwehmeier 3:d7ec6dc025b0 98 va_end(arg);
lwehmeier 3:d7ec6dc025b0 99 r = BufferedSerial::write(buffer, r);
lwehmeier 3:d7ec6dc025b0 100
lwehmeier 3:d7ec6dc025b0 101 return r;
lwehmeier 3:d7ec6dc025b0 102 }
lwehmeier 3:d7ec6dc025b0 103
lwehmeier 3:d7ec6dc025b0 104 ssize_t BufferedSerial::write(const void *s, size_t length)
lwehmeier 3:d7ec6dc025b0 105 {
lwehmeier 3:d7ec6dc025b0 106 if (s != NULL && length > 0) {
lwehmeier 3:d7ec6dc025b0 107 const char* ptr = (const char*)s;
lwehmeier 3:d7ec6dc025b0 108 const char* end = ptr + length;
lwehmeier 3:d7ec6dc025b0 109
lwehmeier 3:d7ec6dc025b0 110 while (ptr != end) {
lwehmeier 3:d7ec6dc025b0 111 _txbuf = *(ptr++);
lwehmeier 3:d7ec6dc025b0 112 }
lwehmeier 3:d7ec6dc025b0 113 BufferedSerial::prime();
lwehmeier 3:d7ec6dc025b0 114
lwehmeier 3:d7ec6dc025b0 115 return ptr - (const char*)s;
lwehmeier 3:d7ec6dc025b0 116 }
lwehmeier 3:d7ec6dc025b0 117 return 0;
lwehmeier 3:d7ec6dc025b0 118 }
lwehmeier 3:d7ec6dc025b0 119
lwehmeier 3:d7ec6dc025b0 120
lwehmeier 3:d7ec6dc025b0 121 void BufferedSerial::rxIrq(void)
lwehmeier 3:d7ec6dc025b0 122 {
lwehmeier 3:d7ec6dc025b0 123 //printf("rx\r\n");
lwehmeier 3:d7ec6dc025b0 124 // read from the peripheral and make sure something is available
lwehmeier 3:d7ec6dc025b0 125 if(serial_readable(&_serial)) {
lwehmeier 3:d7ec6dc025b0 126 _rxbuf = serial_getc(&_serial); // if so load them into a buffer
lwehmeier 3:d7ec6dc025b0 127 }
lwehmeier 3:d7ec6dc025b0 128
lwehmeier 3:d7ec6dc025b0 129 return;
lwehmeier 3:d7ec6dc025b0 130 }
lwehmeier 3:d7ec6dc025b0 131
lwehmeier 3:d7ec6dc025b0 132 void BufferedSerial::txIrq(void)
lwehmeier 3:d7ec6dc025b0 133 {
lwehmeier 3:d7ec6dc025b0 134 // see if there is room in the hardware fifo and if something is in the software fifo
lwehmeier 3:d7ec6dc025b0 135 while(serial_writable(&_serial)) {
lwehmeier 3:d7ec6dc025b0 136 if(_txbuf.available()) {
lwehmeier 3:d7ec6dc025b0 137 serial_putc(&_serial, (int)_txbuf.get());
lwehmeier 3:d7ec6dc025b0 138 } else {
lwehmeier 3:d7ec6dc025b0 139 // disable the TX interrupt when there is nothing left to send
lwehmeier 3:d7ec6dc025b0 140 RawSerial::attach(NULL, RawSerial::TxIrq);
lwehmeier 3:d7ec6dc025b0 141 break;
lwehmeier 3:d7ec6dc025b0 142 }
lwehmeier 3:d7ec6dc025b0 143 }
lwehmeier 3:d7ec6dc025b0 144
lwehmeier 3:d7ec6dc025b0 145 return;
lwehmeier 3:d7ec6dc025b0 146 }
lwehmeier 3:d7ec6dc025b0 147
lwehmeier 3:d7ec6dc025b0 148 void BufferedSerial::prime(void)
lwehmeier 3:d7ec6dc025b0 149 {
lwehmeier 3:d7ec6dc025b0 150 //printf("prime\r\n");
lwehmeier 3:d7ec6dc025b0 151 // if already busy then the irq will pick this up
lwehmeier 3:d7ec6dc025b0 152 if(serial_writable(&_serial)) {
lwehmeier 3:d7ec6dc025b0 153 RawSerial::attach(NULL, RawSerial::TxIrq); // make sure not to cause contention in the irq
lwehmeier 3:d7ec6dc025b0 154 BufferedSerial::txIrq(); // only write to hardware in one place
lwehmeier 3:d7ec6dc025b0 155 RawSerial::attach(this, &BufferedSerial::txIrq, RawSerial::TxIrq);
lwehmeier 3:d7ec6dc025b0 156 }
lwehmeier 3:d7ec6dc025b0 157
lwehmeier 3:d7ec6dc025b0 158 return;
lwehmeier 3:d7ec6dc025b0 159 }
lwehmeier 3:d7ec6dc025b0 160
lwehmeier 3:d7ec6dc025b0 161