• Skip to content
• Skip to link menu

KDE 4.0 API Reference

• KDE API Reference
• kdenetwork

• Sitemap
• Contact Us

 

kopete/protocols/messenger/libpapillon

bytestream.cpp

Go to the documentation of this file.

/*
 * bytestream.cpp - base class for bytestreams
 * Copyright (C) 2003  Justin Karneges
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library 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
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
 *
 */

#include "Papillon/Base/ByteStream"

// CS_NAMESPACE_BEGIN


namespace Papillon
{

class ByteStream::Private
{
public:
    Private() {}

    QByteArray readBuf, writeBuf;
};

ByteStream::ByteStream(QObject *parent)
:QObject(parent)
{
    d = new Private;
}

ByteStream::~ByteStream()
{
    delete d;
}

bool ByteStream::isOpen() const
{
    return false;
}

void ByteStream::close()
{
}

void ByteStream::write(const QByteArray &a)
{
    if(!isOpen())
        return;

    bool doWrite = bytesToWrite() == 0 ? true: false;
    appendWrite(a);
    if(doWrite)
        tryWrite();
}

QByteArray ByteStream::read(int bytes)
{
    return takeRead(bytes);
}

int ByteStream::bytesAvailable() const
{
    return d->readBuf.size();
}

int ByteStream::bytesToWrite() const
{
    return d->writeBuf.size();
}

void ByteStream::clearReadBuffer()
{
    d->readBuf.resize(0);
}

void ByteStream::clearWriteBuffer()
{
    d->writeBuf.resize(0);
}

void ByteStream::appendRead(const QByteArray &block)
{
    appendArray(&d->readBuf, block);
}

void ByteStream::appendWrite(const QByteArray &block)
{
    appendArray(&d->writeBuf, block);
}

QByteArray ByteStream::takeRead(int size, bool del)
{
    return takeArray(&d->readBuf, size, del);
}

QByteArray ByteStream::takeWrite(int size, bool del)
{
    return takeArray(&d->writeBuf, size, del);
}

QByteArray & ByteStream::readBuf()
{
    return d->readBuf;
}

QByteArray & ByteStream::writeBuf()
{
    return d->writeBuf;
}

int ByteStream::tryWrite()
{
    return -1;
}

void ByteStream::appendArray(QByteArray *a, const QByteArray &b)
{
    int oldsize = a->size();
    a->resize(oldsize + b.size());
    memcpy(a->data() + oldsize, b.data(), b.size());
}

QByteArray ByteStream::takeArray(QByteArray *from, int size, bool del)
{
    QByteArray a;
    if(size == 0) {
        a = *from;
        if(del)
            from->resize(0);
    }
    else {
        if(size > (int)from->size())
            size = from->size();
        a.resize(size);
        char *r = from->data();
        memcpy(a.data(), r, size);
        if(del) {
            int newsize = from->size()-size;
            memmove(r, r+size, newsize);
            from->resize(newsize);
        }
    }
    return a;
}
/*
    void connectionClosed();
    void delayedCloseFinished();
    void readyRead();
    void bytesWritten(int);
    void error(int);





*/

}
// CS_NAMESPACE_END

#include "bytestream.moc"

kopete/protocols/messenger/libpapillon

Skip menu "kopete/protocols/messenger/libpapillon"

• Main Page
• Namespace List
• Class Hierarchy
• Alphabetical List
• Class List
• File List
• Namespace Members
• Class Members
• Related Pages

kdenetwork

Skip menu "kdenetwork"

• kget
• kopete
•   kopete
•   libkopete
•       libpapillon
• krfb

Generated for kdenetwork by doxygen 1.5.4
This website is maintained by Adriaan de Groot and Allen Winter.
KDE^® and the K Desktop Environment^® logo are registered trademarks of KDE e.V. | Legal