request_observer.h

Go to the documentation of this file.

#ifndef NEXUS_REQUEST_OBSERVER_H
#define NEXUS_REQUEST_OBSERVER_H
#include "nexus/core/request.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct {
    uint64_t epoch;
    nx_time_us_t observed_at;
    nx_time_us_t deadline;
    nx_request_state_t state;
    nx_result_t result;
    size_t transferred;
    bool settled;
} nx_request_observation_t;

typedef struct {
    const nx_request_slot_t* slot;
    uint64_t epoch;
    nx_time_us_t last_observed;
    nx_time_us_t max_gap;
    uint32_t samples;
    uint32_t transitions;
    uint32_t clock_errors;
    nx_request_state_t last_state;
    bool observed;
} nx_request_observer_t;

nx_result_t nx_request_observer_bind(nx_request_observer_t* observer,
                                     const nx_request_slot_t* slot,
                                     uint64_t epoch);
nx_result_t nx_request_observer_sample(nx_request_observer_t* observer,
                                       nx_time_us_t now,
                                       nx_request_observation_t* out);
void nx_request_observer_detach(nx_request_observer_t* observer);
#ifdef __cplusplus
}
#endif
#endif