request.h

Go to the documentation of this file.

#ifndef NEXUS_REQUEST_H
#define NEXUS_REQUEST_H
 
#include "nexus/core/time.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef enum {
    NX_REQUEST_READY = 0,
    NX_REQUEST_QUEUED,
    NX_REQUEST_ACTIVE,
    NX_REQUEST_DRAINING,
    NX_REQUEST_SETTLED,
    NX_REQUEST_QUARANTINED
} nx_request_state_t;

typedef struct {
    uint32_t state;
    nx_result_t result;
    size_t transferred;
    nx_time_us_t deadline;
} nx_request_t;

typedef struct {
    nx_request_t* request;
    uint64_t epoch;
} nx_request_slot_t;

void nx_request_initialize(nx_request_t* request);
nx_result_t nx_request_prepare(nx_request_t* request, nx_time_us_t deadline);
nx_request_state_t nx_request_state(const nx_request_t* request);
nx_result_t nx_request_admit(nx_request_t* request, nx_request_state_t state);
nx_result_t nx_request_transition(nx_request_t* request,
                                  nx_request_state_t state);
void nx_request_settle(nx_request_t* request, nx_result_t result,
                       size_t transferred);
nx_result_t nx_request_result(const nx_request_t* request, nx_result_t* result,
                              size_t* transferred);
nx_result_t nx_request_slot_bind(nx_request_slot_t* slot, nx_request_t* request,
                                 uint64_t* epoch);
nx_request_t* nx_request_slot_lookup(const nx_request_slot_t* slot,
                                     uint64_t expected_epoch);
nx_result_t nx_request_slot_release(nx_request_slot_t* slot,
                                    uint64_t expected_epoch);
#ifdef __cplusplus
}
#endif
 
#endif