Belle II Software release-09-00-04
Public Member Functions | Static Public Attributes | Private Attributes | List of all members
RFDqmServer Class Reference
Packages » daq
Inheritance diagram for RFDqmServer:
Inheritance graph
[legend]
Collaboration diagram for RFDqmServer:
Collaboration graph
[legend]

Public Member Functions

 RFDqmServer (std::string conffile)
 
int Configure (NSMmsg *, NSMcontext *) override
 
int UnConfigure (NSMmsg *, NSMcontext *) override
 
int Start (NSMmsg *, NSMcontext *) override
 
int Stop (NSMmsg *, NSMcontext *) override
 
int Restart (NSMmsg *, NSMcontext *) override
 
void server ()
 
void cleanup ()
 
virtual int Pause (NSMmsg *, NSMcontext *)
 
virtual int Resume (NSMmsg *, NSMcontext *)
 
virtual int Status (NSMmsg *, NSMcontext *)
 
virtual void SetNodeInfo (RfNodeInfo *ptr)
 
virtual RfNodeInfo * GetNodeInfo ()
 

Static Public Attributes

static RFServerBase * s_instance
 

Private Attributes

RFConf * m_conf
 
RFProcessManager * m_proc
 
RFLogManager * m_log
 
int m_pid_dqm
 
int m_pid_relay
 
int m_expno
 
int m_runno
 
RfNodeInfo * m_nsmmem
 

Detailed Description

Definition at line 27 of file RFDqmServer.h.

Constructor & Destructor Documentation

◆ RFDqmServer()

RFDqmServer ( std::string  conffile)

Definition at line 21 of file RFDqmServer.cc.

22{
23 // 0. Initialize configuration manager
24 m_conf = new RFConf(conffile.c_str());
25 char* nodename = m_conf->getconf("dqmserver", "nodename");
26 // char nodename[256];
27 // gethostname ( nodename, sizeof(nodename) );
28
29 // 1. Set execution directory
30 string execdir = string(m_conf->getconf("system", "execdir_base")) + "/dqmserver";
31
32 mkdir(execdir.c_str(), 0755);
33 chdir(execdir.c_str());
34
35 // 2. Initialize process manager
36 m_proc = new RFProcessManager(nodename);
37
38 // 3. Initialize LogManager
39 m_log = new RFLogManager(nodename, m_conf->getconf("system", "lognode"));
40}

◆ ~RFDqmServer()

~RFDqmServer ( )

Definition at line 42 of file RFDqmServer.cc.

43{
44 delete m_log;
45 delete m_proc;
46 delete m_conf;
47}

Member Function Documentation

◆ cleanup()

void cleanup ( )

Definition at line 209 of file RFDqmServer.cc.

210{
211 printf("RFDqmServer : cleaning up\n");
212 UnConfigure(NULL, NULL);
213 printf("RFDqmServer: Done. Exitting\n");
214 exit(-1);
215}

◆ Configure()

int Configure ( NSMmsg *  ,
NSMcontext *   
)
overridevirtual

Reimplemented from RFServerBase.

Definition at line 51 of file RFDqmServer.cc.

52{
53 // 1. Run DqmSever
54 char* dqmserver = m_conf->getconf("dqmserver", "script");
55 char* port = m_conf->getconf("dqmserver", "port");
56 char* mapfile = m_conf->getconf("dqmserver", "mapfile");
57
58 m_pid_dqm = m_proc->Execute(dqmserver, port, mapfile);
59
60 // 2. Run Dqm Histogram Relay
61 char* relayhost = m_conf->getconf("dqmserver", "historelay", "host");
62 char* relayport = m_conf->getconf("dqmserver", "historelay", "port");
63 char* hrelay = m_conf->getconf("dqmserver", "historelay", "script");
64 char* interval = m_conf->getconf("dqmserver", "historelay", "interval");
65
66 if (strcmp(relayhost, "none") != 0) {
67 printf("DqmServer : command = %s %s %s %s %s\n",
68 hrelay, mapfile, relayhost, relayport, interval);
69 m_pid_relay = m_proc->Execute(hrelay, mapfile, relayhost, relayport,
70 interval);
71 }
72
73 return 0;
74
75}
Belle2::RFProcessManager::Execute
int Execute(char *script, int nargs, char **args)
Definition: RFProcessManager.cc:55

