---

funneldevice.cpp

Go to the documentation of this file.

/***************************************************************************
    funneldevice.cpp  -  Definitions of the FunnelDevice class methods.
                             -------------------
    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 implementation
#endif

#include "funneldevice.h"




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

  bufferSize = size;
  buffer = 0;

  immediate = isImmediate;

  bw = 0;

  //device is "empty"
  dataLength = 0;
  dataPresent = false;
}


FunnelDevice::~FunnelDevice(void)
{
  if (buffer)
    DELETE_ARRAY(buffer);
}

void FunnelDevice::prepare(void) throw (ExaltIOException)
{
  NEW(buffer, XmlChar[bufferSize]);

  dataLength = 0;
}

void FunnelDevice::flush(void) throw (ExaltIOException)
{
  if (dataPresent)
    {
      try
        {
          receiver->receiveData(buffer, dataLength);
        }
      catch (ExaltException)
        {
          throw ExaltIOException();
        }
      
      //buffer is now empty
      dataLength = 0;
      dataPresent = false;
    }
}


void FunnelDevice::finish(void) throw (ExaltIOException)
{
  flush();

  //buffer is empty
  dataLength = 0;
  dataPresent = false;
  bw = 0;
}


IOState FunnelDevice::readData(char *buf, IOSize length) throw (ExaltIOException)
{
  return ReadOk;
}

IOState FunnelDevice::getChar(int *c) throw (ExaltIOException)
{
  *c = 0;
  return ReadOk;
}

IOState FunnelDevice::writeData(const char *buf, IOSize length) throw (ExaltIOException)
{
  bw += length;

  if (!buffer)
    {
      throw ExaltDeviceNotPreparedIOException();
      return WriteError;
    }

  if (length + dataLength > bufferSize)
    {
      throw ExaltDeviceFullIOException();
      return WriteError;
    }

  for (size_t i = 0; i < length; i++)
    {
      buffer[dataLength + i] = ((XmlChar *)buf)[i];
    }

  if (length)
    dataPresent = true;
  else
    dataPresent = false;

  dataLength += length;

  if (immediate)
    flush();

  return WriteOk;
}


IOState FunnelDevice::putChar(int c) throw (ExaltIOException)
{
  bw++;

  if (!buffer)
    {
      throw ExaltDeviceNotPreparedIOException();
      return WriteError;
    }

  if (dataLength >= bufferSize)
    {
      throw ExaltDeviceFullIOException();
      return WriteError;
    }


  buffer[dataLength] = (XmlChar)c;
  dataPresent = true;
  dataLength++;


  if (immediate)
    flush();


  return ReadOk;
}

IOSize FunnelDevice::bytesReadTotal(void)
{
  return 0;
}

IOSize FunnelDevice::bytesRead(void)
{
  return 0;
}

IOSize FunnelDevice::bytesWritten(void)
{
  return bw;
}

bool FunnelDevice::errorOccurred(void)
{
  return false;
}

bool FunnelDevice::eof(void)
{
  return false;
}

---