adc_observer.h

Go to the documentation of this file.

#ifndef NEXUS_IO_ADC_OBSERVER_H
#define NEXUS_IO_ADC_OBSERVER_H
 
#include "nexus/core/time.h"
#include "nexus/io/stream.h"
#ifdef __cplusplus
extern "C" {
#endif
 
#define NX_ADC_OBSERVATION_DISCONTINUITY 1U

typedef struct {
    uint64_t epoch;
    nx_time_us_t observed_at;
    uint64_t sequence;
    uint32_t flags;
} nx_adc_observation_t;

typedef struct {
    nx_stream_t* stream;
    nx_adc_observation_t* records;
    size_t count;
    uint64_t sequence;
    bool discontinuity;
} nx_adc_observer_t;

nx_result_t nx_adc_observer_initialize(nx_adc_observer_t* observer,
                                       nx_adc_observation_t* records,
                                       size_t count);
nx_result_t nx_adc_observer_bind(nx_adc_observer_t* observer,
                                 nx_stream_t* stream, const void* owner,
                                 size_t owner_size);
nx_result_t nx_adc_observer_record(nx_adc_observer_t* observer,
                                   const nx_stream_fill_t* fill,
                                   nx_time_us_t observed_at);
nx_result_t nx_adc_observer_read(const nx_adc_observer_t* observer,
                                 const nx_stream_block_t* block,
                                 nx_adc_observation_t* observation);
nx_result_t nx_adc_observer_unbind(nx_adc_observer_t* observer);
#ifdef __cplusplus
}
#endif
#endif