48{
51 char mbstr[100];
52 time_t now;
53 char* buffer = new char[c_maxBufSize];
54
55 int loop_counter = 0;
56 bool updated = false;
57 while (m_force_exit == 0) {
58 fflush(stdout);
59 int exam_stat = m_man->examine();
60 if (exam_stat == 0) {
61 } else if (exam_stat == 1) {
62
63 vector<int>& recvsock = m_man->connected_socket_list();
64 for (vector<int>::iterator it = recvsock.begin();
65 it != recvsock.end(); ++it) {
66 int fd = *it;
67 if (m_man->connected(fd)) {
68 int is = sio.get(fd, buffer, c_maxBufSize);
69 if (is <= 0) {
70 now = time(0);
71 strftime(mbstr, sizeof(mbstr), "%c", localtime(&now));
72 printf("[%s] HistoServer: fd %d disconnected\n", mbstr, fd);
73 m_man->remove(fd);
74 break;
75 }
76 updated = true;
77
78
80 vector<TObject*> objlist;
81 vector<string> strlist;
82 msghdl.decode_msg(hmsg, objlist, strlist);
83 int nobjs = (hmsg->
header())->reserved[1];
84
85 string subdir = "";
86 now = time(0);
87 strftime(mbstr, sizeof(mbstr), "%c", localtime(&now));
88 printf("[%s] HistoServer : received nobjs = %d\n", mbstr, nobjs);
89 for (int i = 0; i < nobjs; i++) {
90
91
92 string objname = strlist.at(i);
93 if (objname == string("DQMRC:CLEAR")) {
94 m_hman->clear();
95 m_hman->merge();
96 now = time(0);
97 strftime(mbstr, sizeof(mbstr), "%c", localtime(&now));
98 printf("[%s] HistoServer: CLEAR\n", mbstr);
99 updated = false;
100 continue;
101 }
102 if (objname == string("DQMRC:MERGE")) {
103 m_hman->merge();
104 now = time(0);
105 strftime(mbstr, sizeof(mbstr), "%c", localtime(&now));
106 printf("[%s] HistoServer: MERGE\n", mbstr);
107 updated = false;
108 continue;
109 }
110 auto lpos = objname.find("DQMRC:SAVE:");
111 if (lpos != string::npos) {
112 auto filename = objname.substr(11);
113 m_hman->filedump(filename);
114 continue;
115 }
116 lpos = objname.find("SUBDIR:");
117 if (lpos != string::npos) {
118 subdir = objname.substr(7);
119 if (subdir == "EXIT") subdir = "";
120
121 } else {
122 m_hman->update(subdir, strlist.at(i), fd, (TH1*)objlist.at(i));
123 }
124 }
125 }
126 }
127 }
128 usleep(1000);
129 loop_counter++;
130 if (loop_counter % c_mergeIntervall == 0 && updated) {
131 now = time(0);
132 strftime(mbstr, sizeof(mbstr), "%c", localtime(&now));
133 printf("[%s] HistoServer: merging histograms\n", mbstr);
134
135 m_hman->merge();
136
137 updated = false;
138 }
139 }
140 return 0;
141}
Class to manage streamed object.
EvtHeader * header()
Get pointer to EvtHeader.
A class to encode/decode an EvtMessage.
1.9.6