state.h

Go to the documentation of this file.

 
#pragma once
 
#include <ascii-chat/crypto/sizes.h>
#include "metrics.h"
#include "topology.h"
#include <ascii-chat/asciichat_errno.h>
#include <stdint.h>
#include <stdbool.h>

typedef enum {
  CONSENSUS_STATE_IDLE = 0,                
  CONSENSUS_STATE_COLLECTION_START = 1,    
  CONSENSUS_STATE_COLLECTING = 2,          
  CONSENSUS_STATE_COLLECTION_COMPLETE = 3, 
  CONSENSUS_STATE_ELECTION_START = 4,      
  CONSENSUS_STATE_ELECTING = 5,            
  CONSENSUS_STATE_ELECTION_COMPLETE = 6,   
  CONSENSUS_STATE_FAILED = 7               
} consensus_state_machine_t;

typedef struct consensus_state consensus_state_t;

asciichat_error_t consensus_state_create(const uint8_t my_id[SESSION_ID_SIZE], const consensus_topology_t *topology,
                                         consensus_state_t **out_state);

void consensus_state_destroy(consensus_state_t *state);

asciichat_error_t consensus_state_start_collection(consensus_state_t *state);

asciichat_error_t consensus_state_add_metrics(consensus_state_t *state, const participant_metrics_t *metrics);

asciichat_error_t consensus_state_collection_complete(consensus_state_t *state);

asciichat_error_t consensus_state_compute_election(consensus_state_t *state);

asciichat_error_t consensus_state_reset_to_idle(consensus_state_t *state);

consensus_state_machine_t consensus_state_get_current_state(const consensus_state_t *state);

asciichat_error_t consensus_state_get_elected_host(const consensus_state_t *state,
                                                   uint8_t out_host_id[SESSION_ID_SIZE]);

asciichat_error_t consensus_state_get_elected_backup(const consensus_state_t *state,
                                                     uint8_t out_backup_id[SESSION_ID_SIZE]);

bool consensus_state_is_leader(const consensus_state_t *state);

int consensus_state_get_metrics_count(const consensus_state_t *state);

asciichat_error_t consensus_state_get_metric_at(const consensus_state_t *state, int index,
                                                participant_metrics_t *out_metrics);

asciichat_error_t consensus_state_store_election(consensus_state_t *state, int best, int backup);