1 /**************************************************************************
2 * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
4 * Author: The ALICE Off-line Project. *
5 * Contributors are mentioned in the code where appropriate. *
7 * Permission to use, copy, modify and distribute this software and its *
8 * documentation strictly for non-commercial purposes is hereby granted *
9 * without fee, provided that the above copyright notice appears in all *
10 * copies and that both the copyright notice and this permission notice *
11 * appear in the supporting documentation. The authors make no claims *
12 * about the suitability of this software for any purpose. It is *
13 * provided "as is" without express or implied warranty. *
14 **************************************************************************/
16 ///////////////////////////////////////////////////////////////////////////////
18 /// This is a class for reading raw data from a date monitoring libraries.
19 /// It supports two modes - event taken from shared memory via DATE monitoring
20 /// libs, or an emulation mode when the events are taken from a DATE file using
21 /// the same monitoring libs.
22 /// The constructor requires an argument:
24 /// : - events are taken from shared memory
26 /// <DATE_filename> - events are taken from date file
28 /// Cvetan Cheshkov 1/04/2008
29 ///////////////////////////////////////////////////////////////////////////////
32 #include "AliRawReaderDateOnline.h"
39 ClassImp(AliRawReaderDateOnline)
41 AliRawReaderDateOnline::AliRawReaderDateOnline(
45 const char* /* filename */
48 AliRawReaderDate((void*)NULL),
53 // Initialize the DATE monitoring libs
58 // Removal of the selection of physics events
59 // Requested by Filimon and FMD experts
60 // fSelectEventType = PHYSICS_EVENT;
64 /* define data source : this is argument 1 */
65 status=monitorSetDataSource( (char* )filename );
67 AliFatal(Form("monitorSetDataSource() failed : %s",monitorDecodeError(status)));
70 /* declare monitoring program */
71 status=monitorDeclareMp( __FILE__ );
73 AliFatal(Form("monitorDeclareMp() failed : %s",monitorDecodeError(status)));
76 /* define wait event timeout - 1s max */
78 monitorSetNoWaitNetworkTimeout(1000);
80 const Char_t* table[] = {"ALL", "yes", "*", "*",
81 "EOR", "all","*", "*",
82 NULL, NULL, NULL, NULL};
83 monitorDeclareTableExtended(const_cast<char**>(table));
85 // install SIGUSR1 handler to allow clean end-of-events loop
86 gSystem->AddSignalHandler(new AliRawReaderDateIntHandler(this));
89 Fatal("AliRawReaderDateOnline", "this class was compiled without DATE");
93 Bool_t AliRawReaderDateOnline::NextEvent()
95 // wait and get the next event
102 AliInfo("Raw-data reading stopped by SIGUSR1");
103 if (fEvent) free(fEvent);
108 // Event already loaded no need take a new one
109 if (AliRawReaderDate::NextEvent()) return kTRUE;
111 if (fEvent) free(fEvent);
115 /* get next event (blocking call until timeout) */
116 int status=monitorGetEventDynamic((void**)&fEvent);
118 if (status==MON_ERR_EOF) {
119 AliInfo("End of File detected");
122 return kFALSE; /* end of monitoring file has been reached */
126 AliError(Form("monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status)));
132 /* retry if got no event */
137 eventTypeType eventT=fEvent->eventType;
138 /* exit when last event received, no need to wait for TERM signal */
139 if (eventT==END_OF_RUN) {
140 AliInfo("EOR event detected");
147 if (!IsEventSelected()) {
153 AliInfo(Form("Run #%lu, event size: %lu, BC:0x%x, Orbit:0x%x, Period:0x%x",
154 (unsigned long)fEvent->eventRunNb,
155 (unsigned long)fEvent->eventSize,
156 EVENT_ID_GET_BUNCH_CROSSING(fEvent->eventId),
157 EVENT_ID_GET_ORBIT(fEvent->eventId),
158 EVENT_ID_GET_PERIOD(fEvent->eventId)
175 AliRawReaderDateOnline::~AliRawReaderDateOnline()
178 // Free the last event in shared memory
181 if (fEvent) free(fEvent);
185 void AliRawReaderDateOnline::SelectEvents(Int_t type,
186 ULong64_t triggerMask,
187 const char *triggerExpr)
189 // Select event by using DATE monitoring
192 const Char_t* table[] = {"ALL", "no", "*", "*",
193 "PHY", "yes","*", "*",
194 "EOR", "all","*", "*",
195 NULL, NULL, NULL, NULL};
197 for (Int_t i = 0; i < 50; i++) {
198 if (triggerMask & (1ull << i)) {
199 if (!trSelection.IsNull()) trSelection += "&";
200 trSelection += Form("%d",i+1);
203 table[7] = trSelection.Data();
205 monitorDeclareTableExtended(const_cast<char**>(table));
208 AliRawReader::SelectEvents(type,triggerMask,triggerExpr);
211 //______________________________________________________________________________
212 void AliRawReaderDateOnline::Stop()
214 // Stop the event loop (called on SIGUSR1)