---

edm::OnlineHttpReader Class Reference

#include <EventFilter/StorageManager/src/OnlineHttpReader.h>

Inheritance diagram for edm::OnlineHttpReader:

List of all members.

Public Types
typedef std::vector< char >	Buf
Public Member Functions
	OnlineHttpReader (edm::ParameterSet const &pset, edm::InputSourceDescription const &desc)
virtual std::auto_ptr < edm::EventPrincipal >	read ()
void	readHeader ()
void	registerWithEventServer ()
virtual	~OnlineHttpReader ()
Private Types
enum	{ DEFAULT_MAX_CONNECT_TRIES = 360, DEFAULT_CONNECT_TRY_SLEEP_TIME = 10 }
Private Member Functions
std::auto_ptr < edm::EventPrincipal >	getOneEvent ()
virtual void	setRun (RunNumber_t r)
Private Attributes
bool	alreadyGotHeader_
bool	alreadyRegistered_
bool	alreadySaidHalted_
Buf	buf_
int	connectTrySleepTime_
unsigned int	consumerId_
std::string	consumerName_
std::string	consumerPriority_
std::string	consumerPSetString_
bool	endRunAlreadyNotified_
char	eventurl_ [256]
int	headerRetryInterval_
char	headerurl_ [256]
int	hltBitCount
int	l1BitCount
struct timeval	lastRequestTime_
int	maxConnectTries_
double	minEventRequestInterval_
bool	runEnded_
std::string	sourceurl_
char	subscriptionurl_ [256]

---

Detailed Description

Definition at line 24 of file OnlineHttpReader.h.

---

Member Typedef Documentation

typedef std::vector<char> edm::OnlineHttpReader::Buf

Definition at line 27 of file OnlineHttpReader.h.

---

Member Enumeration Documentation

anonymous enum [private]

Enumerator:

DEFAULT_MAX_CONNECT_TRIES
DEFAULT_CONNECT_TRY_SLEEP_TIME

Definition at line 61 of file OnlineHttpReader.h.

    {
      DEFAULT_MAX_CONNECT_TRIES = 360,
      DEFAULT_CONNECT_TRY_SLEEP_TIME = 10
    };

---

Constructor & Destructor Documentation

edm::OnlineHttpReader::OnlineHttpReader	(	edm::ParameterSet const &	pset,
		edm::InputSourceDescription const &	desc
	)

Definition at line 45 of file OnlineHttpReader.cc.

References alreadyGotHeader_, alreadyRegistered_, connectTrySleepTime_, consumerId_, consumerName_, consumerPriority_, consumerPSetString_, DEFAULT_CONNECT_TRY_SLEEP_TIME, DEFAULT_MAX_CONNECT_TRIES, eventurl_, edm::ParameterSet::getUntrackedParameter(), header, headerRetryInterval_, headerurl_, i, lastRequestTime_, maxConnectTries_, L1TDQM_GREJuly_cfg::maxEventRequestRate, minEventRequestInterval_, readHeader(), registerWithEventServer(), sourceurl_, subscriptionurl_, and edm::ParameterSet::toString().

                                                                                     :
    edm::StreamerInputSource(ps, desc),
    sourceurl_(ps.getParameter<string>("sourceURL")),
    buf_(1000*1000*7), 
    endRunAlreadyNotified_(true),
    runEnded_(false),
    alreadySaidHalted_(false),
    maxConnectTries_(DEFAULT_MAX_CONNECT_TRIES),
    connectTrySleepTime_(DEFAULT_CONNECT_TRY_SLEEP_TIME)
  {
    // Retry connection params (wb)
    maxConnectTries_ = ps.getUntrackedParameter<int>("maxConnectTries",
                                               DEFAULT_MAX_CONNECT_TRIES);
    connectTrySleepTime_ = ps.getUntrackedParameter<int>("connectTrySleepTime",
                                               DEFAULT_CONNECT_TRY_SLEEP_TIME);

    std::string evturl = sourceurl_ + "/geteventdata";
    int stlen = evturl.length();
    for (int i=0; i<stlen; i++) eventurl_[i]=evturl[i];
    eventurl_[stlen] = '\0';

    std::string header = sourceurl_ + "/getregdata";
    stlen = header.length();
    for (int i=0; i<stlen; i++) headerurl_[i]=header[i];
    headerurl_[stlen] = '\0';

    std::string regurl = sourceurl_ + "/registerConsumer";
    stlen = regurl.length();
    for (int i=0; i<stlen; i++) subscriptionurl_[i]=regurl[i];
    subscriptionurl_[stlen] = '\0';

    // 09-Aug-2006, KAB: new parameters
    const double MAX_REQUEST_INTERVAL = 300.0;  // seconds
    consumerName_ = ps.getUntrackedParameter<string>("consumerName","Unknown");
    consumerPriority_ = ps.getUntrackedParameter<string>("consumerPriority","normal");
    headerRetryInterval_ = ps.getUntrackedParameter<int>("headerRetryInterval",5);
    double maxEventRequestRate = ps.getUntrackedParameter<double>("maxEventRequestRate",1.0);
    if (maxEventRequestRate < (1.0 / MAX_REQUEST_INTERVAL)) {
      minEventRequestInterval_ = MAX_REQUEST_INTERVAL;
    }
    else {
      minEventRequestInterval_ = 1.0 / maxEventRequestRate;  // seconds
    }
    lastRequestTime_.tv_sec = 0;
    lastRequestTime_.tv_usec = 0;

    // 28-Aug-2006, KAB: save our parameter set in string format to
    // be sent to the event server to specify our "request" (that is, which
    // events we are interested in).
    consumerPSetString_ = ps.toString();

    // 16-Aug-2006, KAB: register this consumer with the event server
    consumerId_ = (time(0) & 0xffffff);  // temporary - will get from ES later
    registerWithEventServer();
    alreadyRegistered_ = true;

    readHeader();
    alreadyGotHeader_ = true;
  }