◆ GetNodeInfo()

virtual RfNodeInfo * GetNodeInfo ( )
inlinevirtualinherited

Definition at line 38 of file RFServerBase.h.

39 {
40 return m_nsmmem;
41 };

◆ Pause()

virtual int Pause ( NSMmsg *  ,
NSMcontext *   
)
inlinevirtualinherited

Definition at line 28 of file RFServerBase.h.

28{ return 0; };

◆ Restart()

int Restart ( NSMmsg *  ,
NSMcontext *   
)
overridevirtual

Reimplemented from RFServerBase.

Definition at line 167 of file RFDqmServer.cc.

168{
169 printf("RFDqmServer : Restarted!!!!!\n");
170 /* Original Impl
171 if (m_pid_dqm != 0) {
172 kill(m_pid_dqm, SIGINT);
173 }
174 system("killall hrelay hserver");
175 fflush(stdout);
176 */
177
178 NSMmsg* nsmmsg = NULL;
179 NSMcontext* nsmcontext = NULL;
180 RFDqmServer::UnConfigure(nsmmsg, nsmcontext);
181 sleep(2);
182 RFDqmServer::Configure(nsmmsg, nsmcontext);
183 return 0;
184}
NSMcontext_struct
Definition: nsmlib2.h:71
NSMmsg
Definition: nsm2.h:224

◆ Resume()

virtual int Resume ( NSMmsg *  ,
NSMcontext *   
)
inlinevirtualinherited

Definition at line 29 of file RFServerBase.h.

29{ return 0; };

◆ server()

void server ( )

Definition at line 188 of file RFDqmServer.cc.

189{
190 while (true) {
191 pid_t pid = m_proc->CheckProcess();
192 if (pid > 0) {
193 printf("RFDqmServer : process dead. pid=%d\n", pid);
194 if (pid == m_pid_dqm)
195 m_log->Error("RFDqmServer : Hserver process dead. pid=%d\n", pid);
196 else if (pid == m_pid_relay)
197 m_log->Error("RFDqmServer : Hrelay process dead. pid=%d\n", pid);
198 }
199 int st = m_proc->CheckOutput();
200 if (st < 0) {
201 perror("RFDqmServer::server");
202 // exit ( -1 );
203 } else if (st > 0) {
204 m_log->ProcessLog(m_proc->GetFd());
205 }
206 }
207}

◆ SetNodeInfo()

virtual void SetNodeInfo ( RfNodeInfo *  ptr)
inlinevirtualinherited

Definition at line 33 of file RFServerBase.h.

34 {
35 m_nsmmem = ptr;
36 };

◆ Start()

int Start ( NSMmsg *  msgm,
NSMcontext *   
)
overridevirtual

Reimplemented from RFServerBase.

Definition at line 119 of file RFDqmServer.cc.

120{
121 m_expno = msgm->pars[0];
122 m_runno = msgm->pars[1];
123 printf("DqmServer : Started. Exp = %d, Run = %d\n", m_expno, m_runno);
124 return 0;
125}

◆ Status()

virtual int Status ( NSMmsg *  ,
NSMcontext *   
)
inlinevirtualinherited

Definition at line 31 of file RFServerBase.h.

31{ return 0; };

◆ Stop()

int Stop ( NSMmsg *  ,
NSMcontext *   
)
overridevirtual

Reimplemented from RFServerBase.

Definition at line 127 of file RFDqmServer.cc.

