Storage.cc

Go to the documentation of this file.

#include "Utilities/StorageFactory/interface/Storage.h"
#include "FWCore/Utilities/interface/Exception.h"
#include <cassert>

Storage::Storage(void) {}

Storage::~Storage(void) {}

IOSize Storage::read(IOBuffer into, IOOffset pos) { return read(into.data(), into.size(), pos); }

IOSize Storage::read(void *into, IOSize n, IOOffset pos) {
  // FIXME: this is not thread safe!  split into separate interface
  // that a particular storage can choose to support or not?  make
  // sure that throw semantics are correct here!
  // FIXME: use saveposition object in case exceptions are thrown?
  IOOffset here = position();
  position(pos);
  n = read(into, n);
  position(here);
  return n;
}

IOSize Storage::readv(IOPosBuffer *into, IOSize n) {
  IOOffset here = position();
  IOSize total = 0;
  for (IOSize i = 0; i < n; ++i) {
    try {
      position(into[i].offset());
      total += read(into[i].data(), into[i].size());
    } catch (cms::Exception &) {
      if (!total)
        throw;
      break;
    }
  }
  position(here);
  return total;
}

IOSize Storage::write(IOBuffer from, IOOffset pos) { return write(from.data(), from.size(), pos); }

IOSize Storage::write(const void *from, IOSize n, IOOffset pos) {
  // FIXME: this is not thread safe!  split into separate interface
  // that a particular storage can choose to support or not?  make
  // sure that throw semantics are correct here!

  // FIXME: use saveposition object in case exceptions are thrown?
  IOOffset here = position();
  position(pos);
  n = write(from, n);
  position(here);
  return n;
}

IOSize Storage::writev(const IOPosBuffer *from, IOSize n) {
  IOSize total = 0;
  for (IOSize i = 0; i < n; ++i) {
    try {
      total += write(from[i].data(), from[i].size(), from[i].offset());
    } catch (cms::Exception &) {
      if (!total)
        throw;
      break;
    }
  }
  return total;
}

IOOffset Storage::position(void) const {
  Storage *self = const_cast<Storage *>(this);
  return self->position(0, CURRENT);
}

IOOffset Storage::size(void) const {
  // FIXME: use saveposition object in case exceptions are thrown?
  Storage *self = const_cast<Storage *>(this);
  IOOffset here = position();
  self->position(0, END);
  IOOffset size = position();
  self->position(here);  // FIXME: VERIFY()?
  return size;
}

void Storage::rewind(void) { position(0); }

bool Storage::prefetch(const IOPosBuffer * /* what */, IOSize /* n */) { return false; }

void Storage::flush(void) {}

void Storage::close(void) {}

bool Storage::eof(void) const { return position() == size(); }