edm::OnlineHttpReader::~OnlineHttpReader

(

)

[virtual]

Definition at line 106 of file OnlineHttpReader.cc.

  {
  }

---

Member Function Documentation

std::auto_ptr< edm::EventPrincipal > edm::OnlineHttpReader::getOneEvent

(

)

[private]

Definition at line 152 of file OnlineHttpReader.cc.

References alreadyRegistered_, alreadySaidHalted_, buf_, TestMuL1L2Filter_cff::cerr, HeaderView::code(), consumerId_, convert(), GenMuonPlsPt100GeV_cfg::cout, stor::ReadData::d_, data, edm::StreamerInputSource::deserializeEvent(), Header::DONE, lat::endl(), endRunAlreadyNotified_, Header::EVENT, Header::EVENT_REQUEST, eventurl_, Exception, FDEBUG, stor::func(), i, lastRequestTime_, len, minEventRequestInterval_, OtherMessageBuilder::msgBody(), NULL, runEnded_, edm::StreamerInputSource::setEndRun(), stor::setopt(), edm::shutdown_flag, OtherMessageBuilder::size(), and OtherMessageBuilder::startAddress().

Referenced by read().

  {
    // repeat a https get every N seconds until we get an event
    // wait for Storage Manager event server buffer to not be empty
    // only way to stop is specify a maxEvents parameter or cntrol-c.
    // If the Storage Manager is killed so the https get fails, we
    // end the job as we would be in an unknown state (If SM is up
    // and we have a network problem we just try to get another event,
    // but if SM is killed/dead we want to register.)

    // check if we need to sleep (to enforce the allowed request rate)
    struct timeval now;
    struct timezone dummyTZ;
    gettimeofday(&now, &dummyTZ);
    double timeDiff = (double) now.tv_sec;
    timeDiff -= (double) lastRequestTime_.tv_sec;
    timeDiff += ((double) now.tv_usec / 1000000.0);
    timeDiff -= ((double) lastRequestTime_.tv_usec / 1000000.0);
    if (timeDiff < minEventRequestInterval_)
    {
      double sleepTime = minEventRequestInterval_ - timeDiff;
      // trim off a little sleep time to account for the time taken by
      // calling gettimeofday again
      sleepTime -= 0.01;
      if (sleepTime < 0.0) {sleepTime = 0.0;}
      //cout << "sleeping for " << sleepTime << endl;
      usleep(static_cast<int>(1000000 * sleepTime));
      gettimeofday(&lastRequestTime_, &dummyTZ);
    }
    else
    {
      lastRequestTime_ = now;
    }

    stor::ReadData data;
    bool alreadySaidWaiting = false;
    do {
      CURL* han = curl_easy_init();

      if(han==0)
      {
        cerr << "could not create handle" << endl;
        // this will end cmsRun 
        //return std::auto_ptr<edm::EventPrincipal>();
        throw cms::Exception("getOneEvent","OnlineHttpReader")
            << "Could not get event: problem with curl"
            << "\n";
      }

      stor::setopt(han,CURLOPT_URL,eventurl_);
      stor::setopt(han,CURLOPT_WRITEFUNCTION,stor::func);
      stor::setopt(han,CURLOPT_WRITEDATA,&data);

      // 24-Aug-2006, KAB: send our consumer ID as part of the event request
      char msgBuff[100];
      OtherMessageBuilder requestMessage(&msgBuff[0], Header::EVENT_REQUEST,
                                         sizeof(char_uint32));
      uint8 *bodyPtr = requestMessage.msgBody();
      convert(consumerId_, bodyPtr);
      stor::setopt(han, CURLOPT_POSTFIELDS, requestMessage.startAddress());
      stor::setopt(han, CURLOPT_POSTFIELDSIZE, requestMessage.size());
      struct curl_slist *headers=NULL;
      headers = curl_slist_append(headers, "Content-Type: application/octet-stream");
      headers = curl_slist_append(headers, "Content-Transfer-Encoding: binary");
      stor::setopt(han, CURLOPT_HTTPHEADER, headers);

      // send the HTTP POST, read the reply, and cleanup before going on
      CURLcode messageStatus = curl_easy_perform(han);
      curl_slist_free_all(headers);
      curl_easy_cleanup(han);

      if(messageStatus!=0)
      {
        cerr << "curl perform failed for event, messageStatus = "
             << messageStatus << endl;
        // this will end cmsRun 
        //return std::auto_ptr<edm::EventPrincipal>();
        throw cms::Exception("getOneEvent","OnlineHttpReader")
            << "Could not get event: probably XDAQ not running on Storage Manager "
            << "\n";
      }
      if(data.d_.length() == 0)
      {
        if(!alreadySaidWaiting) {
          std::cout << "...waiting for event from Storage Manager..." << std::endl;
          alreadySaidWaiting = true;
        }
        // sleep for the standard request interval
        usleep(static_cast<int>(1000000 * minEventRequestInterval_));
      }
    } while (data.d_.length() == 0 && !edm::shutdown_flag);
    if (edm::shutdown_flag) {
        return std::auto_ptr<edm::EventPrincipal>();
    }

    int len = data.d_.length();
    FDEBUG(9) << "OnlineHttpReader received len = " << len << std::endl;
    buf_.resize(len);
    for (int i=0; i<len ; i++) buf_[i] = data.d_[i];

    // first check if done message
    OtherMessageView msgView(&buf_[0]);

    if (msgView.code() == Header::DONE) {
      // no need to register again as the SM/EventServer is kept alive on a stopAction
      // *BUT* for a haltAction, we need a code to say when SM is halted as then we need 
      // register again else the consumerId is wrong and we may get wrong events!
      // We may even need to end the job if a new run has new triggers, etc.
      if(!alreadySaidHalted_) {
        alreadySaidHalted_ = true;
        std::cout << "Storage Manager has stopped - waiting for restart" << std::endl;
        std::cout << "Warning! If you are waiting forever at: "
                  << "...waiting for event from Storage Manager... " << std::endl
                  << "   it may be that the Storage Manager has been halted with a haltAction," << std::endl
                  << "   instead of a stopAction. In this case you should control-c to end " << std::endl
                  << "   this consumer and restart it. (This will be fixed in a future update)" << std::endl;
      }
      // decide if we need to notify that a run has ended
      if(!endRunAlreadyNotified_) {
        endRunAlreadyNotified_ = true;
        setEndRun();
        runEnded_ = true;
        alreadyRegistered_ = false;
      }
      return std::auto_ptr<edm::EventPrincipal>();
    } else {
      // reset need-to-set-end-run flag when we get the first event (here any event)
      endRunAlreadyNotified_ = false;
      alreadySaidHalted_ = false;

      // 29-Jan-2008, KAB:  catch (and re-throw) any exceptions decoding
      // the event data so that we can display the returned HTML and
      // (hopefully) give the user a hint as to the cause of the problem.
      std::auto_ptr<edm::EventPrincipal> evtPtr;
      try {
        HeaderView hdrView(&buf_[0]);
        if (hdrView.code() != Header::EVENT) {
          throw cms::Exception("OnlineHttpReader", "readOneEvent");
        }
        EventMsgView eventView(&buf_[0]);
        evtPtr = deserializeEvent(eventView);
      }
      catch (cms::Exception excpt) {
        const unsigned int MAX_DUMP_LENGTH = 2000;
        std::cout << "========================================" << std::endl;
        std::cout << "* Exception decoding the geteventdata response from the storage manager!" << std::endl;
        if (data.d_.length() <= MAX_DUMP_LENGTH) {
          std::cout << "* Here is the raw text that was returned:" << std::endl;
          std::cout << data.d_ << std::endl;
        }
        else {
          std::cout << "* Here are the first " << MAX_DUMP_LENGTH <<
            " characters of the raw text that was returned:" << std::endl;
          std::cout << (data.d_.substr(0, MAX_DUMP_LENGTH)) << std::endl;
        }
        std::cout << "========================================" << std::endl;
        throw excpt;
      }
      return evtPtr;
    }
  }

