src/contrib/libqxt-2007-10-24/src/core/qxtfifo.cpp

   1 /****************************************************************************
   2 **
   3 ** Copyright (C) Qxt Foundation. Some rights reserved.
   4 **
   5 ** This file is part of the QxtCore module of the Qt eXTension library
   6 **
   7 ** This library is free software; you can redistribute it and/or modify it
   8 ** under the terms of th Common Public License, version 1.0, as published by
   9 ** IBM.
  10 **
  11 ** This file is provided "AS IS", without WARRANTIES OR CONDITIONS OF ANY
  12 ** KIND, EITHER EXPRESS OR IMPLIED INCLUDING, WITHOUT LIMITATION, ANY
  13 ** WARRANTIES OR CONDITIONS OF TITLE, NON-INFRINGEMENT, MERCHANTABILITY OR
  14 ** FITNESS FOR A PARTICULAR PURPOSE.
  15 **
  16 ** You should have received a copy of the CPL along with this file.
  17 ** See the LICENSE file and the cpl1.0.txt file included with the source
  18 ** distribution for more information. If you did not receive a copy of the
  19 ** license, contact the Qxt Foundation.
  20 **
  21 ** <http://libqxt.sourceforge.net>  <foundation@libqxt.org>
  22 **
  23 ****************************************************************************/
  24
  25
  26 /**
  27 \class QxtFifo QxtFifo
  28
  29 \ingroup QxtCore
  30
  31 \brief Simple Loopback QIODevice
  32
  33 read and write to the same object \n
  34 emits a readyRead Signal. \n
  35 usefull for loopback tests where QBuffer does not work.
  36
  37 \code
  38 QxtFifo fifo;
  39  QTextStream (&fifo)<<QString("foo");
  40  QString a;
  41  QTextStream(&fifo)>>a;
  42  qDebug()<<a;
  43 \endcode
  44
  45 */
  46 #include "qxtfifo.h"
  47 #include <QDebug>
  48
  49 QxtFifo::QxtFifo(QObject *parent):QIODevice(parent)
  50 {
  51     setOpenMode (QIODevice::ReadWrite);
  52 }
  53
  54 qint64 QxtFifo::readData ( char * data, qint64 maxSize )
  55 {
  56     qint64 i=0;
  57     for (;i<maxSize;i++)
  58     {
  59         if (q.isEmpty())
  60             break;
  61         (*data++)=q.dequeue();
  62     }
  63     return i;
  64 }
  65 qint64 QxtFifo::writeData ( const char * data, qint64 maxSize )
  66 {
  67     qint64 i=0;
  68     for (;i<maxSize;i++)
  69         q.enqueue(*data++);
  70
  71     if (i>0)
  72         emit(readyRead ());
  73     return maxSize;
  74 }
  75
  76
  77 bool QxtFifo::isSequential () const
  78 {
  79     return true;
  80 }
  81
  82
  83 qint64 QxtFifo::bytesAvailable () const
  84 {
  85     return q.count();
  86 }
  87
  88
  89
  90
  91
  92
  93