File content as of revision 0:563b70517320:

#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 */