std::auto_ptr< edm::EventPrincipal > edm::OnlineHttpReader::read

(

)

[virtual]

Implements edm::StreamerInputSource.

Definition at line 120 of file OnlineHttpReader.cc.

References alreadyRegistered_, consumerId_, getOneEvent(), NULL, readHeader(), registerWithEventServer(), HLT_VtxMuL3::result, runEnded_, and edm::shutdown_flag.

  {
    // on a stop and enable reregister but don't get the header as
    // we cannot change the product registry
    if(!alreadyRegistered_) {
      consumerId_ = (time(0) & 0xffffff);  // temporary - will get from ES later
      registerWithEventServer();
      alreadyRegistered_ = true;
      // we need to fake getting the Header again, but we don't need it
      // TODO: change the requirements in the SM and SMProxy to get an event
      readHeader();
    }
    // repeat a https get every N seconds until we get an event
    // wait for Storage Manager event server buffer to not be empty
    // only way to stop is specify a maxEvents parameter
    // or kill the Storage Manager so the https get fails.

    // try to get an event repeat until we get one, this allows
    // re-registration if the SM is halted or stopped

    bool gotEvent = false;
    std::auto_ptr<EventPrincipal> result(0);
    while ((!gotEvent) && (!runEnded_) && (!edm::shutdown_flag))
    {
       result = getOneEvent();
       if(result.get() != NULL) gotEvent = true;
    }
    // need next line so we only return a null pointer once for each end of run
    if(runEnded_) runEnded_ = false;
    return result;
  }

