TransportStub.cpp

Go to the documentation of this file.

/*

Copyright (C) 2006-2007 by Peter Dimov.

This file is part of Calitko (http://www.calitko.org).

Calitko is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.

Calitko is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with Calitko; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA

*/

#include "Qt.h"
#include "TransportStub.h"
#include "Imports.cpp"

TransportStub::TransportStub()
 :  readBuffer(), writeBuffer(), status (0)
{
}

void TransportStub::connectToNode (const Uri &)
{
}

void TransportStub::disconnectFromNode()
{
}

void TransportStub::abort()
{
}

bool TransportStub::canRead (int count) const
{
    return readBuffer.length() >= count;
}

QByteArray TransportStub::peek (int count) const
{
    QByteArray bytes = readBuffer.left (count);
    return bytes;
}

QByteArray TransportStub::peekAtMost (int count) const
{
    // left() will not return more bytes than already available:
    QByteArray bytes = readBuffer.left (count);
    return bytes;
}

QByteArray TransportStub::peekTo (const QByteArray &delimiter) const
{
    QByteArray bytes = readBuffer.left (readBuffer.indexOf (delimiter)
                                        + delimiter.length());
    return bytes;
}

QByteArray TransportStub::peekAll() const
{
    QByteArray bytes = readBuffer;
    return bytes;
}

QByteArray TransportStub::read (int count)
{
    QByteArray bytes = peek (count);
    readBuffer = readBuffer.mid (bytes.length());
    return bytes;
}

QByteArray TransportStub::readAtMost (int count)
{
    QByteArray bytes = peekAtMost (count);
    readBuffer = readBuffer.mid (bytes.length());
    return bytes;
}

QByteArray TransportStub::readTo (const QByteArray &delimiter)
{
    QByteArray bytes = peekTo (delimiter);
    readBuffer = readBuffer.mid (bytes.length());
    return bytes;
}

QByteArray TransportStub::readAll()
{
    QByteArray bytes = peekAll();
    readBuffer = QByteArray();
    return bytes;
}

bool TransportStub::canWrite (int count) const
{
    return writeBuffer.capacity() - writeBuffer.size() >= count;
}

bool TransportStub::write (const QByteArray &bytes, bool)
{
    writeBuffer += bytes;
    return true;
}

// NodeAddress TransportStub::ownNodeAddress() const
// {
//  return NodeAddress(); // \todo
// }
//
// NodeAddress TransportStub::remoteNodeAddress() const
// {
//  return NodeAddress(); // \todo
// }

void TransportStub::setTransportStatus (TransportStatus *s)
{
    status = s;
}

TransportStub::operator Transport *()
{
    return this;
}

Copyright © 2006 Peter Dimov.
Powered by Doxygen.