---

edm::StreamerInputSource Class Reference

#include <IOPool/Streamer/interface/StreamerInputSource.h>

Inheritance diagram for edm::StreamerInputSource:

List of all members.

Public Member Functions
void	deserializeAndMergeWithRegistry (InitMsgView const &initView, bool subsequent=false)
	Deserializes the specified init message into a SendJobHeader object and merges registries.
std::auto_ptr< EventPrincipal >	deserializeEvent (EventMsgView const &eventView)
	Deserializes the specified event message into an EventPrincipal object.
	StreamerInputSource (ParameterSet const &pset, InputSourceDescription const &desc)
virtual	~StreamerInputSource ()
Static Public Member Functions
static std::auto_ptr < SendJobHeader >	deserializeRegistry (InitMsgView const &initView)
	Deserializes the specified init message into a SendJobHeader object (which is related to the product registry).
static void	mergeIntoRegistry (SendJobHeader const &header, ProductRegistry &, bool subsequent)
static unsigned int	uncompressBuffer (unsigned char *inputBuffer, unsigned int inputSize, std::vector< unsigned char > &outputBuffer, unsigned int expectedFullSize)
	Uncompresses the data in the specified input buffer into the specified output buffer.
Protected Member Functions
void	resetAfterEndRun ()
void	saveTriggerNames (InitMsgView const *header)
void	setEndRun ()
Static Protected Member Functions
static void	buildClassCache (SendDescs const &descs)
static void	declareStreamers (SendDescs const &descs)
Protected Attributes
bool	inputFileTransitionsEachEvent_
Private Member Functions
virtual ItemType	getNextItemType ()
virtual std::auto_ptr < EventPrincipal >	read ()=0
virtual std::auto_ptr < EventPrincipal >	readEvent_ ()
virtual boost::shared_ptr < FileBlock >	readFile_ ()
virtual boost::shared_ptr < LuminosityBlockPrincipal >	readLuminosityBlock_ ()
virtual boost::shared_ptr < RunPrincipal >	readRun_ ()
virtual void	setRun (RunNumber_t r)
Private Attributes
std::vector< unsigned char >	dest_
std::auto_ptr< EventPrincipal >	ep_
bool	newLumi_
bool	newRun_
ProductGetter	productGetter_
bool	runEndingFlag_
TClass *	tc_
RootBuffer	xbuf_
Static Private Attributes
static std::string	processName_
static unsigned int	protocolVersion_
Classes
class	ProductGetter

---

Detailed Description

Definition at line 34 of file StreamerInputSource.h.

---

Constructor & Destructor Documentation

edm::StreamerInputSource::StreamerInputSource	(	ParameterSet const &	pset,
		InputSourceDescription const &	desc
	)			[explicit]

Definition at line 49 of file StreamerInputSource.cc.

                                                       :
    InputSource(pset, desc),
    // The value for the following parameter gets overwritten in at least one derived class
    // where it has a different default value.
    inputFileTransitionsEachEvent_(
      pset.getUntrackedParameter<bool>("inputFileTransitionsEachEvent", false)),
    newRun_(true),
    newLumi_(true),
    ep_(),
    tc_(getTClass(typeid(SendEvent))),
    dest_(init_size),
    xbuf_(TBuffer::kRead, init_size),
    runEndingFlag_(false),
    productGetter_()
  {
  }

edm::StreamerInputSource::~StreamerInputSource

(

)

[virtual]

Definition at line 68 of file StreamerInputSource.cc.

{}

---

Member Function Documentation

void edm::StreamerInputSource::buildClassCache

(

SendDescs const &

descs

)

[static, protected]

Definition at line 125 of file StreamerInputSource.cc.

References edm::doBuildRealData(), e, lat::endl(), FDEBUG, i, and edm::wrappedClassName().

Referenced by mergeIntoRegistry().

                                                             { 
    SendDescs::const_iterator i(descs.begin()), e(descs.end());

    for(; i != e; ++i) {
        //pi->init();
        std::string const real_name = wrappedClassName(i->className());
        FDEBUG(6) << "BuildReadData: " << real_name << std::endl;
        doBuildRealData(real_name);
    }
  }