void edm::OnlineHttpReader::readHeader

(

)

Definition at line 314 of file OnlineHttpReader.cc.

References TestMuL1L2Filter_cff::cerr, consumerId_, convert(), GenMuonPlsPt100GeV_cfg::cout, stor::ReadData::d_, data, edm::StreamerInputSource::deserializeAndMergeWithRegistry(), lat::endl(), Exception, FDEBUG, stor::func(), Header::HEADER_REQUEST, headerRetryInterval_, headerurl_, i, Header::INIT, len, OtherMessageBuilder::msgBody(), NULL, p, stor::setopt(), edm::shutdown_flag, OtherMessageBuilder::size(), and OtherMessageBuilder::startAddress().

Referenced by OnlineHttpReader(), and read().

  {
    // repeat a https get every 5 seconds until we get the registry
    // do it like this for pull mode
    bool alreadySaidWaiting = false;
    stor::ReadData data;
    do {
      CURL* han = curl_easy_init();

      if(han==0)
        {
          cerr << "could not create handle" << endl;
          //return 0; //or use this?
          throw cms::Exception("readHeader","OnlineHttpReader")
            << "Could not get header: probably XDAQ not running on Storage Manager "
            << "\n";
        }

      stor::setopt(han,CURLOPT_URL,headerurl_);
      stor::setopt(han,CURLOPT_WRITEFUNCTION,stor::func);
      stor::setopt(han,CURLOPT_WRITEDATA,&data);

      // 10-Aug-2006, KAB: send our consumer ID as part of the header request
      char msgBuff[100];
      OtherMessageBuilder requestMessage(&msgBuff[0], Header::HEADER_REQUEST,
                                         sizeof(char_uint32));
      uint8 *bodyPtr = requestMessage.msgBody();
      convert(consumerId_, bodyPtr);
      stor::setopt(han, CURLOPT_POSTFIELDS, requestMessage.startAddress());
      stor::setopt(han, CURLOPT_POSTFIELDSIZE, requestMessage.size());
      struct curl_slist *headers=NULL;
      headers = curl_slist_append(headers, "Content-Type: application/octet-stream");
      headers = curl_slist_append(headers, "Content-Transfer-Encoding: binary");
      stor::setopt(han, CURLOPT_HTTPHEADER, headers);

      // send the HTTP POST, read the reply, and cleanup before going on
      CURLcode messageStatus = curl_easy_perform(han);
      curl_slist_free_all(headers);
      curl_easy_cleanup(han);

      if(messageStatus!=0)
      {
        cerr << "curl perform failed for header" << endl;
        // do not retry curl here as we should return to registration instead if we
        // want an automatic recovery
        throw cms::Exception("readHeader","OnlineHttpReader")
          << "Could not get header: probably XDAQ not running on Storage Manager "
          << "\n";
      }
      if(data.d_.length() == 0)
      {
        if(!alreadySaidWaiting) {
          std::cout << "...waiting for header from Storage Manager..." << std::endl;
          alreadySaidWaiting = true;
        }
        // sleep for desired amount of time
        sleep(headerRetryInterval_);
      }
    } while (data.d_.length() == 0 && !edm::shutdown_flag);
    if (edm::shutdown_flag) {
      throw cms::Exception("readHeader","OnlineHttpReader")
          << "The header read was aborted by a shutdown request.\n";
    }

    std::vector<char> regdata(1000*1000);

    // rely on https transfer string of correct length!
    int len = data.d_.length();
    FDEBUG(9) << "OnlineHttpReader received registry len = " << len << std::endl;
    regdata.resize(len);
    for (int i=0; i<len ; i++) regdata[i] = data.d_[i];
    // 21-Jun-2006, KAB:  catch (and re-throw) any exceptions decoding
    // the job header so that we can display the returned HTML and
    // (hopefully) give the user a hint as to the cause of the problem.
    std::auto_ptr<SendJobHeader> p;
    try {
      HeaderView hdrView(&regdata[0]);
      if (hdrView.code() != Header::INIT) {
        throw cms::Exception("OnlineHttpReader", "readHeader");
      }
      InitMsgView initView(&regdata[0]);
      deserializeAndMergeWithRegistry(initView);
    }
    catch (cms::Exception excpt) {
      const unsigned int MAX_DUMP_LENGTH = 1000;
      std::cout << "========================================" << std::endl;
      std::cout << "* Exception decoding the getregdata response from the storage manager!" << std::endl;
      if (data.d_.length() <= MAX_DUMP_LENGTH) {
        std::cout << "* Here is the raw text that was returned:" << std::endl;
        std::cout << data.d_ << std::endl;
      }
      else {
        std::cout << "* Here are the first " << MAX_DUMP_LENGTH <<
          " characters of the raw text that was returned:" << std::endl;
        std::cout << (data.d_.substr(0, MAX_DUMP_LENGTH)) << std::endl;
      }
      std::cout << "========================================" << std::endl;
      throw excpt;
    }
  }

