githubmirror/dbus-broker

src/util/dispatch.h
75 строк2 KB
David Rheinsberg
dbus-broker: switch to c-stdaux
09 апр 2019, 17:01
09 апр 2019, 17:016a35f0e
#pragma once

/*
 * Event Dispatcher
 */

#include <c-list.h>
#include <c-stdaux.h>
#include <stdlib.h>

enum {
        _DISPATCH_E_SUCCESS,

        DISPATCH_E_EXIT,
        DISPATCH_E_FAILURE,
};

typedef struct DispatchContext DispatchContext;
typedef struct DispatchFile DispatchFile;
typedef int (*DispatchFn) (DispatchFile *file);

/* files */

struct DispatchFile {
        DispatchContext *context;
        CList ready_link;
        DispatchFn fn;

        int fd;
        uint32_t user_mask;
        uint32_t kernel_mask;
        uint32_t events;
};

#define DISPATCH_FILE_NULL(_x) {                                \
                .ready_link = C_LIST_INIT((_x).ready_link),     \
                .fd = -1,                                       \
        }

int dispatch_file_init(DispatchFile *file,
                       DispatchContext *ctx,
                       DispatchFn fn,
                       int fd,
                       uint32_t mask,
                       uint32_t events);
void dispatch_file_deinit(DispatchFile *file);

void dispatch_file_select(DispatchFile *file, uint32_t mask);
void dispatch_file_deselect(DispatchFile *file, uint32_t mask);
void dispatch_file_clear(DispatchFile *file, uint32_t mask);

/* contexts */

struct DispatchContext {
        CList ready_list;
        int epoll_fd;
        size_t n_files;
};

#define DISPATCH_CONTEXT_NULL(_x) {                             \
                .ready_list = C_LIST_INIT((_x).ready_list),     \
                .epoll_fd = -1,                                 \
        }

int dispatch_context_init(DispatchContext *ctx);
void dispatch_context_deinit(DispatchContext *ctx);

int dispatch_context_poll(DispatchContext *ctx, int timeout);
int dispatch_context_dispatch(DispatchContext *ctx);

/* inline helpers */

static inline uint32_t dispatch_file_events(DispatchFile *file) {
        return file->events & file->user_mask;
}