Public Attributes
bool	isFirstInTopology = true
	Wether we are a source in the processing chain.

size_t	nextEnumerationTimeslice = 0

bool	nextEnumerationTimesliceRewinded = false

int64_t	lastTimeslice = 0
	Last timeslice we communicated. Notice this should never go backwards.

int64_t	nextTimeslice = 0

bool	orderedCompletionPolicyActive = false
	Ordered completion policy is active.

o2::framework::AsyncTaskId	oldestPossibleTimesliceTask = {0}

Detailed Description

Definition at line 18 of file DecongestionService.h.

Member Data Documentation

bool o2::framework::DecongestionService::isFirstInTopology = true

Wether we are a source in the processing chain.

Definition at line 20 of file DecongestionService.h.

int64_t o2::framework::DecongestionService::lastTimeslice = 0

Last timeslice we communicated. Notice this should never go backwards.

Definition at line 28 of file DecongestionService.h.

size_t o2::framework::DecongestionService::nextEnumerationTimeslice = 0

The last timeslice which the ExpirationHandler::Creator callback created. This can be used to skip dummy iterations.

Definition at line 23 of file DecongestionService.h.

bool o2::framework::DecongestionService::nextEnumerationTimesliceRewinded = false

Flag to indicate that we rewinded the nextExnumerationTimeslice. The rewinded value must be checked when sending the oldestPossible.

Definition at line 26 of file DecongestionService.h.

int64_t o2::framework::DecongestionService::nextTimeslice = 0

The next timeslice we should consume, when running in order, using an ordered completion policy.

Definition at line 31 of file DecongestionService.h.

o2::framework::AsyncTaskId o2::framework::DecongestionService::oldestPossibleTimesliceTask = {0}

Definition at line 36 of file DecongestionService.h.

bool o2::framework::DecongestionService::orderedCompletionPolicyActive = false

Ordered completion policy is active.

Definition at line 33 of file DecongestionService.h.

The documentation for this struct was generated from the following file: