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;
}