Module Tezos_baking_alpha.Baking_automaton

the event loop's I/O state

retry ctxt ~delay ?max_delay ~factor ~tries ?msg f x retries applying f x tries until it succeeds or returns an error different from Connection_failed, at most tries number of times. After each try it waits for a number of seconds, but not more than max_delay, if given. The wait time between tries is given by the initial delay, multiplied by factor at each subsequent try. At each failure, msg together with the current delay is printed using ctxt#message.

try_resolve_consensus_keys cctxt key attempts to resolve the primary delegate associated with the given key.

• If key is a primary baking key, it is returned directly.
• If key is a consensus key, attestation rights over the past 50 levels are inspected to retrieve the associated primary delegate.
• Falls back to returning the PKH of key if no rights are found, or if key is neither a registered delegate nor a consensus key.

sleep_until time is blocking until it is time.

first_potential_round_at_next_level Returns the first round at the next level, at or after earliest_round, whose baking slot belongs to one of our own delegates; also returns the corresponding delegate. Or returns None if no such round exists.

first_potential_round_at_current_level Returns the first round at current level, at or after earliest_round, whose baking slot belongs to one of our own delegates; also returns the corresponding delegate. Or returns None if no such round exists.

compute_next_potential_baking_time state From the current state, the function returns an optional association pair, which consists of the next baking timestamp and its baking round. In that case, an elected block must exist.

compute_bootstrap_event state emits the first event. If the latest proposal is for the current round, then trigger the new proposal event to possibly preattest. Otherwise, trigger the end of round event (for the previous round) to check whether we need to propose at this level or not.

create_loop_state ?get_valid_blocks_stream heads_stream forge_event_stream operation_worker creates a loop state with the streams of valid blocks, new heads, forged events and operations from the node's mempool.

automaton_loop ?stop_on_event baking_configuration on_error loop_state state event:

• calls State_transitions.step with the state and event and recover a new state and an action to perform

• calls Baking_actions.perform_action on this new state and action

• records the new state on the disk if the baking_configuration is not Baking_configuration.state_recorder_config.Memory

• computes the next timeouts from the current state using a function that returns an Lwt promise that fulfills once the nearest timeout (between those computed by wait_end_of_round and wait_baking_time_next_level) is expired (at that moment the state machine will react)

• waits for the next event from the events streams (new valid proposal, new heads, new forged event, (pre)quorum reached), or a timeout (end of round, or a baking time)

• stops if stop_on_event matches the given event; recursively calls itself with the new event otherwise