Implemented Mutex

[u/mrichter/AliRoot.git] / EVE / EveHLT / AliEveHLTEventManagerHomer.cxx

diff --git a/EVE/EveHLT/AliEveHLTEventManagerHomer.cxx b/EVE/EveHLT/AliEveHLTEventManagerHomer.cxx
index e09ff1a45ddf4f2d0ac54b520182ddf070d416b8..635743d2cd7039958eaf7d2de672892bf9323717 100644 (file)
--- a/EVE/EveHLT/AliEveHLTEventManagerHomer.cxx
+++ b/EVE/EveHLT/AliEveHLTEventManagerHomer.cxx
@@ -57,12 +57,10 @@ void AliEveHLTEventManagerHomer::ProcessList(TList * blockList) {
 ///________________________________________________________________________________
 void AliEveHLTEventManagerHomer::NextEvent() {
   //See header file for documentation
-  if(fEventBuffer->GetBusy() ) {
+  if(fEventBuffer->LockMutex() ) {
     cout << "event buffer already busy"<<endl;
     return;
-  }else {
-    fEventBuffer->SetBusy(kTRUE);
-  }
+  } else {
 
   TList * aSyncEvent = fEventBuffer->GetASyncEvent();
   TList * event = static_cast<TList*>(fEventBuffer->NextEvent());
@@ -92,8 +90,9 @@ void AliEveHLTEventManagerHomer::NextEvent() {
   //   }  else {
   //    cout << "No async bloc"<<endl;
   // }
-
-  fEventBuffer->SetBusy(kFALSE);
+  }
+  
+  fEventBuffer->UnLockMutex();
 }