128{
129 // Wait 10 sec. for basf2 completion
130 printf("DqmServer : waiting 10 sec. for basf2 completion\n");
131 sleep(10);
132
133 // Store histogram files
134 char blank[] = "";
135 char* merger = m_conf->getconf("dqmserver", "merger");
136 char* topdir = m_conf->getconf("system", "execdir_base");
137 char* nodebase = m_conf->getconf("processor", "nodebase");
138 char* nnodes = m_conf->getconf("processor", "nnodes");
139 char* startnode = m_conf->getconf("processor", "idbase");
140 char* badlist = m_conf->getconf("processor", "badlist");
141 if (badlist == NULL)
142 badlist = blank;
143
144 int colpid = fork();
145 if (colpid == 0) {
146 char outfile[1024];
147 // sprintf(outfile, "dqm_e%4.4dr%6.6d.root", msg->pars[0], msg->pars[1]);
148 sprintf(outfile, "dqm_e%4.4dr%6.6d.root", m_expno, m_runno);
149 // Double fork to avoid zombie
150 int dblpid = fork();
151 if (dblpid == 0) {
152 m_proc->Execute(merger, outfile, nodebase, topdir, nnodes, startnode, badlist);
153 exit(0);
154 }
155 exit(0); // Exit mother of double fork
156 }
157 // Wait for the completion of mother
158 int status;
159 waitpid(colpid, &status, 0);
160
161 printf("DqmServer : Stopped.\n");
162
163 return 0;
164}

◆ UnConfigure()

int UnConfigure ( NSMmsg *  ,
NSMcontext *   
)
overridevirtual

Reimplemented from RFServerBase.

Definition at line 77 of file RFDqmServer.cc.

78{
79
80 // Wait 10 sec. for basf2 completion
81 printf("DqmServer : waiting 10 sec. for basf2 completion\n");
82 sleep(10);
83
84 // Store histograms in the file (make sure all event processes are stopped already)
85 m_conf->getconf("dqmserver", "merger");
86 m_conf->getconf("system", "execdir_base");
87 m_conf->getconf("processor", "nodebase");
88 m_conf->getconf("processor", "nnodes");
89 m_conf->getconf("processor", "idbase");
90 m_conf->getconf("processor", "badlist");
91
92
93 /* Should be done at STOP
94 char outfile[1024];
95 // sprintf(outfile, "dqm_e%4.4dr%6.6d.root", msg->pars[0], msg->pars[1]);
96 sprintf(outfile, "dqm_e%4.4dr%6.6d.root", m_expno, m_runno);
97 int pid_dqmmerge = m_proc->Execute(merger, outfile, nodebase, topdir, nnodes, startnode, badlist);
98 int status;
99 pid_t done = waitpid(pid_dqmmerge, &status, 0);
100 */
101
102 // Kill DQM hrelay and hserver
103 // system("killall hrelay hserver");
104 if (m_pid_dqm != 0) {
105 int status;
106 kill(m_pid_dqm, SIGINT);
107 waitpid(m_pid_dqm, &status, 0);
108 }
109 if (m_pid_relay != 0) {
110 int status;
111 kill(m_pid_relay, SIGINT);
112 waitpid(m_pid_relay, &status, 0);
113 }
114
115 printf("DqmServer : Unconfigure done\n");
116 return 0;
117}

Member Data Documentation

◆ m_conf

RFConf* m_conf
private

Definition at line 46 of file RFDqmServer.h.

◆ m_expno

int m_expno
private

Definition at line 53 of file RFDqmServer.h.

◆ m_log

RFLogManager* m_log
private

Definition at line 48 of file RFDqmServer.h.

◆ m_nsmmem

RfNodeInfo* m_nsmmem
privateinherited

Definition at line 47 of file RFServerBase.h.

◆ m_pid_dqm

int m_pid_dqm
private

Definition at line 50 of file RFDqmServer.h.

◆ m_pid_relay

int m_pid_relay
private

Definition at line 51 of file RFDqmServer.h.

◆ m_proc

RFProcessManager* m_proc
private

Definition at line 47 of file RFDqmServer.h.

◆ m_runno

int m_runno
private

Definition at line 54 of file RFDqmServer.h.

◆ s_instance

RFServerBase* s_instance
staticinherited

Definition at line 44 of file RFServerBase.h.

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