native.h

Go to the documentation of this file.

#ifndef NEXUS_OS_NATIVE_H
#define NEXUS_OS_NATIVE_H
#include "nexus/os/wait.h"
#include <pthread.h>
#include <stddef.h>
 
#ifdef __cplusplus
extern "C" {
#endif

typedef struct {
    pthread_mutex_t mutex;
    pthread_cond_t condition;
    uint32_t sequence;
    bool initialized;
    bool waiting;
} nx_native_notify_t;

typedef struct {
    pthread_mutex_t mutex;
    pthread_cond_t readable;
    pthread_cond_t writable;
    uint8_t* bytes;
    size_t depth;
    size_t item_size;
    size_t head;
    size_t count;
    size_t users;
    bool closed;
    bool initialized;
} nx_native_queue_t;

typedef struct {
    pthread_t thread;
    void (*entry)(void*);
    void* context;
    bool started;
} nx_native_task_t;

uint64_t nx_native_now_us(void);
nx_result_t nx_native_notify_init(nx_native_notify_t* notification);
nx_wait_port_t nx_native_notify_port(nx_native_notify_t* notification);
nx_result_t nx_native_notify_destroy(nx_native_notify_t* notification);
nx_result_t nx_native_queue_init(nx_native_queue_t* queue, void* storage,
                                 size_t storage_bytes, size_t depth,
                                 size_t item_size);
nx_result_t nx_native_queue_send(nx_native_queue_t* queue, const void* item,
                                 uint64_t deadline_us);
nx_result_t nx_native_queue_receive(nx_native_queue_t* queue, void* item,
                                    uint64_t deadline_us);
nx_result_t nx_native_queue_close(nx_native_queue_t* queue);
nx_result_t nx_native_queue_destroy(nx_native_queue_t* queue);
nx_result_t nx_native_task_start(nx_native_task_t* task, void* stack,
                                 size_t stack_bytes, void (*entry)(void*),
                                 void* context);
nx_result_t nx_native_task_join(nx_native_task_t* task);
 
#ifdef __cplusplus
}
#endif
 
#endif /* NEXUS_OS_NATIVE_H */