endpoints_link.h

Go to the documentation of this file.

 
#pragma once
 
#include <stdatomic.h>
#include <stdbool.h>
#include <stdint.h>
 
#ifdef __cplusplus
extern "C" {
#endif

#define ENDPOINTS_SETTLE_MS 300u

typedef enum {
    ENDPOINTS_PAID = 0,
    ENDPOINTS_WAIT_DISARM,
    ENDPOINTS_WAIT_SETTLE,
    ENDPOINTS_PAY,
} endpoints_next_t;

endpoints_next_t endpoints_next(bool owed, bool far_disarmed,
                                uint32_t edit_ms, uint32_t now_ms);

typedef enum {
    ENDPOINTS_NO_ANSWER = 0,
    ENDPOINTS_READ_REFUSED,
    ENDPOINTS_ORDER,
    ENDPOINTS_HELD,
    ENDPOINTS_TAKEN,
    ENDPOINTS_WRITE_REFUSED,
    ENDPOINTS_DIFFERS,
} endpoints_outcome_t;

typedef enum {
    ENDPOINTS_BLOCK_NONE = 0,
    ENDPOINTS_BLOCK_OWED,
    ENDPOINTS_BLOCK_UNKNOWN,
    ENDPOINTS_BLOCK_ORDER,
    ENDPOINTS_BLOCK_REFUSED,
    ENDPOINTS_BLOCK_DIFFERS,
} endpoints_block_t;

bool endpoints_page_holds(const uint16_t *page, uint16_t min_us,
                          uint16_t max_us);

bool endpoints_owed_after(endpoints_outcome_t outcome);

typedef struct {
    atomic_uint pair;     
    atomic_uint edit_ms;  
    atomic_bool owed;     
    bool hold;
    uint8_t refused;
} endpoints_debt_t;

void endpoints_publish(endpoints_debt_t *d, uint16_t min_us, uint16_t max_us,
                       uint32_t now_ms);

void endpoints_link_up(endpoints_debt_t *d);

bool endpoints_owed(const endpoints_debt_t *d);

void endpoints_recheck(endpoints_debt_t *d);

endpoints_block_t endpoints_block(const endpoints_debt_t *d);

bool endpoints_blocked(const endpoints_debt_t *d);

bool endpoints_held(const endpoints_debt_t *d);

uint16_t endpoints_min(const endpoints_debt_t *d);
uint16_t endpoints_max(const endpoints_debt_t *d);

endpoints_next_t endpoints_take(endpoints_debt_t *d, bool far_disarmed,
                                uint32_t now_ms);

void endpoints_paid(endpoints_debt_t *d, endpoints_outcome_t outcome);
 
#ifdef __cplusplus
}
#endif