bus_owner.h

Go to the documentation of this file.

#ifndef NEXUS_COMPONENTS_BUS_OWNER_H
#define NEXUS_COMPONENTS_BUS_OWNER_H
#include "nexus/core/request.h"
#include "nexus/os/wait.h"
 
#ifdef __cplusplus
extern "C" {
#endif

typedef struct {
    void* context;
    uintptr_t (*enter)(void*);
    void (*leave)(void*, uintptr_t);
} nx_owner_guard_port_t;

typedef struct {
    void* context;
    nx_result_t (*start)(void*, void* operation, nx_time_us_t deadline);
    nx_result_t (*service)(void*, nx_result_t* result, size_t* transferred);
    nx_result_t (*cancel)(void*);
    bool terminal_authority;
} nx_owner_executor_port_t;

typedef struct {
    size_t slot;
    uint64_t epoch;
} nx_owner_ticket_t;

typedef struct {
    nx_request_slot_t identity;
    void* operation;
    nx_wait_port_t completion;
    size_t next;
    bool cancel_requested;
    bool cancel_sent;
} nx_owner_slot_t;

typedef struct {
    nx_owner_slot_t* slots;
    size_t capacity;
    size_t head;
    size_t tail;
    size_t active;
    size_t free_head;
    nx_owner_guard_port_t guard;
    nx_owner_executor_port_t executor;
    nx_clock_t clock;
    nx_wait_port_t wake;
    nx_result_t cancellation_result;
    bool accepting;
    bool servicing;
} nx_bus_owner_t;

nx_result_t nx_bus_owner_init(nx_bus_owner_t* owner, nx_owner_slot_t* slots,
                              size_t capacity, nx_owner_guard_port_t guard,
                              nx_owner_executor_port_t executor,
                              nx_clock_t clock, const nx_wait_port_t* wake);
nx_result_t nx_bus_owner_submit(nx_bus_owner_t* owner, nx_request_t* request,
                                void* operation,
                                const nx_wait_port_t* completion,
                                nx_owner_ticket_t* ticket);
nx_result_t nx_bus_owner_cancel(nx_bus_owner_t* owner,
                                nx_owner_ticket_t ticket);
nx_result_t nx_bus_owner_service(nx_bus_owner_t* owner);
void nx_bus_owner_stop(nx_bus_owner_t* owner);
bool nx_bus_owner_idle(nx_bus_owner_t* owner);
 
#ifdef __cplusplus
}
#endif
 
#endif /* NEXUS_COMPONENTS_BUS_OWNER_H */