void edm::StreamerInputSource::declareStreamers

(

SendDescs const &

descs

)

[static, protected]

Definition at line 112 of file StreamerInputSource.cc.

References e, lat::endl(), FDEBUG, i, edm::loadCap(), and edm::wrappedClassName().

Referenced by mergeIntoRegistry().

                                                              {
    SendDescs::const_iterator i(descs.begin()), e(descs.end());

    for(; i != e; ++i) {
        //pi->init();
        std::string const real_name = wrappedClassName(i->className());
        FDEBUG(6) << "declare: " << real_name << std::endl;
        loadCap(real_name);
    }
  }

void edm::StreamerInputSource::deserializeAndMergeWithRegistry	(	InitMsgView const &	initView,
		bool	subsequent = false
	)

Deserializes the specified init message into a SendJobHeader object and merges registries.

Definition at line 250 of file StreamerInputSource.cc.

References deserializeRegistry(), i, edm::detail::ThreadSafeRegistry< KEY, T, E >::insertMapped(), edm::detail::ThreadSafeRegistry< KEY, T, E >::instance(), k, mergeIntoRegistry(), and edm::InputSource::productRegistryUpdate().

Referenced by edm::StreamerInputModule< Producer >::read(), edm::EventStreamHttpReader::readHeader(), edm::OnlineHttpReader::readHeader(), and edm::StreamerInputModule< Producer >::StreamerInputModule().

  {
     std::auto_ptr<SendJobHeader> sd = deserializeRegistry(initView);
     mergeIntoRegistry(*sd, productRegistryUpdate(), subsequent);
     ModuleDescriptionRegistry & moduleDescriptionRegistry = *ModuleDescriptionRegistry::instance();
     ModuleDescriptionMap const& mdMap = sd->moduleDescriptionMap();
     for (ModuleDescriptionMap::const_iterator k = mdMap.begin(), kEnd = mdMap.end(); k != kEnd; ++k) {
       moduleDescriptionRegistry.insertMapped(k->second);
     } 
     SendJobHeader::ParameterSetMap const & psetMap = sd->processParameterSet();
     pset::Registry& psetRegistry = *pset::Registry::instance();
     for (SendJobHeader::ParameterSetMap::const_iterator i = psetMap.begin(), iEnd = psetMap.end(); i != iEnd; ++i) {
       psetRegistry.insertMapped(ParameterSet(i->second.pset_));
     }
  }

std::auto_ptr< EventPrincipal > edm::StreamerInputSource::deserializeEvent

(

EventMsgView const &

eventView

)

Deserializes the specified event message into an EventPrincipal object.

Definition at line 270 of file StreamerInputSource.cc.

References EventMsgView::code(), edmNew::copy(), dest_, lat::endl(), EventMsgView::event(), Header::EVENT, EventMsgView::eventData(), EventMsgView::eventLength(), Exception, FDEBUG, Capri::details::from(), edm::ProcessConfiguration::id(), edm::ProductID::id(), edm::detail::ThreadSafeRegistry< KEY, T, E >::instance(), edm::Timestamp::invalidTimestamp(), EventMsgView::lumi(), edm::lumiAux, edm::InputSource::luminosityBlock(), edm::InputSource::luminosityBlockPrincipal(), newLumi_, newRun_, EventMsgView::origDataSize(), edm::InputSource::processConfiguration(), productGetter_, edm::InputSource::productRegistry(), edm::InputSource::productRegistryUpdate(), edm::InputSource::resetLuminosityBlockPrincipal(), edm::InputSource::run(), EventMsgView::run(), edm::runAux, edm::InputSource::runPrincipal(), edm::StreamerInputSource::ProductGetter::setEventPrincipal(), edm::InputSource::setLuminosityBlockPrincipal(), edm::ProductRegistry::setNextID(), edm::ProductRegistry::setProductIDs(), edm::setRefCoreStreamer(), edm::InputSource::setRunPrincipal(), EventMsgView::size(), tc_, uncompressBuffer(), and xbuf_.

