#include <DecongestionService.h>

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

bool	suppressDomainInfo = false
	do not advertise/forward DomainInfoHeader from this device

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.

bool	consumeWhenPastOldestPossibleTimeframeActive = false
	consumeWhenPastOldestPossibleTimeframe completion policy is active.

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

Detailed Description

Definition at line 18 of file DecongestionService.h.

Member Data Documentation

◆ consumeWhenPastOldestPossibleTimeframeActive

bool o2::framework::DecongestionService::consumeWhenPastOldestPossibleTimeframeActive = false

consumeWhenPastOldestPossibleTimeframe completion policy is active.

Definition at line 37 of file DecongestionService.h.

◆ isFirstInTopology

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

Wether we are a source in the processing chain.

Definition at line 20 of file DecongestionService.h.

◆ lastTimeslice

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

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

Definition at line 30 of file DecongestionService.h.

◆ nextEnumerationTimeslice

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 25 of file DecongestionService.h.

◆ nextEnumerationTimesliceRewinded

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 28 of file DecongestionService.h.

◆ nextTimeslice

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 33 of file DecongestionService.h.

◆ oldestPossibleTimesliceTask

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

Definition at line 40 of file DecongestionService.h.

◆ orderedCompletionPolicyActive

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

Ordered completion policy is active.

Definition at line 35 of file DecongestionService.h.

◆ suppressDomainInfo

bool o2::framework::DecongestionService::suppressDomainInfo = false

do not advertise/forward DomainInfoHeader from this device

Definition at line 22 of file DecongestionService.h.

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

/home/runner/work/AliceO2/AliceO2/Framework/Core/src/DecongestionService.h

Public Attributes