Multi-Hackers / SocketModem

A library for talking to Multi-Tech's Cellular SocketModem Devices.

Dependents:   M2X_dev axeda_wrapper_dev MTS_M2x_Example1 MTS_Cellular_Connect_Example ... more

io/MTSSerialFlowControl.cpp@142:3b40320f3f73, 2014-01-04 (annotated)

Committer:
sam_grove
Date:
Sat Jan 04 21:09:13 2014 +0000
Revision:
142:3b40320f3f73
Parent:
141:571e0ef6c8dc
Child:
144:52cb5b6667cc
Hack serial comm error to keep alive

Who changed what in which revision?

UserRevisionLine numberNew contents of line
kranjan 141:571e0ef6c8dc 1 /* Universal Socket Modem Interface Library
kranjan 141:571e0ef6c8dc 2 * Copyright (c) 2013 Multi-Tech Systems
kranjan 141:571e0ef6c8dc 3 *
kranjan 141:571e0ef6c8dc 4 * Licensed under the Apache License, Version 2.0 (the "License");
kranjan 141:571e0ef6c8dc 5 * you may not use this file except in compliance with the License.
kranjan 141:571e0ef6c8dc 6 * You may obtain a copy of the License at
kranjan 141:571e0ef6c8dc 7 *
kranjan 141:571e0ef6c8dc 8 * http://www.apache.org/licenses/LICENSE-2.0
kranjan 141:571e0ef6c8dc 9 *
kranjan 141:571e0ef6c8dc 10 * Unless required by applicable law or agreed to in writing, software
kranjan 141:571e0ef6c8dc 11 * distributed under the License is distributed on an "AS IS" BASIS,
kranjan 141:571e0ef6c8dc 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
kranjan 141:571e0ef6c8dc 13 * See the License for the specific language governing permissions and
kranjan 141:571e0ef6c8dc 14 * limitations under the License.
kranjan 141:571e0ef6c8dc 15 */
kranjan 141:571e0ef6c8dc 16
jengbrecht 0:563b70517320 17 #include "MTSSerialFlowControl.h"
jengbrecht 0:563b70517320 18
mfiore 39:6e94520a3217 19 using namespace mts;
mfiore 39:6e94520a3217 20
jengbrecht 140:bf0c8288eb78 21 MTSSerialFlowControl::MTSSerialFlowControl(PinName TXD, PinName RXD, PinName RTS, PinName CTS, int txBufSize, int rxBufSize)
jengbrecht 140:bf0c8288eb78 22 : MTSSerial(TXD, RXD, txBufSize, rxBufSize)
jengbrecht 140:bf0c8288eb78 23 , rxReadyFlag(false)
jengbrecht 140:bf0c8288eb78 24 , rts(RTS)
jengbrecht 140:bf0c8288eb78 25 , cts(CTS)
jengbrecht 0:563b70517320 26 {
mfiore 10:2bd727a4b329 27 notifyStartSending();
jengbrecht 45:40745c2036cf 28
sgodinez 84:77c5ab16534d 29 highThreshold = MAX(rxBufSize - 10, rxBufSize * 0.85);
mfiore 2:8d3ea0dfce39 30 lowThreshold = rxBufSize * 0.3;
jengbrecht 45:40745c2036cf 31
sgodinez 86:186bbf974c7c 32 rxBuffer.attach(this, &MTSSerialFlowControl::notifyStartSending, lowThreshold, Vars::LESS);
mfiore 2:8d3ea0dfce39 33 }
mfiore 2:8d3ea0dfce39 34
jengbrecht 45:40745c2036cf 35 MTSSerialFlowControl::~MTSSerialFlowControl()
jengbrecht 45:40745c2036cf 36 {
mfiore 2:8d3ea0dfce39 37
jengbrecht 45:40745c2036cf 38 }
jengbrecht 45:40745c2036cf 39
jengbrecht 140:bf0c8288eb78 40 void MTSSerialFlowControl::rxClear()
jengbrecht 140:bf0c8288eb78 41 {
sgodinez 101:27bb34e23304 42 MTSBufferedIO::rxClear();
jengbrecht 140:bf0c8288eb78 43 notifyStartSending();
sgodinez 101:27bb34e23304 44 }
sgodinez 101:27bb34e23304 45
jengbrecht 45:40745c2036cf 46 void MTSSerialFlowControl::notifyStartSending()
jengbrecht 45:40745c2036cf 47 {
sgodinez 101:27bb34e23304 48 if(!rxReadyFlag) {
sgodinez 101:27bb34e23304 49 rts.write(0);
sgodinez 101:27bb34e23304 50 rxReadyFlag = true;
sgodinez 110:8f3149c99112 51 //printf("RTS LOW: READY - RX[%d/%d]\r\n", rxBuffer.size(), rxBuffer.capacity());
sgodinez 101:27bb34e23304 52 }
mfiore 2:8d3ea0dfce39 53 }
mfiore 2:8d3ea0dfce39 54
jengbrecht 45:40745c2036cf 55 void MTSSerialFlowControl::notifyStopSending()
jengbrecht 45:40745c2036cf 56 {
sgodinez 101:27bb34e23304 57 if(rxReadyFlag) {
sgodinez 101:27bb34e23304 58 rts.write(1);
sgodinez 101:27bb34e23304 59 rxReadyFlag = false;
sgodinez 110:8f3149c99112 60 //printf("RTS HIGH: NOT-READY - RX[%d/%d]\r\n", rxBuffer.size(), rxBuffer.capacity());
sgodinez 101:27bb34e23304 61 }
mfiore 2:8d3ea0dfce39 62 }
mfiore 2:8d3ea0dfce39 63
jengbrecht 45:40745c2036cf 64 void MTSSerialFlowControl::handleRead()
jengbrecht 45:40745c2036cf 65 {
sgodinez 86:186bbf974c7c 66 while (serial.readable()) {
sgodinez 96:27bdf4aa3a31 67 char byte = serial.getc();
sgodinez 96:27bdf4aa3a31 68 if(rxBuffer.write(byte) != 1) {
sgodinez 110:8f3149c99112 69 rts.write(1);
sgodinez 110:8f3149c99112 70 rxReadyFlag = false;
sgodinez 101:27bb34e23304 71 printf("[ERROR] Serial Rx Byte Dropped [%c][0x%02X]\r\n", byte, byte);
jengbrecht 140:bf0c8288eb78 72 if(byte == 0xFF) {
sam_grove 142:3b40320f3f73 73 // hack so we dont hang - fix later
sam_grove 142:3b40320f3f73 74 puts("[ERR] Comm errors, must reboot");
sam_grove 142:3b40320f3f73 75 fflush(stdout);
sam_grove 142:3b40320f3f73 76 NVIC_SystemReset();
jengbrecht 140:bf0c8288eb78 77 }
sgodinez 110:8f3149c99112 78 return;
sgodinez 96:27bdf4aa3a31 79 }
sgodinez 86:186bbf974c7c 80 if (rxBuffer.size() > highThreshold) {
jengbrecht 77:d7b14688a704 81 notifyStopSending();
jengbrecht 77:d7b14688a704 82 }
mfiore 2:8d3ea0dfce39 83 }
mfiore 2:8d3ea0dfce39 84 }
mfiore 2:8d3ea0dfce39 85
jengbrecht 45:40745c2036cf 86 void MTSSerialFlowControl::handleWrite()
jengbrecht 45:40745c2036cf 87 {
sgodinez 86:186bbf974c7c 88 while(txBuffer.size() != 0) {
sgodinez 86:186bbf974c7c 89 if (serial.writeable() && cts.read() == 0) {
jengbrecht 77:d7b14688a704 90 char byte;
sgodinez 86:186bbf974c7c 91 if(txBuffer.read(byte) == 1) {
sgodinez 86:186bbf974c7c 92 serial.putc(byte);
mfiore 2:8d3ea0dfce39 93 }
jengbrecht 77:d7b14688a704 94 } else {
jengbrecht 77:d7b14688a704 95 return;
mfiore 2:8d3ea0dfce39 96 }
mfiore 2:8d3ea0dfce39 97 }
mfiore 2:8d3ea0dfce39 98 }
kranjan 141:571e0ef6c8dc 99