// $Id$
//-----------------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//         Experiment Data Processing at EE department, GSI
//-----------------------------------------------------------------------
// Copyright (C) 2000- GSI Helmholtzzentrum für Schwerionenforschung GmbH
//                     Planckstr. 1, 64291 Darmstadt, Germany
// Contact:            http://go4.gsi.de
//-----------------------------------------------------------------------
// This software can be used under the license agreements as stated
// in Go4License.txt file which is part of the distribution.
//-----------------------------------------------------------------------

#include "TGo4Ratemeter.h"

#include "TStopwatch.h"

const Double_t TGo4Ratemeter::fgdUPDATEINTERVAL= 1.0; // time in s


TGo4Ratemeter::TGo4Ratemeter()
: fuCurrentCount(0), fuLastCount(0), fdRate(0), fdAveRate(0),  fdTime(0), fdLastTime(0),fdDeltaTime(0)
{
   fxClock = new TStopwatch;
   fxClock->Stop();
}

TGo4Ratemeter::~TGo4Ratemeter()
{
   delete fxClock;
}

void TGo4Ratemeter::Reset()
{
   fdTime = 0;
   fdDeltaTime = 0;
   fdRate = 0;
   fdAveRate = 0;
   fuLastCount = 0;
   fdLastTime = 0;
   fuCurrentCount = 0;
   fxClock->RealTime();
   fxClock->Start(kTRUE);
}

void TGo4Ratemeter::Update(Int_t increment)
{
   if(increment<0) {
      if(increment==-2)
         fdRate=1; // first update after start: dummy rate
      else
         fdRate=0; // case of stopped analysis: zero rate
      // keep last values of time, average rate, eventnumber
   } else {
      // normal operation
      fdTime = fxClock->RealTime();
      fxClock->Continue();
      fdDeltaTime = fdTime - fdLastTime; // difference since last update
      fuCurrentCount += (UInt_t) increment;
      UInt_t deltacount = fuCurrentCount - fuLastCount;
      if(fdDeltaTime > TGo4Ratemeter::fgdUPDATEINTERVAL) {
         // we reach the update point, calculate the rate
         if(fdDeltaTime>0. && deltacount>0)
            fdRate = deltacount/fdDeltaTime;
         else
            fdRate=0.; // reset rate in case of stopped analysis
         if(fdTime>0)
            fdAveRate = fuCurrentCount/fdTime;
         fdLastTime = fdTime; // remember updata time and count
         fuLastCount = fuCurrentCount;
      } else {
         // too short time since last update, we do not calculate...
      } // if( fdDeltaTime > TGo4Ratemeter::fgdUPDATEINTERVAL)
   } //if(increment<0)
   fbUpdateDone = kTRUE; // tell watch thread we did the update
}

Bool_t TGo4Ratemeter::TestUpdate()
{
   Bool_t rev = fbUpdateDone;
   fbUpdateDone = kFALSE;
   return rev;
}