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