Skip to main content

chronon::sender::TickSimulation::WorkerPredecessorCycleCache

More...

Public Functions​

Name
uint64_t *data()
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 for one worker invocation and 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 data​

inline uint64_t * data()

function WorkerPredecessorCycleCache​

inline explicit WorkerPredecessorCycleCache(
    size_t num_clusters
)

Public Attributes Documentation​

variable observed_cycles​

std::vector< uint64_t > observed_cycles;

Updated on 2026-07-14 at 10:30:41 +0000