clock-sync.h

Go to the documentation of this file.

 
#ifndef CLOCK_SYNC_H
#define CLOCK_SYNC_H
 
#include "low_level_platform.h"
#include "net_abstraction.h"
 
#ifndef LF_CLOCK_SYNC
#define LF_CLOCK_SYNC LF_CLOCK_SYNC_INIT
#endif

#define LF_CLOCK_SYNC_OFF 1

#define LF_CLOCK_SYNC_INIT 2

#define LF_CLOCK_SYNC_ON 3

#ifndef _LF_CLOCK_SYNC_EXCHANGES_PER_INTERVAL
#define _LF_CLOCK_SYNC_EXCHANGES_PER_INTERVAL 10
#endif

#ifndef _LF_CLOCK_SYNC_ATTENUATION
#define _LF_CLOCK_SYNC_ATTENUATION 10
#endif

#ifndef _LF_CLOCK_SYNC_COLLECT_STATS
#define _LF_CLOCK_SYNC_COLLECT_STATS true
#endif

#define CLOCK_SYNC_GUARD_BAND USEC(100)

typedef struct socket_stat_t {
  instant_t remote_physical_clock_snapshot_T1;

  instant_t local_physical_clock_snapshot_T2;

  interval_t local_delay;

  int received_T4_messages_in_current_sync_window;

  interval_t history;

  interval_t network_stat_round_trip_delay_max;

  int network_stat_sample_index;

  interval_t clock_synchronization_error_bound;

  interval_t network_stat_samples[_LF_CLOCK_SYNC_EXCHANGES_PER_INTERVAL];
} socket_stat_t;

typedef struct lf_stat_ll {
  int64_t average;
  int64_t standard_deviation;
  int64_t variance;
  int64_t max;
} lf_stat_ll;

void reset_socket_stat(struct socket_stat_t* socket_stat);

uint16_t setup_clock_synchronization_with_rti(void);

void synchronize_initial_physical_clock_with_rti(net_abstraction_t rti_net);

int handle_T1_clock_sync_message(unsigned char* buffer, void* socket_or_net, instant_t t2, socket_type_t socket_type);

void handle_T4_clock_sync_message(unsigned char* buffer, void* socket_or_net, instant_t r4, socket_type_t socket_type);

int create_clock_sync_thread(lf_thread_t* thread_id);

void clock_sync_add_offset(instant_t* t);

void clock_sync_subtract_offset(instant_t* t);

void clock_sync_set_constant_bias(interval_t offset);
 
#endif // CLOCK_SYNC_H