edm::CountAndLimit Class Reference

#include <ELmap.h>

Public Member Functions
bool	add ()
	CountAndLimit (int lim=-1, int ts=-1, int ivl=-1)

Public Attributes
int	aggregateN
int	interval
time_t	lastTime
int	limit
int	n
int	skipped
int	timespan

Detailed Description

Definition at line 53 of file ELmap.h.

Constructor & Destructor Documentation

CountAndLimit()

edm::CountAndLimit::CountAndLimit	(	int	lim = -1,
		int	ts = -1,
		int	ivl = -1
	)

Definition at line 40 of file ELmap.cc.

      : n(0),
        aggregateN(0),
        lastTime(time(nullptr)),
        limit(lim),
        timespan(ts),
        interval(ivl),
        skipped(ivl - 1)  // So that the FIRST of the prescaled messages emerges
  {}

Member Function Documentation

add()

bool edm::CountAndLimit::add

(

)

Definition at line 50 of file ELmap.cc.

References aggregateN, DMR_cfg::cerr, change_name::diff, interval, lastTime, limit, n, submitPVValidationJobs::now, skipped, protons_cff::time, and timespan.

Referenced by counter.Counter::register(), SequenceTypes._TaskBase::remove(), and SequenceTypes._TaskBase::replace().

                          {
    time_t now = time(nullptr);

#ifdef ELcountTRACE
    std::cerr << "&&&--- CountAndLimit::add \n";
    std::cerr << "&&&    Time now  is " << now << "\n";
    std::cerr << "&&&    Last time is " << lastTime << "\n";
    std::cerr << "&&&    timespan  is " << timespan << "\n";
    std::cerr << "&&&    difftime  is " << difftime(now, lastTime) << "\n" << std::flush;
#endif

    // Has it been so long that we should restart counting toward the limit?
    if ((timespan >= 0) && (difftime(now, lastTime) >= timespan)) {
      n = 0;
      if (interval > 0) {
        skipped = interval - 1;  // So this message will be reacted to
      } else {
        skipped = 0;
      }
    }

    lastTime = now;

    ++n;
    ++aggregateN;
    ++skipped;

#ifdef ELcountTRACE
    std::cerr << "&&&       n is " << n << "-- limit is    " << limit << "\n";
    std::cerr << "&&& skipped is " << skipped << "-- interval is " << interval << "\n";
#endif

    if (skipped < interval)
      return false;

    if (limit == 0)
      return false;  // Zero limit - never react to this
    if ((limit < 0) || (n <= limit)) {
      skipped = 0;
      return true;
    }

    // Now we are over the limit - have we exceeded limit by 2^N * limit?
    long diff = n - limit;
    long r = diff / limit;
    if (r * limit != diff) {  // Not a multiple of limit - don't react
      return false;
    }
    if (r == 1) {  // Exactly twice limit - react
      skipped = 0;
      return true;
    }

    while (r > 1) {
      if ((r & 1) != 0)
        return false;  // Not 2**n times limit - don't react
      r >>= 1;
    }
    // If you never get an odd number till one, r is 2**n so react

    skipped = 0;
    return true;

  }  // add()

Member Data Documentation

aggregateN

int edm::CountAndLimit::aggregateN

Definition at line 56 of file ELmap.h.

Referenced by add().

interval

int edm::CountAndLimit::interval

Definition at line 60 of file ELmap.h.

Referenced by add().

lastTime

time_t edm::CountAndLimit::lastTime

Definition at line 57 of file ELmap.h.

Referenced by add().

limit

int edm::CountAndLimit::limit

Definition at line 58 of file ELmap.h.

Referenced by add().

n

int edm::CountAndLimit::n

Definition at line 55 of file ELmap.h.

Referenced by add(), and output.OutputBranch::fill().

skipped

int edm::CountAndLimit::skipped

Definition at line 61 of file ELmap.h.

Referenced by add().

timespan

int edm::CountAndLimit::timespan

Definition at line 59 of file ELmap.h.

Referenced by add().