void edm::OnlineHttpReader::registerWithEventServer

(

)

Definition at line 415 of file OnlineHttpReader.cc.

References buf_, TestMuL1L2Filter_cff::cerr, connectTrySleepTime_, consumerId_, consumerName_, consumerPriority_, consumerPSetString_, GenMuonPlsPt100GeV_cfg::cout, stor::ReadData::d_, data, lat::endl(), ConsRegResponseBuilder::ES_NOT_READY, Exception, FDEBUG, stor::func(), headerRetryInterval_, i, len, maxConnectTries_, NULL, stor::setopt(), edm::shutdown_flag, ConsRegRequestBuilder::size(), ConsRegRequestBuilder::startAddress(), and subscriptionurl_.

Referenced by OnlineHttpReader(), and read().

  {
    stor::ReadData data;
    uint32 registrationStatus = ConsRegResponseBuilder::ES_NOT_READY;
    bool alreadySaidWaiting = false;
    do {
      data.d_.clear();
      CURL* han = curl_easy_init();
      if(han==0)
        {
          cerr << "could not create handle" << endl;
          throw cms::Exception("registerWithEventServer","OnlineHttpReader")
            << "Unable to create curl handle\n";
        }

      // set the standard https request options
      stor::setopt(han,CURLOPT_URL,subscriptionurl_);
      stor::setopt(han,CURLOPT_WRITEFUNCTION,stor::func);
      stor::setopt(han,CURLOPT_WRITEDATA,&data);

      // build the registration request message to send to the storage manager
      const int BUFFER_SIZE = 2000;
      char msgBuff[BUFFER_SIZE];
      ConsRegRequestBuilder requestMessage(msgBuff, BUFFER_SIZE, consumerName_,
                                       consumerPriority_, consumerPSetString_);

      // add the request message as a https post
      stor::setopt(han, CURLOPT_POSTFIELDS, requestMessage.startAddress());
      stor::setopt(han, CURLOPT_POSTFIELDSIZE, requestMessage.size());
      struct curl_slist *headers=NULL;
      headers = curl_slist_append(headers, "Content-Type: application/octet-stream");
      headers = curl_slist_append(headers, "Content-Transfer-Encoding: binary");
      stor::setopt(han, CURLOPT_HTTPHEADER, headers);

      // send the HTTP POST, read the reply, and cleanup before going on
      //CURLcode messageStatus = (CURLcode)-1;
      // set messageStatus to a non-zero (but still within CURLcode enum list)
      CURLcode messageStatus = CURLE_COULDNT_CONNECT;
      int tries = 0;
      while (messageStatus!=0 && !edm::shutdown_flag)
      {
        tries++;
        messageStatus = curl_easy_perform(han);
        if ( messageStatus != 0 )
        {
          if ( tries >= maxConnectTries_ )
          {
            std::cerr << "Giving up waiting for connection after " << tries 
                      << " tries"  << std::endl;
            curl_slist_free_all(headers);
            curl_easy_cleanup(han);
            cerr << "curl perform failed for registration" << endl;
            throw cms::Exception("registerWithEventServer","OnlineHttpReader")
              << "Could not register: probably XDAQ not running on Storage Manager "
              << "\n";
          }
          else
          {
            std::cout << "Waiting for connection to StorageManager... " 
                      << tries << "/" << maxConnectTries_
                      << std::endl;
            sleep(connectTrySleepTime_);
          }
        }
      }
      if (edm::shutdown_flag) {
          continue;
      }

      curl_slist_free_all(headers);
      curl_easy_cleanup(han);

      registrationStatus = ConsRegResponseBuilder::ES_NOT_READY;
      if(data.d_.length() > 0)
      {
        int len = data.d_.length();
        FDEBUG(9) << "OnlineHttpReader received len = " << len << std::endl;
        buf_.resize(len);
        for (int i=0; i<len ; i++) buf_[i] = data.d_[i];

        try {
          ConsRegResponseView respView(&buf_[0]);
          registrationStatus = respView.getStatus();
          consumerId_ = respView.getConsumerId();
        }
        catch (cms::Exception excpt) {
          const unsigned int MAX_DUMP_LENGTH = 1000;
          std::cout << "========================================" << std::endl;
          std::cout << "* Exception decoding the registerWithEventServer response!" << std::endl;
          if (data.d_.length() <= MAX_DUMP_LENGTH) {
            std::cout << "* Here is the raw text that was returned:" << std::endl;
            std::cout << data.d_ << std::endl;
          }
          else {
            std::cout << "* Here are the first " << MAX_DUMP_LENGTH <<
              " characters of the raw text that was returned:" << std::endl;
            std::cout << (data.d_.substr(0, MAX_DUMP_LENGTH)) << std::endl;
          }
          std::cout << "========================================" << std::endl;
          throw excpt;
        }
      }

      if (registrationStatus == ConsRegResponseBuilder::ES_NOT_READY)
      {
        if(!alreadySaidWaiting) {
          std::cout << "...waiting for registration response from Storage Manager..." << std::endl;
          alreadySaidWaiting = true;
        }
        // sleep for desired amount of time
        sleep(headerRetryInterval_);
      }
    } while (registrationStatus == ConsRegResponseBuilder::ES_NOT_READY &&
             !edm::shutdown_flag);
    if (edm::shutdown_flag) {
      throw cms::Exception("registerWithEventServer","OnlineHttpReader")
          << "Registration was aborted by a shutdown request.\n";
    }

    FDEBUG(5) << "Consumer ID = " << consumerId_ << endl;
  }

