///////////////////////////////////////////////////////////////////////
// $Id: IDbiTimer.cxx,v 1.1 2011/01/18 05:49:20 finch Exp $
//
// COMET::IDbiTimer
//
// Package: COMET::IDbi (Database Interface).
//
// N. West 01/2002
//
// Concept: Simple timer record query progress and final times.
//
// Purpose: To find out why this is all soooo sssllloooowwww!
//
///////////////////////////////////////////////////////////////////////

#include "IDbiTimer.hxx"
#include <IMsgFormat.h>
#include <ICOMETLog.hxx>
#include <IMsgFormat.h>
using std::endl;

ClassImp(COMET::IDbiTimer)


//   Definition of static data members
//   *********************************


// Definition of member functions (alphabetical order)
// ***************************************************

//.....................................................................

COMET::IDbiTimer::IDbiTimer() :
fCurSubWatch(0),
fRowSize(0),
fQueryStage(kPassive)
{
//
//
//  Purpose:  Default constructor
//
//  Contact:   N. West
//


  COMETTrace( "Creating COMET::IDbiTimer" << "  ");

  fWatch.Stop();
  for ( int subWatch = 0; subWatch <  kMaxSubWatch; ++subWatch) {
    fSubWatches[subWatch].Stop();
  }

}


//.....................................................................

COMET::IDbiTimer::~IDbiTimer() {
//
//
//  Purpose: Destructor
//
//  Contact:   N. West
//


  COMETTrace( "Destroying COMET::IDbiTimer" << "  ");

}

//.....................................................................

void COMET::IDbiTimer::RecBegin(string tableName, UInt_t rowSize) {
//
//
//  Purpose:  Record the start of initial query on supplied table.
//
//  Arguments:
//    tableName    in    Name of table.
//    rowSize      in    Size of row object
//
//  Contact:   N. West

  fQueryStage = kInitialQuery;
  fTableName = tableName;
  fRowSize = rowSize;
  fWatch.Start();
  for ( int subWatch = 0; subWatch <  kMaxSubWatch; ++subWatch) {
    // Use Start to reset the counter (Reset doesn't do this).
    fSubWatches[subWatch].Start();
    fSubWatches[subWatch].Stop();
  }
  if ( fCurSubWatch >= 0 ) this->StartSubWatch(0);

}
//.....................................................................

void COMET::IDbiTimer::RecEnd(UInt_t numRows) {
//
//
//  Purpose:  Record the end of query.
//
//  Arguments:
//    numRows    in    Number of rows found in query
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Record the end of query.  If query never reached the Main Query
//    phase then quit as query must have been satisfied
//    by the cache.
//
// o  If SubWatches enabled print them out if the main timer has
//    recorded significant activity.

//  None.

  if ( fQueryStage != kMainQuery ) return;

  Float_t tableSize = numRows * fRowSize/1.0e+3;
  string units = "Kb";
  if ( tableSize > 1000. ) {
    tableSize /= 1000.;
    units = "Mb";
  }
  IMsgFormat ffmt("%6.1f");

  COMETInfo( "COMET::IDbiTimer:" <<  fTableName
      << ": Query done. "  << numRows
        << "rows, " << ffmt(tableSize) << units
        << " Cpu" << ffmt(fWatch.CpuTime())
        << " , elapse" << ffmt(fWatch.RealTime())
                        << "  ");

  fWatch.Stop();
  fQueryStage = kPassive;

  if ( fCurSubWatch >= 0 && fWatch.RealTime() > 5. ) {
    for ( int subWatch = 0; subWatch <  kMaxSubWatch; ++subWatch) {
    static const Char_t* subWatchNames[kMaxSubWatch]
      = { "Query database     ",
          "Create row objects ",
          "Retrieve TSQL rows ",
          "Fill row objects   "};
       COMETInfo(  "      SubWatch " <<  subWatchNames[subWatch]
            << ": Cpu" << ffmt(fSubWatches[subWatch].CpuTime())
        << " , elapse" << ffmt(fSubWatches[subWatch].RealTime())
      << " , Starts " << fSubWatches[subWatch].Counter()
            << "  ");
    }
  }
}
//.....................................................................

void COMET::IDbiTimer::RecMainQuery() {
//
//
//  Purpose:  Record the start of main query.
//
//  Contact:   N. West

  fQueryStage = kMainQuery;

}
//.....................................................................

void COMET::IDbiTimer::RecFillAgg(Int_t /* aggNo */) {
//
//
//  Purpose:  Record filling of aggregate.
//
//  Arguments:
//    aggNo        in    Aggregate number.
//
//  Contact:   N. West

}

void COMET::IDbiTimer::Resume() {
//
//
//  Purpose:  Resume timer and any partial timer.
//
//  Contact:   N. West

  if ( fCurSubWatch >= 0 ) fSubWatches[fCurSubWatch].Start(kFALSE);
  fWatch.Start(kFALSE);
}

//.....................................................................

void COMET::IDbiTimer::StartSubWatch(UInt_t subWatch) {
//
//
//  Purpose:  Start specified SubWatch if SubWatch timers enabled.
//
//  Arguments:
//    subWatch     in    SubWatch number ( 0 .. kMaxSubWatch-1 ).
//
//  Contact:   N. West

  if (     fCurSubWatch < 0
        || subWatch >= kMaxSubWatch ) return;

  fSubWatches[fCurSubWatch].Stop();
  fCurSubWatch = subWatch;
  fSubWatches[fCurSubWatch].Start(kFALSE);

}

void COMET::IDbiTimer::Suspend() {
//
//
//  Purpose:  Suspend timer and any partial timer.
//
//  Contact:   N. West

  if ( fCurSubWatch >= 0 ) fSubWatches[fCurSubWatch].Stop();
  fWatch.Stop();
}

/*    Template for New Member Function

//.....................................................................

COMET::IDbiTimer:: {
//
//
//  Purpose:
//
//  Arguments:
//    xxxxxxxxx    in    yyyyyy
//
//  Return:
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o

//  Program Notes:-
//  =============

//  None.


}

*/