11 #include <dqm/analysis/modules/DQMHistAnalysisOutputRelayMsg.h>
35 addParam(
"Hostname", m_hostname,
"Hostname of THTTP", std::string(
"localhost"));
36 addParam(
"Port", m_port,
"Port number to THTTP", 9191);
37 B2DEBUG(20,
"DQMHistAnalysisOutputRelayMsg: Constructor done.");
41 DQMHistAnalysisOutputRelayMsgModule::~DQMHistAnalysisOutputRelayMsgModule() { }
43 void DQMHistAnalysisOutputRelayMsgModule::initialize()
45 if (m_sock !=
nullptr)
delete m_sock;
46 m_sock =
new TSocket(m_hostname.c_str(), m_port);
47 B2DEBUG(20,
"DQMHistAnalysisOutputRelayMsg: initialized.");
51 void DQMHistAnalysisOutputRelayMsgModule::beginRun()
53 B2DEBUG(20,
"DQMHistAnalysisOutputRelayMsg: beginRun called.");
57 void DQMHistAnalysisOutputRelayMsgModule::event()
59 B2DEBUG(20,
"DQMHistAnalysisOutputRelayMsg: event called.");
60 TMessage mess(kMESS_OBJECT);
62 TSeqCollection* seq = gROOT->GetListOfCanvases();
68 strftime(mbstr,
sizeof(mbstr),
"%c", localtime(&now));
70 B2INFO(
"[" << mbstr <<
"] before sending " << seq->GetEntries() <<
" objects.");
71 bool first_try =
true;
72 while ((obj = (TObject*)nextkey())) {
73 if (obj->IsA()->InheritsFrom(
"TCanvas")) {
74 TCanvas* c = (TCanvas*) obj;
77 if (m_sock->Send(mess) < 0) {
85 m_sock =
new TSocket(m_hostname.c_str(), m_port);
87 if (m_sock->Send(mess) < 0) {
95 strftime(mbstr,
sizeof(mbstr),
"%c", localtime(&now));
96 B2INFO(
"[" << mbstr <<
"] after sending " << seq->GetEntries() <<
" objects.");
99 void DQMHistAnalysisOutputRelayMsgModule::endRun()
101 B2DEBUG(20,
"DQMHistAnalysisOutputRelayMsg: endRun called");
105 void DQMHistAnalysisOutputRelayMsgModule::terminate()
107 B2DEBUG(20,
"DQMHistAnalysisOutputRelayMsg: terminate called");