Skip to main content

chronon::sender::TickSimulation::WorkerPredecessorCycleCache

More...

Public Functions​

Name
voidreset(size_t num_clusters)
uint64_t *data()
WorkerPredecessorCycleCache() =default
WorkerPredecessorCycleCache(size_t num_clusters)

Public Attributes​

Name
std::vector< uint64_t >observed_cycles

Detailed Description​

struct chronon::sender::TickSimulation::WorkerPredecessorCycleCache;

Worker-private lower bounds for predecessor progress. Each cache lives across invocations, but its values reset at each invocation. It needs no atomic synchronization of its own. ThreadProgress is release-published and never decreases, so a value read with acquire remains a valid lower bound for all later dependency checks on that worker. The extra slot is reserved for the synthetic lookahead floor dependency (pred_id == thread_progress_count_).

Public Functions Documentation​

function reset​

inline void reset(
    size_t num_clusters
)

function data​

inline uint64_t * data()

function WorkerPredecessorCycleCache​

WorkerPredecessorCycleCache() =default

function WorkerPredecessorCycleCache​

inline explicit WorkerPredecessorCycleCache(
    size_t num_clusters
)

Public Attributes Documentation​

variable observed_cycles​

std::vector< uint64_t > observed_cycles;

Updated on 2026-09-20 at 14:23:39 +0000