Referenced by edm::OnlineHttpReader::getOneEvent(), edm::EventStreamHttpReader::getOneEvent(), and edm::StreamerInputModule< Producer >::read().

  {
    if(eventView.code() != Header::EVENT)
      throw cms::Exception("StreamTranslation","Event deserialization error")
        << "received wrong message type: expected EVENT, got "
        << eventView.code() << "\n";
    FDEBUG(9) << "Decode event: "
         << eventView.event() << " "
         << eventView.run() << " "
         << eventView.size() << " "
         << eventView.eventLength() << " "
         << eventView.eventData()
         << std::endl;
    EventSourceSentry(*this);
    // uncompress if we need to
    // 78 was a dummy value (for no uncompressed) - should be 0 for uncompressed
    // need to get rid of this when 090 MTCC streamers are gotten rid of
    unsigned long origsize = eventView.origDataSize();
    unsigned long dest_size; //(should be >= eventView.origDataSize() )

    if(origsize != 78 && origsize != 0)
    {
      // compressed
      dest_size = uncompressBuffer((unsigned char*)eventView.eventData(),
                                   eventView.eventLength(), dest_, origsize);
    }
    else // not compressed
    {
      // we need to copy anyway the buffer as we are using dest in xbuf
      dest_size = eventView.eventLength();
      dest_.resize(dest_size);
      unsigned char* pos = (unsigned char*) &dest_[0];
      unsigned char* from = (unsigned char*) eventView.eventData();
      std::copy(from,from+dest_size,pos);
    }
    //TBuffer xbuf(TBuffer::kRead, dest_size,
    //             (char*) &dest[0],kFALSE);
    //TBuffer xbuf(TBuffer::kRead, eventView.eventLength(),
    //             (char*) eventView.eventData(),kFALSE);
    xbuf_.Reset();
    xbuf_.SetBuffer(&dest_[0],dest_size,kFALSE);
    RootDebug tracer(10,10);

    setRefCoreStreamer(&productGetter_);
    std::auto_ptr<SendEvent> sd((SendEvent*)xbuf_.ReadObjectAny(tc_));

    if(sd.get()==0) {
        throw cms::Exception("StreamTranslation","Event deserialization error")
          << "got a null event from input stream\n";
    }
    sd->processHistory().setDefaultTransients();
    ProcessHistoryRegistry::instance()->insertMapped(sd->processHistory());

    FDEBUG(5) << "Got event: " << sd->aux().id() << " " << sd->products().size() << std::endl;
    if(!runPrincipal() || runPrincipal()->run() != sd->aux().run()) {
        newRun_ = newLumi_ = true;
        RunAuxiliary runAux(sd->aux().run(), sd->aux().time(), Timestamp::invalidTimestamp());
        setRunPrincipal(boost::shared_ptr<RunPrincipal>(
          new RunPrincipal(runAux,
                           productRegistry(),
                           processConfiguration())));
        resetLuminosityBlockPrincipal();
    }
    if(!luminosityBlockPrincipal() || luminosityBlockPrincipal()->luminosityBlock() != eventView.lumi()) {
      
      LuminosityBlockAuxiliary lumiAux(runPrincipal()->run(), eventView.lumi(), sd->aux().time(), Timestamp::invalidTimestamp());
      setLuminosityBlockPrincipal(boost::shared_ptr<LuminosityBlockPrincipal>(
        new LuminosityBlockPrincipal(lumiAux,
                                     productRegistry(),
                                     processConfiguration())));
      newLumi_ = true;
    }

    std::auto_ptr<EventPrincipal> ep(new EventPrincipal(sd->aux(),
                                                   productRegistry(),
                                                   processConfiguration(),
                                                   sd->processHistory().id()));
    productGetter_.setEventPrincipal(ep.get());

    // no process name list handling

    ProductID largestID;
    SendProds & sps = sd->products();
    for(SendProds::iterator spi = sps.begin(), spe = sps.end(); spi != spe; ++spi) {
        FDEBUG(10) << "check prodpair" << std::endl;
        if(spi->desc() == 0)
          throw cms::Exception("StreamTranslation","Empty Provenance");
        FDEBUG(5) << "Prov:"
             << " " << spi->desc()->className()
             << " " << spi->desc()->productInstanceName()
             << " " << spi->desc()->branchID()
             << std::endl;

        ConstBranchDescription branchDesc(*spi->desc());
        // This EventEntryInfo constructor inserts into the entry description registry
        boost::shared_ptr<EventEntryInfo> eventEntryDesc(
             new EventEntryInfo(spi->branchID(),
                                spi->status(),
                                spi->mod(),
                                spi->productID(),
                                *spi->parents()));

        ep->branchMapperPtr()->insert(*eventEntryDesc);
        if(spi->productID() > largestID) {
           largestID = spi->productID();
        }
        if(spi->prod() != 0) {
          std::auto_ptr<EDProduct> aprod(const_cast<EDProduct*>(spi->prod()));
          FDEBUG(10) << "addgroup next " << spi->branchID() << std::endl;
          ep->addGroup(aprod, branchDesc, eventEntryDesc);
          FDEBUG(10) << "addgroup done" << std::endl;
        } else {
          FDEBUG(10) << "addgroup empty next " << spi->branchID() << std::endl;
          ep->addGroup(branchDesc, eventEntryDesc);
          FDEBUG(10) << "addgroup empty done" << std::endl;
        }
        spi->clear();
    }

    if(largestID.id() >= productRegistry()->nextID()) {
       edm::LogError("MetaDataError")<<"The input file has a critical problem, the 'nextID' for the ProductRegistry ("
                                     <<productRegistry()->nextID()
                                     <<")\n is less than the largest ProductID ("
                                     <<largestID.id()
                                     <<") used in a previous process.\n"
          " Will modify the ProductRegistry to attempt to correct the problem,\n"
          " although it is possible that edm::Ref*'s or edm::Ptr's may still fail.\n"
          " Please contact StreamerOutputModule developers.";
       //NOTE: this works since only EDProducers get their ProductIDs for the event from
       // the ProductRegistry and they do not do that until they 'put' their data
       // so at this point no one has tried to use the ProductIDs yet
       productRegistryUpdate().setNextID(largestID.id()+1);
       productRegistryUpdate().setProductIDs(largestID.id()+1);
    }
    FDEBUG(10) << "Size = " << ep->size() << std::endl;

    return ep;     
  }

