IOOutput.cc

Go to the documentation of this file.

#include "Utilities/StorageFactory/interface/IOOutput.h"
#include "FWCore/Utilities/interface/EDMException.h"
#include <cassert>

IOOutput::~IOOutput (void)
{}


IOSize
IOOutput::write (unsigned char byte)
{ return write (&byte, 1); }

IOSize
IOOutput::write (IOBuffer from)
{ return write (from.data (), from.size ()); }

IOSize
IOOutput::writev (const IOBuffer *from, IOSize buffers)
{
  assert (! buffers || from);

  // Keep writing as long as possible; ignore errors if we have
  // written something, otherwise pass it on.
  IOSize x;
  IOSize done = 0;
  try
  {
    for (IOSize i = 0; i < buffers; ++i)
    {
      done += (x = write (from [i].data (), from [i].size ()));
      if (x < from [i].size ())
    break;
    }
  }
  catch (cms::Exception &)
  {
    if (! done)
      throw;
  }

  return done;
}


IOSize
IOOutput::xwrite (IOBuffer from)
{ return xwrite (from.data (), from.size ()); }

IOSize
IOOutput::xwrite (const void *from, IOSize n)
{
  // Keep writing until we've written it all.  Let errors fly over.
  IOSize done = 0;
  while (done < n)
    done += write ((const char *) from + done, n - done);

  return done;
}

IOSize
IOOutput::xwritev (const IOBuffer *from, IOSize buffers)
{
  // Keep writing until we've written it all.  Let errors fly over.
  // FIXME: Use writev(from, buffers) and then sort out in case of
  // failure, the writev probably succeed directly with much less
  // overhead.
  assert (! buffers || from);

  IOSize done = 0;
  for (IOSize i = 0; i < buffers; ++i)
    done += xwrite (from [i].data (), from [i].size ());

  return done;
}