Diff: io/MTSBufferedIO.cpp

Revision:

0:563b70517320

Child:

2:8d3ea0dfce39

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/io/MTSBufferedIO.cpp	Mon Dec 09 15:29:35 2013 +0000
@@ -0,0 +1,111 @@
+#ifndef MTSBUFFEREDIO_CPP
+#define MTSBUFFEREDIO_CPP
+
+#include "MTSBufferedIO.h"
+
+MTSBufferedIO::MTSBufferedIO(int txBufferSize, int rxBufferSize)
+{
+    txBuffer = new MTSCircularBuffer(txBufferSize);
+    rxBuffer = new MTSCircularBuffer(rxBufferSize);
+}
+
+MTSBufferedIO::~MTSBufferedIO()
+{
+    delete txBuffer;
+    delete rxBuffer;
+}
+
+int MTSBufferedIO::write(char* data, int length)
+{
+    int tmp = txBuffer->write(data, length);
+    handleWrite();
+    return tmp;
+}
+
+int MTSBufferedIO::write(char data)
+{
+    int tmp = txBuffer->write(data);
+    handleWrite();
+    return tmp;
+}
+
+int MTSBufferedIO::read(char* data, int length)
+{
+    return rxBuffer->read(data, length);
+}
+
+int MTSBufferedIO::read()
+{
+    return rxBuffer->read();
+}
+
+template<typename T>
+void MTSBufferedIO::attach(T *tptr, void(T::*mptr)(void), int threshold, Vars::RelationalOperator op, Serial::IrqType type)
+{
+    if (type == Serial::TxIrq) {
+        txBuffer->attach(tptr, mptr, threshold, op);
+    } else if (type == Serial::RxIrq) {
+        rxBuffer->attach(tptr, mptr, threshold, op);
+    }
+}
+
+void MTSBufferedIO::attach(void(*fptr)(void), int threshold, Vars::RelationalOperator op, Serial::IrqType type)
+{
+    if (type == Serial::TxIrq) {
+        txBuffer->attach(fptr, threshold, op);
+    } else if (type == Serial::RxIrq) {
+        rxBuffer->attach(fptr, threshold, op);
+    }
+}
+
+bool MTSBufferedIO::txEmpty()
+{
+    return txBuffer->isEmpty();
+}
+
+bool MTSBufferedIO::rxEmpty()
+{
+    return rxBuffer->isEmpty();
+}
+
+bool MTSBufferedIO::txFull()
+{
+    return txBuffer->isFull();
+}
+
+bool MTSBufferedIO::rxFull()
+{
+    return rxBuffer->isFull();
+}
+
+void MTSBufferedIO::txClear()
+{
+    txBuffer->clear();
+}
+
+void MTSBufferedIO::rxClear()
+{
+    rxBuffer->clear();
+}
+
+int MTSBufferedIO::txAvailable()
+{
+    return txBuffer->available();
+}
+
+int MTSBufferedIO::rxAvailable()
+{
+    return rxBuffer->available();
+}
+
+int MTSBufferedIO::txCapacity()
+{
+    return txBuffer->capacity();
+}
+
+int MTSBufferedIO::rxCapacity()
+{
+    return rxBuffer->capacity();
+}
+
+#endif /* MTSBUFFEREDSERIAL_CPP */
\ No newline at end of file