void edm::OnlineHttpReader::setRun

(

RunNumber_t

r

)

[private, virtual]

Reimplemented from edm::StreamerInputSource.

Definition at line 110 of file OnlineHttpReader.cc.

References edm::StreamerInputSource::resetAfterEndRun(), edm::InputSource::resetLuminosityBlockPrincipal(), and edm::InputSource::resetRunPrincipal().

                                             {
     // We do not actually set the run number, just use this hook
     // to do the needed resetting of flags in the EP and this source
     resetAfterEndRun();
     // I think we need the 2 of the 3 lines below as in DAQ source
     //newRun_ = newLumi_ = true;
     resetLuminosityBlockPrincipal();
     resetRunPrincipal();
   }

---

Member Data Documentation

bool edm::OnlineHttpReader::alreadyGotHeader_ [private]

Definition at line 60 of file OnlineHttpReader.h.

Referenced by OnlineHttpReader().

bool edm::OnlineHttpReader::alreadyRegistered_ [private]

Definition at line 59 of file OnlineHttpReader.h.

Referenced by getOneEvent(), OnlineHttpReader(), and read().

bool edm::OnlineHttpReader::alreadySaidHalted_ [private]

Definition at line 58 of file OnlineHttpReader.h.

Referenced by getOneEvent().

