|
|
|
#include <EventServerProxy.h>
Retrieve events from the Storage Manager event server.
This does uses a HTTP get using the CURL library. The Storage Manager event server responses with a binary octet-stream. The init message is also obtained through a HTTP get.
Definition at line 35 of file EventServerProxy.h.
| stor::EventServerProxy< RegInfo >::EventServerProxy | ( | edm::ParameterSet const & | ) |
| virtual stor::EventServerProxy< RegInfo >::~EventServerProxy | ( | ) | [inline, virtual] |
Definition at line 41 of file EventServerProxy.h.
{};
| void stor::EventServerProxy< RegInfo >::checkEvent | ( | CurlInterface::Content & | ) | [private] |
| void stor::EventServerProxy< RegInfo >::checkInitMsg | ( | CurlInterface::Content & | ) | [private] |
| void stor::EventServerProxy< EventConsumerRegistrationInfo >::checkInitMsg | ( | CurlInterface::Content & | data | ) | [inline, private] |
Definition at line 138 of file EventServerProxy.h.
References HeaderView::code(), ExpressReco_HICollisions_FallBack::dump, Exception, and Header::INIT.
{
try {
HeaderView hdrView(&data[0]);
if (hdrView.code() != Header::INIT) {
throw cms::Exception("EventServerProxy", "readHeader");
}
}
catch (cms::Exception excpt) {
const unsigned int MAX_DUMP_LENGTH = 1000;
std::ostringstream dump;
dump << "========================================" << std::endl;
dump << "* Exception decoding the getregdata response from the event server!" << std::endl;
if (data.size() <= MAX_DUMP_LENGTH)
{
dump << "* Here is the raw text that was returned:" << std::endl;
dump << std::string(&data[0]) << std::endl;
}
else
{
dump << "* Here are the first " << MAX_DUMP_LENGTH <<
" characters of the raw text that was returned:" << std::endl;
dump << std::string(&data[0], MAX_DUMP_LENGTH) << std::endl;
}
dump << "========================================" << std::endl;
edm::LogError("EventServerProxy") << dump.str();
throw excpt;
}
}
| void stor::EventServerProxy< RegInfo >::connectToEventServer | ( | CurlInterface::Content & | ) | [private] |
| bool stor::EventServerProxy< RegInfo >::extractConsumerId | ( | CurlInterface::Content & | ) | [private] |
| bool stor::EventServerProxy< RegInfo >::getEventMaybe | ( | CurlInterface::Content & | data | ) |
Try to get one event from the event server. If succesful, returns true.
| void stor::EventServerProxy< EventConsumerRegistrationInfo >::getInitMsg | ( | CurlInterface::Content & | data | ) | [inline] |
Definition at line 171 of file EventServerProxy.h.
References Exception, and edm::shutdown_flag.
{
do
{
data.clear();
getInitMsgFromEventServer(data);
}
while ( !edm::shutdown_flag && data.empty() );
if (edm::shutdown_flag) {
throw cms::Exception("readHeader","EventServerProxy")
<< "The header read was aborted by a shutdown request.\n";
}
checkInitMsg(data);
}
| void stor::EventServerProxy< RegInfo >::getInitMsg | ( | CurlInterface::Content & | data | ) |
Get the init message from the the event server.
Referenced by edm::EventStreamHttpReader::readHeader().
| void stor::EventServerProxy< EventConsumerRegistrationInfo >::getInitMsgFromEventServer | ( | CurlInterface::Content & | data | ) | [inline, private] |
Definition at line 89 of file EventServerProxy.h.
References lhef::cc::convert(), runTheMatrix::data, Header::HEADER_REQUEST, OtherMessageBuilder::msgBody(), stor::CurlInterface::postBinaryMessage(), query::result, OtherMessageBuilder::size(), stor::utils::sleep(), and OtherMessageBuilder::startAddress().
{
// build the header request message to send to the event server
char msgBuff[100];
OtherMessageBuilder requestMessage(
&msgBuff[0],
Header::HEADER_REQUEST,
sizeof(char_uint32)
);
uint8 *bodyPtr = requestMessage.msgBody();
convert(consumerId_, bodyPtr);
// send the header request
stor::CurlInterface curl;
CURLcode result = curl.postBinaryMessage(
regInfo_.sourceURL() + "/getregdata",
requestMessage.startAddress(),
requestMessage.size(),
data
);
if ( result != CURLE_OK )
{
// connection failed: try to reconnect
edm::LogError("EventServerProxy") << "curl perform failed for header:"
<< std::string(&data[0]) << std::endl
<< ". Trying to reconnect.";
data.clear();
registerWithEventServer();
}
if( data.empty() )
{
if(!alreadySaidWaiting_) {
edm::LogInfo("EventServerProxy") << "...waiting for header from event server...";
alreadySaidWaiting_ = true;
}
// sleep for desired amount of time
::sleep(regInfo_.headerRetryInterval());
}
else
{
alreadySaidWaiting_ = false;
}
}
| void stor::EventServerProxy< RegInfo >::getInitMsgFromEventServer | ( | CurlInterface::Content & | ) | [private] |
| void stor::EventServerProxy< RegInfo >::getOneEvent | ( | CurlInterface::Content & | data | ) |
Get one event from the event server.
Referenced by edm::EventStreamHttpReader::read(), and edm::DQMHttpSource::readOneEvent().
| void stor::EventServerProxy< RegInfo >::getOneEventFromEventServer | ( | CurlInterface::Content & | ) | [private] |
| void stor::EventServerProxy< RegInfo >::registerWithEventServer | ( | ) | [private] |
bool stor::EventServerProxy< RegInfo >::alreadySaidHalted_ [private] |
Definition at line 75 of file EventServerProxy.h.
bool stor::EventServerProxy< RegInfo >::alreadySaidWaiting_ [private] |
Definition at line 76 of file EventServerProxy.h.
unsigned int stor::EventServerProxy< RegInfo >::consumerId_ [private] |
Definition at line 71 of file EventServerProxy.h.
unsigned int stor::EventServerProxy< RegInfo >::failedAttemptsToGetData_ [private] |
Definition at line 77 of file EventServerProxy.h.
const stor::utils::Duration_t stor::EventServerProxy< RegInfo >::minEventRequestInterval_ [private] |
Definition at line 73 of file EventServerProxy.h.
stor::utils::TimePoint_t stor::EventServerProxy< RegInfo >::nextRequestTime_ [private] |
Definition at line 72 of file EventServerProxy.h.
const RegInfo stor::EventServerProxy< RegInfo >::regInfo_ [private] |
Definition at line 70 of file EventServerProxy.h.
1.7.3