std::auto_ptr< SendJobHeader > edm::StreamerInputSource::deserializeRegistry

(

InitMsgView const &

initView

)

[static]

Deserializes the specified init message into a SendJobHeader object (which is related to the product registry).

Definition at line 213 of file StreamerInputSource.cc.

References InitMsgView::code(), InitMsgView::descData(), InitMsgView::descLength(), lat::endl(), Exception, FDEBUG, edm::getTClass(), Header::INIT, InitMsgView::processName(), processName_, InitMsgView::protocolVersion(), and protocolVersion_.

Referenced by deserializeAndMergeWithRegistry(), and edm::readHeaderFromStream().

  {
    if(initView.code() != Header::INIT)
      throw cms::Exception("StreamTranslation","Registry deserialization error")
        << "received wrong message type: expected INIT, got "
        << initView.code() << "\n";

    //Get the process name and store if for Protocol version 4 and above.
    if (initView.protocolVersion() > 3) {

         processName_ = initView.processName();
         protocolVersion_ = initView.protocolVersion();

         FDEBUG(10) << "StreamerInputSource::deserializeRegistry processName = "<< processName_<< std::endl;
         FDEBUG(10) << "StreamerInputSource::deserializeRegistry protocolVersion_= "<< protocolVersion_<< std::endl;
    }
    
    TClass* desc = getTClass(typeid(SendJobHeader));

    RootBuffer xbuf(TBuffer::kRead, initView.descLength(),
                 (char*)initView.descData(),kFALSE);
    RootDebug tracer(10,10);
    std::auto_ptr<SendJobHeader> sd((SendJobHeader*)xbuf.ReadObjectAny(desc));

    if(sd.get()==0) {
        throw cms::Exception("StreamTranslation","Registry deserialization error")
          << "Could not read the initial product registry list\n";
    }

    return sd;  
  }

