}
-
+///____________________________________________________________
ULong64_t AliEveEventBufferHomer::GetEventIdFromSource() {
- ///
+ ///see header file for documentation
return fHomer->GetEventID();
}
if(fHomer) {
cout << "calling nexthomerevent"<<endl;
TList * blockList = fHomer->NextHOMEREvent();
-
+ cout << "getting async block list"<<endl;
+ TList * aList = fHomer->GetAsyncBlockList();
+ fAsyncList = aList;
if(blockList) return dynamic_cast<TObject*>(blockList);
else return NULL;
}
///___________________________________________________________________________
void AliEveEventBufferHomer::AddToBuffer(TObject * event) {
- cout << "Add to buffer"<<endl;
- if(!event) return;
+ cout << "AliEveEventBufferHomer::Add to buffer"<<endl;
+ if(!event) {
+ cout << "event is NULL pointer, return" << endl;
+ return;
+ }
+
+
+ TList * listIn = dynamic_cast<TList*>(event);
+ if(!listIn || !(listIn->GetSize() > 0)) {
+ cout << "AliEveEventBufferHomer::AddToBuffer(): List Is empty, not added to buffer!"<<endl;
+ return;
+ }
+
fBIndex[kTop] = CalculateNext(fBIndex[kTop]);
TList * list = dynamic_cast<TList*>(fEventBuffer->At(fBIndex[kTop]));
if(list) {
- list->Clear();
+ list->Delete();
list->AddAll(dynamic_cast<TList*>(event));
}
}
-// ///___________________________________________________________________________
-// void AliEveEventBufferHomer::AddToBuffer(TObject * event, ULong64_t eventId ) {
-// cout << "Add to buffer"<<endl;
-// if(!event) return;
-// fBIndex[kTop] = CalculateNext(fBIndex[kTop]);
-// TList * list = dynamic_cast<TList*>(fEventBuffer->At(fBIndex[kTop]));
-// if(list) {
-// list->Clear();
-// list->AddAll(dynamic_cast<TList*>(event));
-// fEventId[fBIndex[kTop]] = eventId;
-// }
-// }
///______________________________________________________________________
fHomer->SetRetryCount(1,15);
fHomer->SetBlockOwner(kFALSE);
- fHomer->StartEveSourceListLoop();
+ //fHomer->StartEveSourceListLoop();
}
}
///_____________________________________________________________________
-void AliEveEventBufferHomer::WriteToFile(){
+void AliEveEventBufferHomer::WriteToFile(Int_t runnumber){
- TFile * file = TFile::Open(Form("Event_0x%016X_ITS.root", 100), "RECREATE");
- fEventBuffer->At(fBIndex[kTop])->Write("blockList", TObject::kSingleKey);
+ TFile * file = TFile::Open(Form("Run_%d_0x%016LX_ESD.root", runnumber, GetEventId()), "RECREATE");
+ fEventBuffer->At(fBIndex[kCurrent])->Write("blockList", TObject::kSingleKey);
file->Close();
if(fAsyncList) {
- TFile * afile = TFile::Open(Form("Event_0x%016X_Async.root", 100), "RECREATE");
+ TFile * afile = TFile::Open(Form("Run_%d_0x%016LX_Async.root", runnumber, GetEventId()), "RECREATE");
fAsyncList->Write("blockList", TObject::kSingleKey);
+ //aFile-
afile->Close();
}
}