JTimekeeper.cc

Go to the documentation of this file.

#include <string>
#include <iostream>
#include <iomanip>
 
#include "Jeep/JTimekeeper.hh"
#include "JSystem/JTime.hh"
 
#include "Jeep/JPrint.hh"
#include "Jeep/JParser.hh"
#include "Jeep/JMessage.hh"
 
 
/**
 * \file
 * Example program to test JEEP::JTimekeeper class.
 * \author mdejong
 */
int main(int argc, char* argv[])
{
  using namespace std;
 
  int     intervalTime_ms;
  int     totalTime_s;
  int     debug;
 
  try {
 
    JParser<> zap;
 
    zap['t'] = make_field(intervalTime_ms) = 100;
    zap['s'] = make_field(totalTime_s)     =   2;
    zap['d'] = make_field(debug)           = 1;
 
    zap(argc, argv);
  }
  catch(const exception &error) {
    FATAL(error.what() << endl);
  }
 
 
  using namespace JPP;
 
  if (intervalTime_ms <= 0) { FATAL("interval time [ms]  " << intervalTime_ms << " < 0." << endl); }
  if (totalTime_s     <= 0) { FATAL("total    time [s]   " << totalTime_s     << " < 0." << endl); }
 
  JFileDescriptorMask mask;
 
  cout << "hit <return> to interrupt" << endl;
 
  JTimekeeper clock;
 
  clock.setInterval(intervalTime_ms * 1000);
  clock.reset();
 
  const long long int t0 = getLocalTime();
 
  string buffer;
  int    numberOfInterrupts = 0;
 
  for (int i = 0; i < 1000 * totalTime_s / intervalTime_ms; ) {
 
    DEBUG(setw(5) << i << rewind);
 
    mask.set(STDIN_FILENO);      // hit <return> to interrupt wait(..)
 
    if (clock.wait(mask)) {
 
      getline(cin, buffer);      // flush input
 
      ++numberOfInterrupts;
 
    } else {
 
      ++i;
    }
  }
  NOTICE(endl);
 
  const long long int t1 = getLocalTime();
 
  NOTICE("Number of interrupts    " << setw(8) << right << numberOfInterrupts      << endl);
  NOTICE("Total delay        [ms] " << setw(8) << right << clock.getDelay() / 1000 << endl);
  NOTICE("Elapsed time       [ms] " << setw(8) << right << (t1 - t0)        / 1000 << endl);
 
  if (numberOfInterrupts != 0) {
    NOTICE("Time per interrupt [us] " << setw(8) << right << (t1 - t0 - clock.getDelay()) / numberOfInterrupts << endl);
  }
}