InputSource::ItemType edm::StreamerInputSource::getNextItemType

(

)

[private, virtual]

Implements edm::InputSource.

Definition at line 174 of file StreamerInputSource.cc.

References ep_, inputFileTransitionsEachEvent_, edm::InputSource::IsEvent, edm::InputSource::IsFile, edm::InputSource::IsLumi, edm::InputSource::IsRun, edm::InputSource::IsStop, edm::InputSource::luminosityBlockPrincipal(), newLumi_, newRun_, read(), edm::InputSource::resetLuminosityBlockPrincipal(), edm::InputSource::resetRunPrincipal(), runEndingFlag_, and edm::InputSource::runPrincipal().

                                       {
    if (runEndingFlag_) {
      return IsStop;
    }
    if(newRun_ && runPrincipal()) {
      return IsRun;
    }
    if(newLumi_ && luminosityBlockPrincipal()) {
      return IsLumi;
    }
    if (ep_.get() != 0) {
      return IsEvent;
    }
    if (inputFileTransitionsEachEvent_) {
      resetRunPrincipal();
      resetLuminosityBlockPrincipal();
    }
    ep_ = read();
    if (ep_.get() == 0) {
      return IsStop;
    } else {
      runEndingFlag_ = false;
      if (inputFileTransitionsEachEvent_) {
        return IsFile;
      }
    }
    if(newRun_) {
      return IsRun;
    } else if(newLumi_) {
      return IsLumi;
    }
    return IsEvent;
  }

void edm::StreamerInputSource::mergeIntoRegistry	(	SendJobHeader const &	header,
		ProductRegistry &	reg,
		bool	subsequent
	)			[static]

Definition at line 78 of file StreamerInputSource.cc.

References buildClassCache(), edm::ProductRegistry::copyProduct(), declareStreamers(), edm::SendJobHeader::descs(), e, lat::endl(), Exception, FDEBUG, i, edm::loadExtraClasses(), edm::ProductRegistry::merge(), edm::SendJobHeader::nextID(), edm::BranchDescription::Permissive, and edm::ProductRegistry::setNextID().

Referenced by deserializeAndMergeWithRegistry(), and edm::getRegFromFile().

                                                                {

    SendDescs const& descs = header.descs();

    SendDescs::const_iterator i(descs.begin()), e(descs.end());

    FDEBUG(6) << "mergeIntoRegistry: Product List: " << std::endl;

    if (subsequent) {
      ProductRegistry pReg;
      for(; i != e; ++i) {
        pReg.copyProduct(*i);
        FDEBUG(6) << "StreamInput prod = " << i->className() << std::endl;
      }
      std::string mergeInfo = reg.merge(pReg, std::string(), BranchDescription::Permissive);
      if (!mergeInfo.empty()) {
        throw cms::Exception("MismatchedInput","RootInputFileSequence::previousEvent()") << mergeInfo;
      }
    } else {
      declareStreamers(descs);
      buildClassCache(descs);
      loadExtraClasses();
      for(; i != e; ++i) {
        i->setDefaultTransients();
        i->init();
        reg.copyProduct(*i);
        FDEBUG(6) << "StreamInput prod = " << i->className() << std::endl;
      }
    }
    reg.setNextID(header.nextID());
  }

virtual std::auto_ptr<EventPrincipal> edm::StreamerInputSource::read

(

)

[private, pure virtual]

Implemented in edm::EventStreamHttpReader, edm::OnlineHttpReader, and edm::StreamerInputModule< Producer >.

Referenced by getNextItemType().

std::auto_ptr< EventPrincipal > edm::StreamerInputSource::readEvent_

(

)

[private, virtual]

Implements edm::InputSource.

Definition at line 165 of file StreamerInputSource.cc.

References ep_, newLumi_, and newRun_.

                                  {
    assert(!newRun_);
    assert(!newLumi_);
    assert(ep_.get() != 0);
    // This copy resets ep_.
    return ep_;
  }

