Removal of the default physics event selection. Requested by Filimon and FMD experts...
[u/mrichter/AliRoot.git] / RAW / AliRawReaderDateOnline.cxx
CommitLineData
3b98a4d4 1/**************************************************************************
2 * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
3 * *
4 * Author: The ALICE Off-line Project. *
5 * Contributors are mentioned in the code where appropriate. *
6 * *
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 **************************************************************************/
15
16///////////////////////////////////////////////////////////////////////////////
17///
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:
23///
24/// : - events are taken from shared memory
25/// or
26/// <DATE_filename> - events are taken from date file
27///
28/// Cvetan Cheshkov 1/04/2008
29///////////////////////////////////////////////////////////////////////////////
30
31#include "AliRawReaderDateOnline.h"
36a7d3c6 32#include "AliLog.h"
33#ifdef ALI_DATE
34#include "event.h"
35#include "monitor.h"
36#endif
3b98a4d4 37
38ClassImp(AliRawReaderDateOnline)
39
36a7d3c6 40AliRawReaderDateOnline::AliRawReaderDateOnline(
3b98a4d4 41#ifdef ALI_DATE
42 const char* filename
43#else
44 const char* /* filename */
45#endif
46 ) :
36a7d3c6 47 AliRawReaderDate((void*)NULL)
3b98a4d4 48{
49
50// Constructor
51// Initialize the DATE monitoring libs
52
53#ifdef ALI_DATE
54
b2d2e1ea 55
56 // Removal of the selection of physics events
57 // Requested by Filimon and FMD experts
58 // fSelectEventType = PHYSICS_EVENT;
00665a00 59
3b98a4d4 60 int status;
61
62 /* define data source : this is argument 1 */
36a7d3c6 63 status=monitorSetDataSource( (char* )filename );
3b98a4d4 64 if (status!=0) {
65 AliFatal(Form("monitorSetDataSource() failed : %s",monitorDecodeError(status)));
66 }
67
68 /* declare monitoring program */
69 status=monitorDeclareMp( __FILE__ );
70 if (status!=0) {
71 AliFatal(Form("monitorDeclareMp() failed : %s",monitorDecodeError(status)));
72 }
73
74 /* define wait event timeout - 1s max */
75 monitorSetNowait();
76 monitorSetNoWaitNetworkTimeout(1000);
77
78#else
79 Fatal("AliRawReaderDateOnline", "this class was compiled without DATE");
80#endif
81}
82
36a7d3c6 83Bool_t AliRawReaderDateOnline::NextEvent()
3b98a4d4 84{
85// wait and get the next event
86// from shared memory
87
88#ifdef ALI_DATE
89
36a7d3c6 90 // Event already loaded no need take a new one
91 if (AliRawReaderDate::NextEvent()) return kTRUE;
92
3b98a4d4 93 if (fEvent) free(fEvent);
36a7d3c6 94 fEvent = NULL;
3b98a4d4 95
96 while (1) {
97 /* get next event (blocking call until timeout) */
36a7d3c6 98 int status=monitorGetEventDynamic((void**)&fEvent);
3b98a4d4 99
00665a00 100 if (status==MON_ERR_EOF) {
3b98a4d4 101 AliInfo("End of File detected");
36a7d3c6 102 Reset();
103 fEvent = NULL;
3b98a4d4 104 return kFALSE; /* end of monitoring file has been reached */
105 }
106
107 if (status!=0) {
108 AliError(Form("monitorGetEventDynamic() failed : %s\n",monitorDecodeError(status)));
36a7d3c6 109 Reset();
110 fEvent = NULL;
3b98a4d4 111 return kFALSE;
112 }
113
114 /* retry if got no event */
36a7d3c6 115 if (fEvent==NULL) {
3b98a4d4 116 continue;
117 }
36a7d3c6 118
119 eventTypeType eventT=fEvent->eventType;
3b98a4d4 120 /* exit when last event received, no need to wait for TERM signal */
121 if (eventT==END_OF_RUN) {
122 AliInfo("EOR event detected");
36a7d3c6 123 Reset();
124 fEvent = NULL;
3b98a4d4 125 return kFALSE;
126 }
36a7d3c6 127
00665a00 128 if (!IsEventSelected()) {
3b98a4d4 129 continue;
130 }
131
00665a00 132 AliInfo(Form("Run #%lu, event size: %lu, BC:0x%x, Orbit:0x%x, Period:0x%x",
36a7d3c6 133 (unsigned long)fEvent->eventRunNb,
134 (unsigned long)fEvent->eventSize,
135 EVENT_ID_GET_BUNCH_CROSSING(fEvent->eventId),
136 EVENT_ID_GET_ORBIT(fEvent->eventId),
137 EVENT_ID_GET_PERIOD(fEvent->eventId)
3b98a4d4 138 ));
36a7d3c6 139 break;
3b98a4d4 140 }
141
36a7d3c6 142 fEventNumber++;
143 Reset();
3b98a4d4 144
36a7d3c6 145 return kTRUE;
3b98a4d4 146
36a7d3c6 147}
148
149#else
3b98a4d4 150 return kFALSE;
151}
36a7d3c6 152#endif
3b98a4d4 153
36a7d3c6 154AliRawReaderDateOnline::~AliRawReaderDateOnline()
155{
156// Destructor
157// Free the last event in shared memory
3b98a4d4 158
36a7d3c6 159#ifdef ALI_DATE
160 if (fEvent) free(fEvent);
161#endif
162}