fix coding violation
authorslindal <slindal@f7af4fe6-9843-0410-8265-dc069ae4e863>
Fri, 3 Dec 2010 15:33:32 +0000 (15:33 +0000)
committerslindal <slindal@f7af4fe6-9843-0410-8265-dc069ae4e863>
Fri, 3 Dec 2010 15:33:32 +0000 (15:33 +0000)
EVE/EveHLT/AliEveEventBuffer.cxx
EVE/EveHLT/AliEveEventBuffer.h

index 4837327..7b739c3 100644 (file)
@@ -18,7 +18,6 @@ ClassImp(AliEveEventBuffer)
 AliEveEventBuffer::AliEveEventBuffer() :
   fBufferSize(10),
   fPreBuffer(4),
-  fBusy(kFALSE),
   fEventBuffer(NULL),
   fCurrentEvent(NULL),
   fBIndex(),
@@ -70,7 +69,7 @@ AliEveEventBuffer::~AliEveEventBuffer() {
 
 ///___________________________________________________________________________
 void AliEveEventBuffer::CreateBufferThread() {
-  
+    // see header file for class documentation
   
   cout << "Threadexists: " << fThread->Exists() << endl;
   if( fMutex->TryLock() ) {
@@ -78,7 +77,6 @@ void AliEveEventBuffer::CreateBufferThread() {
     return;
   } else {
     if ( (CalculateDifference(fBIndex[kTop],fBIndex[kLast]) < fPreBuffer) ) {
-      SetBusy(kTRUE);
       cout << "StartBufferThread()"<<endl;
       fThread->Run();
       cout << "Started BufferThread"<<endl;
@@ -91,6 +89,7 @@ void AliEveEventBuffer::CreateBufferThread() {
 
 ///___________________________________________________________________________
 void * AliEveEventBuffer::BufferThread(void * buffer) {
+  // see header file for class documentation
   cout <<"BufferThread : " <<endl;
   if(buffer) {
       reinterpret_cast<AliEveEventBuffer*>(buffer)->MonitorBuffer();
@@ -102,6 +101,7 @@ void * AliEveEventBuffer::BufferThread(void * buffer) {
 
 ///_____________________________________________________________________________
 void AliEveEventBuffer::MonitorBuffer() {
+  // see header file for class documentation
   cout << "Monitorbuffer() ";
   FetchEvent();
   fMutex->UnLock();
@@ -120,6 +120,7 @@ TObject * AliEveEventBuffer::NextEvent() {
 
 ///______________________________________________________________________________
 TObject * AliEveEventBuffer::Back() {
+  // see header file for class documentation
   cout << "go back"<<endl;
   PrintIndeces();
   Int_t prevId = CalculatePrevious(fBIndex[kCurrent]);
@@ -138,6 +139,7 @@ TObject * AliEveEventBuffer::Back() {
 
 ///______________________________________________________________________________
 TObject * AliEveEventBuffer::Fwd() {
+  // see header file for class documentation
   PrintIndeces();
   if (fBIndex[kCurrent] == fBIndex[kLast]) {
     cout<<  "returning NULL"<<endl;
@@ -168,12 +170,14 @@ TObject * AliEveEventBuffer::GetNextUnSeen() {
 }
 ///_________________________________________________________________________________
 void AliEveEventBuffer::PrintIndeces() {
+  // see header file for class documentation
   for(Int_t i = 0; i < kSize; i++) {
     cout << i << ": " << fBIndex[i] << endl;
   }
 }
 ///_________________________________________________________________________________
 void AliEveEventBuffer::PrintBuffer() {
+  // see header file for class documentation
   for(Int_t i = 0; i < 10; i++) {
     AliESDEvent * event = dynamic_cast<AliESDEvent*>(fEventBuffer->At(i));
     if(event) {
@@ -184,6 +188,7 @@ void AliEveEventBuffer::PrintBuffer() {
 
 ///____________________________________________________________________________________
 void AliEveEventBuffer::FetchEvent() {
+  // see header file for class documentation
   cout << "FetchEvent " << endl;
   TObject * event = GetEventFromSource();
   ULong64_t eventId = GetEventIdFromSource();
@@ -199,6 +204,7 @@ void AliEveEventBuffer::FetchEvent() {
 
 ///_________________________________________________________________________________
 void AliEveEventBuffer::AddToBuffer(TObject * event) {
+  // see header file for class documentation
   cout << "Add to buffer"<<endl;
   if(!event) return;
 
@@ -212,7 +218,7 @@ void AliEveEventBuffer::AddToBuffer(TObject * event) {
 }
 
 ///_____________________________________________________________________________________
-Int_t AliEveEventBuffer::CalculateNext(Int_t current) {
+Int_t AliEveEventBuffer::CalculateNext(Int_t current) const {
   //See header file for documentation
   current++;
   if(current == fBufferSize) current = 0;
@@ -221,7 +227,7 @@ Int_t AliEveEventBuffer::CalculateNext(Int_t current) {
 
 
 ///_____________________________________________________________________________________
-Int_t AliEveEventBuffer::CalculatePrevious(Int_t current) {
+Int_t AliEveEventBuffer::CalculatePrevious(Int_t current) const {
   //See header file for documentation
   cout << "CalculatePrev:  " << current; 
   current--;
@@ -231,7 +237,7 @@ Int_t AliEveEventBuffer::CalculatePrevious(Int_t current) {
 }
 
 ///__________________________________________________________________________________
-Int_t AliEveEventBuffer::CalculateDifference(Int_t top, Int_t low) {
+Int_t AliEveEventBuffer::CalculateDifference(Int_t top, Int_t low) const {
   //See header file for documentation
   if (top > low) {
     //    cout << "top > low"<<endl;
@@ -261,6 +267,7 @@ void AliEveEventBuffer::StartBufferMonitor() {
 }
 ///___________________________________________________________________________________
 void AliEveEventBuffer::StopBufferMonitor() {
+  // see header file for class documentation
   cout << "Stopping buffer mon"<<endl;
   SetBufferMonStarted(kFALSE);
   fTimer->Stop();
index a32f97b..bb8dc87 100644 (file)
@@ -1,10 +1,5 @@
-//-*- Mode: C++ -*-
-
 // $Id$
 
-#ifndef ALIEVEEVENTBUFFER_H
-#define ALIEVEEVENTBUFFER_H
-
 /* This file is property of and copyright by the ALICE HLT Project        * 
  * ALICE Experiment at CERN, All rights reserved.                         *
  * See cxx source for full Copyright notice     
 /** @file   AliEveEventBuffer.h
     @author Svein Lindal
     @date
-    @brief  Manager for HOMER in aliroot
+    @brief  Event buffer for HOMER
 */
 
 
+#ifndef ALIEVEEVENTBUFFER_H
+#define ALIEVEEVENTBUFFER_H
+
+
+
+#include "TObject.h"
+#include "TMutex.h"
+
 class TObjArray;
-class TObject;
 class TTimer;
 class TThread;
-#include "TMutex.h"
-#include "TTimer.h"
+class TTimer;
+
 
 class AliEveEventBuffer : public TObject{
 
@@ -35,12 +37,7 @@ public:
   virtual ~AliEveEventBuffer();
 
   void SetBufferSize(Int_t bs) { fBufferSize = bs;}
-  void SetBusy(Bool_t busy) { fBusy = busy;}
-  Bool_t GetBusy() { return fBusy;}
-  
-  //Navigate the event buffer
-  // TObject *  NavigateFwd();
-  // TObject *  NavigateBack();
+    
   TObject * NextEvent();
   TObject * Back();
   TObject * Fwd();
@@ -74,18 +71,12 @@ protected:
   };
 
   
-  Int_t fBufferSize;
-  Int_t fPreBuffer;
-  Bool_t fBusy;
-
-  //TClonesArray containing the stored events
-  TObjArray * fEventBuffer;
-
-  //Pointer to current event
-  TObject * fCurrentEvent;
+  Int_t fBufferSize;//Size of event buffer
+  Int_t fPreBuffer;//How many events should be prefetched
+  TObjArray * fEventBuffer;   //TClonesArray containing the stored events
+  TObject * fCurrentEvent;   //Pointer to current event
+  Int_t fBIndex[kSize];   //Event buffer indexes
 
-  //Event buffer indexes
-  Int_t fBIndex[kSize];
   
   
   //Add event to buffer
@@ -98,9 +89,9 @@ protected:
   
 
   //Calculate buffer index stuff
-  Int_t CalculateDifference(Int_t top, Int_t low);
-  Int_t CalculatePrevious(Int_t current);
-  Int_t CalculateNext(Int_t current);
+  Int_t CalculateDifference(Int_t top, Int_t low) const;
+  Int_t CalculatePrevious(Int_t current) const;
+  Int_t CalculateNext(Int_t current) const;
 
   
   void SetBufferMonStarted(Bool_t started) {fBufferMonStarted = started;}
@@ -121,15 +112,15 @@ private:
   void PrintIndeces();
   void PrintBuffer();
 
-  TTimer * fTimer;
+  TTimer * fTimer;//Timer to loop over buffer monitor
 
   //Current event id
-  ULong64_t * fEventId;
+  ULong64_t * fEventId;//Event id
   
-  Bool_t fBufferMonStarted;
+  Bool_t fBufferMonStarted;//Has buffer monitor loop started?
 
-  TThread * fThread;
- TMutex * fMutex;
+  TThread * fThread; //Thread pointer
+  TMutex * fMutex;//Mutex
 
   ClassDef(AliEveEventBuffer, 0); // Manage connections to HLT data-sources.
 };