boost::shared_ptr< FileBlock > edm::StreamerInputSource::readFile_

(

)

[private, virtual]

Reimplemented from edm::InputSource.

Definition at line 72 of file StreamerInputSource.cc.

References edm::InputSource::productRegistry(), edm::InputSource::productRegistryUpdate(), and edm::ProductRegistry::setProductIDs().

                                 {
    productRegistryUpdate().setProductIDs(productRegistry()->nextID());
    return boost::shared_ptr<FileBlock>(new FileBlock);
  }

boost::shared_ptr< LuminosityBlockPrincipal > edm::StreamerInputSource::readLuminosityBlock_

(

)

[private, virtual]

Implements edm::InputSource.

Definition at line 156 of file StreamerInputSource.cc.

References edm::InputSource::luminosityBlockPrincipal(), newLumi_, and newRun_.

                                            {
    assert(!newRun_);
    assert(newLumi_);
    assert(luminosityBlockPrincipal());
    newLumi_ = false;
    return luminosityBlockPrincipal();
  }

boost::shared_ptr< RunPrincipal > edm::StreamerInputSource::readRun_

(

)

[private, virtual]

Implements edm::InputSource.

Definition at line 148 of file StreamerInputSource.cc.

References newRun_, and edm::InputSource::runPrincipal().

                                {
    assert(newRun_);
    assert(runPrincipal());
    newRun_ = false;
    return runPrincipal();
  }

void edm::StreamerInputSource::resetAfterEndRun

(

)

[protected]

Definition at line 455 of file StreamerInputSource.cc.

References ep_, edm::InputSource::reset(), and runEndingFlag_.

Referenced by edm::OnlineHttpReader::setRun().

  {
     // called from an online streamer source to reset after a stop command
     // so an enable command will work
     assert(ep_.get() == 0);
     reset();
     runEndingFlag_ = false;
  }

void edm::StreamerInputSource::saveTriggerNames

(

InitMsgView const *

header

)

[protected]

Definition at line 137 of file StreamerInputSource.cc.

References edm::ParameterSet::addParameter(), InitMsgView::hltTriggerNames(), and edm::detail::ThreadSafeRegistry< KEY, T, E >::instance().

Referenced by edm::StreamerInputModule< Producer >::read(), and edm::StreamerInputModule< Producer >::StreamerInputModule().

                                                                 {

    ParameterSet trigger_pset;
    std::vector<std::string> paths;
    header->hltTriggerNames(paths);
    trigger_pset.addParameter<Strings>("@trigger_paths", paths);
    pset::Registry* psetRegistry = pset::Registry::instance();
    psetRegistry->insertMapped(trigger_pset);
  }

void edm::StreamerInputSource::setEndRun

(

)

[inline, protected]

Definition at line 66 of file StreamerInputSource.h.

Referenced by edm::OnlineHttpReader::getOneEvent(), and edm::EventStreamHttpReader::getOneEvent().

{runEndingFlag_ = true;}

void edm::StreamerInputSource::setRun

(

RunNumber_t

r

)

[private, virtual]

Reimplemented from edm::InputSource.

Reimplemented in edm::OnlineHttpReader.

Definition at line 464 of file StreamerInputSource.cc.

References edm::errors::LogicError.

  {
     // Need to define a dummy setRun here or else the InputSource::setRun is called
     // if we have a source inheriting from this and wants to define a setRun method
     throw edm::Exception(edm::errors::LogicError)
     << "StreamerInputSource::setRun()\n"
     << "Run number cannot be modified for this type of Input Source\n"
     << "Contact a Storage Manager Developer\n";
  }

unsigned int edm::StreamerInputSource::uncompressBuffer	(	unsigned char *	inputBuffer,
		unsigned int	inputSize,
		std::vector< unsigned char > &	outputBuffer,
		unsigned int	expectedFullSize
	)			[static]

Uncompresses the data in the specified input buffer into the specified output buffer.

The inputSize should be set to the size of the compressed data in the inputBuffer. The expectedFullSize should be set to the original size of the data (before compression). Returns the actual size of the uncompressed data. Errors are reported by throwing exceptions.

