Belle II Software  release-05-01-25
HistoRelay.cc
1 //+
2 // File : HistoRelay.cc
3 // Description : Read Histograms in a TMapFile periodically and
4 // relay them to HistoServer
5 //
6 // Author : Ryosuke Itoh, IPNS, KEK
7 // Date : 3 - Sep - 2013
8 //-
9 
10 #include "daq/dqm/HistoRelay.h"
11 
12 #include <framework/pcore/EvtMessage.h>
13 #include <framework/pcore/MsgHandler.h>
14 
15 using namespace Belle2;
16 using namespace std;
17 
18 HistoRelay::HistoRelay(string& file, string& dest, int port)
19 {
20  // m_map = TMapFile::Create(file.c_str());
21  m_memfile = new DqmMemFile(file);
22  m_sock = new EvtSocketSend(dest.c_str(), port);
23  // m_msg = new MsgHandler(0);
24 }
25 
26 HistoRelay::~HistoRelay()
27 {
28  delete m_sock;
29  delete m_msg;
30 }
31 
32 int HistoRelay::collect()
33 {
34  // printf ( "HistoRelay : collect!!\n" );
35  // m_map = TMapFile::Create(m_filename.c_str());
36  EvtMessage* msg = m_memfile->StreamMemFile();
37 
38  /* Old Impl.
39  EvtMessage* msg = m_msg->encode_msg(MSG_EVENT);
40 
41  (msg->header())->reserved[0] = 0;
42  (msg->header())->reserved[1] = nobjs;
43  (msg->header())->reserved[2] = 0;
44 
45  // printf("HistoRelay : Sending %d histograms\n", nobjs);
46  */
47 
48  m_sock->send(msg);
49 
50  delete(msg);
51 
52  return 0;
53 }
Belle2::EvtSocketSend
Definition: EvtSocket.h:26
Belle2::EvtMessage
Class to manage streamed object.
Definition: EvtMessage.h:60
Belle2
Abstract base class for different kinds of events.
Definition: MillepedeAlgorithm.h:19
Belle2::DqmMemFile
Definition: DqmMemFile.h:28