Buf edm::OnlineHttpReader::buf_ [private]

Definition at line 46 of file OnlineHttpReader.h.

Referenced by getOneEvent(), and registerWithEventServer().

int edm::OnlineHttpReader::connectTrySleepTime_ [private]

Definition at line 67 of file OnlineHttpReader.h.

Referenced by OnlineHttpReader(), and registerWithEventServer().

unsigned int edm::OnlineHttpReader::consumerId_ [private]

Definition at line 54 of file OnlineHttpReader.h.

Referenced by getOneEvent(), OnlineHttpReader(), read(), readHeader(), and registerWithEventServer().

std::string edm::OnlineHttpReader::consumerName_ [private]

Definition at line 49 of file OnlineHttpReader.h.

Referenced by OnlineHttpReader(), and registerWithEventServer().

std::string edm::OnlineHttpReader::consumerPriority_ [private]

Definition at line 50 of file OnlineHttpReader.h.

Referenced by OnlineHttpReader(), and registerWithEventServer().

std::string edm::OnlineHttpReader::consumerPSetString_ [private]

Definition at line 51 of file OnlineHttpReader.h.

Referenced by OnlineHttpReader(), and registerWithEventServer().

bool edm::OnlineHttpReader::endRunAlreadyNotified_ [private]

Definition at line 56 of file OnlineHttpReader.h.

Referenced by getOneEvent().

char edm::OnlineHttpReader::eventurl_[256] [private]

Definition at line 43 of file OnlineHttpReader.h.

Referenced by getOneEvent(), and OnlineHttpReader().

int edm::OnlineHttpReader::headerRetryInterval_ [private]

Definition at line 52 of file OnlineHttpReader.h.

Referenced by OnlineHttpReader(), readHeader(), and registerWithEventServer().

char edm::OnlineHttpReader::headerurl_[256] [private]

Definition at line 44 of file OnlineHttpReader.h.

Referenced by OnlineHttpReader(), and readHeader().

int edm::OnlineHttpReader::hltBitCount [private]

Definition at line 47 of file OnlineHttpReader.h.

int edm::OnlineHttpReader::l1BitCount [private]

Definition at line 48 of file OnlineHttpReader.h.

struct timeval edm::OnlineHttpReader::lastRequestTime_ [read, private]

Definition at line 55 of file OnlineHttpReader.h.

Referenced by getOneEvent(), and OnlineHttpReader().

int edm::OnlineHttpReader::maxConnectTries_ [private]

Definition at line 66 of file OnlineHttpReader.h.

Referenced by OnlineHttpReader(), and registerWithEventServer().

double edm::OnlineHttpReader::minEventRequestInterval_ [private]

Definition at line 53 of file OnlineHttpReader.h.

Referenced by getOneEvent(), and OnlineHttpReader().

bool edm::OnlineHttpReader::runEnded_ [private]

Definition at line 57 of file OnlineHttpReader.h.

Referenced by getOneEvent(), and read().

std::string edm::OnlineHttpReader::sourceurl_ [private]

Definition at line 42 of file OnlineHttpReader.h.

Referenced by OnlineHttpReader().

char edm::OnlineHttpReader::subscriptionurl_[256] [private]

Definition at line 45 of file OnlineHttpReader.h.

Referenced by OnlineHttpReader(), and registerWithEventServer().

---

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

• EventFilter/StorageManager/src/OnlineHttpReader.h
• EventFilter/StorageManager/src/OnlineHttpReader.cc

---