X-Git-Url: http://git.uio.no/git/?a=blobdiff_plain;f=EVE%2FEveHLT%2FAliEveEventBufferHomer.cxx;h=0483b4323c1ccc77be189e4ab71b513b0f8d2473;hb=ebc2af25da4f6dc0e5aac0a25cdbda86313ad96f;hp=16d7d3c4003da77cae737e8328b24f85b5b2a0ed;hpb=8676f4b1a5fb3cac607ea30dcb1f662a5781d8b9;p=u%2Fmrichter%2FAliRoot.git

diff --git a/EVE/EveHLT/AliEveEventBufferHomer.cxx b/EVE/EveHLT/AliEveEventBufferHomer.cxx
index 16d7d3c4003..0483b4323c1 100644
--- a/EVE/EveHLT/AliEveEventBufferHomer.cxx
+++ b/EVE/EveHLT/AliEveEventBufferHomer.cxx
@@ -35,9 +35,9 @@ AliEveEventBufferHomer::~AliEveEventBufferHomer() {
 }
 
 
-
+///____________________________________________________________
 ULong64_t AliEveEventBufferHomer::GetEventIdFromSource() {
-  ///
+  ///see header file for documentation
   return fHomer->GetEventID();
 }
 
@@ -47,7 +47,9 @@ TObject * AliEveEventBufferHomer::GetEventFromSource() {
   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;
   } 
@@ -58,28 +60,27 @@ TObject * AliEveEventBufferHomer::GetEventFromSource() {
 
 ///___________________________________________________________________________
 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;  
-//   }
-// }
 
 
 ///______________________________________________________________________
@@ -106,7 +107,7 @@ void AliEveEventBufferHomer::Initialize() {
 
   fHomer->SetRetryCount(1,15);
   fHomer->SetBlockOwner(kFALSE);
-  fHomer->StartEveSourceListLoop();
+  //fHomer->StartEveSourceListLoop();
 }
 
 
@@ -118,15 +119,16 @@ void AliEveEventBufferHomer::ConnectToSource () {
 }
 
 ///_____________________________________________________________________
-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();
   }
 }