---

funneldevice.h

Go to the documentation of this file.

/***************************************************************************
    funneldevice.h  -  Definition of the FunnelDevice class.
                             -------------------
    begin                : June 21 2002
    copyright            : (C) 2003 by Vojtìch Toman
    email                : vtoman@lit.cz
 ***************************************************************************/

/***************************************************************************
 *                                                                         *
 *   This program 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.                                   *
 *                                                                         *
 ***************************************************************************/

#ifdef __GNUG__
# pragma interface
#endif

#ifndef CHANNELDEVICE_H
#define CHANNELDEVICE_H

#include "defs.h"
#include "debug.h"
#include "exceptions.h"
#include "iodevice.h"
#include "xmldefs.h"



#define DEFAULT_FUNNEL_BUFFER_SIZE      4098


class UserOfFunnelDevice;



class FunnelDevice : public IODevice
{
public:
  FunnelDevice(UserOfFunnelDevice *rcvr, bool isImmediate = false, size_t size = DEFAULT_FUNNEL_BUFFER_SIZE);

  virtual ~FunnelDevice(void);

  virtual void prepare(void) throw (ExaltIOException);

  virtual void flush(void) throw (ExaltIOException);

  virtual void finish(void) throw (ExaltIOException);

  virtual IOState readData(char *buf, IOSize length) throw (ExaltIOException);

  virtual IOState getChar(int *) throw (ExaltIOException);

  virtual IOState writeData(const char *buf, IOSize length) throw (ExaltIOException);

  virtual IOState putChar(int) throw (ExaltIOException);

  virtual IOSize bytesReadTotal(void);

  virtual IOSize bytesRead(void);

  virtual IOSize bytesWritten(void);

  virtual bool errorOccurred(void);

  virtual bool eof(void);

protected:
  UserOfFunnelDevice *receiver;

  size_t bufferSize;

  size_t dataLength;

  bool dataPresent;

  bool immediate;

  IOSize bw;

  XmlChar *buffer;
};


class UserOfFunnelDevice
{
public:
  virtual void receiveData(XmlChar *data, size_t size) = 0;
};




#endif //FUNNELDEVICE_H

---