Definition at line 418 of file StreamerInputSource.cc.

References TestMuL1L2Filter_cff::cerr, lat::endl(), Exception, and FDEBUG.

Referenced by edm::StreamDQMDeserializer::deserializeDQMEvent(), and deserializeEvent().

  {
    unsigned long origSize = expectedFullSize;
    unsigned long uncompressedSize = expectedFullSize;
    FDEBUG(1) << "Uncompress: original size = " << origSize
              << ", compressed size = " << inputSize
              << std::endl;
    outputBuffer.resize(origSize);
    int ret = uncompress(&outputBuffer[0], &uncompressedSize,
                         inputBuffer, inputSize); // do not need compression level
    //std::cout << "unCompress Return value: " << ret << " Okay = " << Z_OK << std::endl;
    if(ret == Z_OK) {
        // check the length against original uncompressed length
        FDEBUG(10) << " original size = " << origSize << " final size = " 
                   << uncompressedSize << std::endl;
        if(origSize != uncompressedSize) {
            std::cerr << "deserializeEvent: Problem with uncompress, original size = "
                 << origSize << " uncompress size = " << uncompressedSize << std::endl;
            // we throw an error and return without event! null pointer
            throw cms::Exception("StreamDeserialization","Uncompression error")
              << "mismatch event lengths should be" << origSize << " got "
              << uncompressedSize << "\n";
        }
    } else {
        // we throw an error and return without event! null pointer
        std::cerr << "deserializeEvent: Problem with uncompress, return value = "
             << ret << std::endl;
        throw cms::Exception("StreamDeserialization","Uncompression error")
            << "Error code = " << ret << "\n ";
    }

    return (unsigned int) uncompressedSize;
  }

---

Member Data Documentation

std::vector<unsigned char> edm::StreamerInputSource::dest_ [private]

Definition at line 107 of file StreamerInputSource.h.

Referenced by deserializeEvent().

std::auto_ptr<EventPrincipal> edm::StreamerInputSource::ep_ [private]

Definition at line 104 of file StreamerInputSource.h.

Referenced by getNextItemType(), readEvent_(), and resetAfterEndRun().

bool edm::StreamerInputSource::inputFileTransitionsEachEvent_ [protected]

Definition at line 69 of file StreamerInputSource.h.

Referenced by edm::EventStreamHttpReader::EventStreamHttpReader(), and getNextItemType().

bool edm::StreamerInputSource::newLumi_ [private]

Definition at line 103 of file StreamerInputSource.h.

Referenced by deserializeEvent(), getNextItemType(), readEvent_(), and readLuminosityBlock_().

bool edm::StreamerInputSource::newRun_ [private]

Definition at line 102 of file StreamerInputSource.h.

Referenced by deserializeEvent(), getNextItemType(), readEvent_(), readLuminosityBlock_(), and readRun_().

std::string edm::StreamerInputSource::processName_ [static, private]

Definition at line 113 of file StreamerInputSource.h.

Referenced by deserializeRegistry().

ProductGetter edm::StreamerInputSource::productGetter_ [private]

Definition at line 110 of file StreamerInputSource.h.

Referenced by deserializeEvent().

unsigned int edm::StreamerInputSource::protocolVersion_ [static, private]

Definition at line 114 of file StreamerInputSource.h.

Referenced by deserializeRegistry().

bool edm::StreamerInputSource::runEndingFlag_ [private]

Definition at line 109 of file StreamerInputSource.h.

Referenced by getNextItemType(), and resetAfterEndRun().

TClass* edm::StreamerInputSource::tc_ [private]

Definition at line 106 of file StreamerInputSource.h.

Referenced by deserializeEvent().

RootBuffer edm::StreamerInputSource::xbuf_ [private]

Definition at line 108 of file StreamerInputSource.h.

Referenced by deserializeEvent().

---

The documentation for this class was generated from the following files:

• IOPool/Streamer/interface/StreamerInputSource.h
• IOPool/Streamer/src/StreamerInputSource.cc

---