![]() |
![]() |
00001 // $Id: EventStreamHttpReader.h,v 1.22.10.2 2011/03/10 09:00:16 mommsen Exp $ 00003 00004 #ifndef StorageManager_EventStreamHttpReader_h 00005 #define StorageManager_EventStreamHttpReader_h 00006 00007 #include "EventFilter/StorageManager/interface/EventConsumerRegistrationInfo.h" 00008 #include "EventFilter/StorageManager/interface/EventServerProxy.h" 00009 #include "FWCore/ParameterSet/interface/ParameterSet.h" 00010 #include "FWCore/Framework/interface/InputSourceDescription.h" 00011 #include "IOPool/Streamer/interface/StreamerInputSource.h" 00012 00013 00014 namespace edm 00015 { 00033 class EventStreamHttpReader : public edm::StreamerInputSource 00034 { 00035 public: 00036 EventStreamHttpReader 00037 ( 00038 edm::ParameterSet const&, 00039 edm::InputSourceDescription const& 00040 ); 00041 virtual ~EventStreamHttpReader() {}; 00042 00043 virtual EventPrincipal* read(); 00044 00045 private: 00046 void readHeader(); 00047 00048 stor::EventServerProxy<stor::EventConsumerRegistrationInfo> eventServerProxy_; 00049 00050 const bool dropOldLumisectionEvents_; 00051 unsigned int lastLS_; 00052 00053 }; 00054 00055 } // namespace edm 00056 00057 #endif // StorageManager_EventStreamHttpReader_h 00058