githubmirror/dbus-broker

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

/*
 * Connection
 */

#include <c-stdaux.h>
#include <stdlib.h>
#include <sys/types.h>
#include "dbus/sasl.h"
#include "dbus/socket.h"
#include "util/dispatch.h"

typedef struct Connection Connection;
typedef struct Message Message;
typedef struct User User;

enum {
        _CONNECTION_E_SUCCESS,

        CONNECTION_E_SASL_FAILURE,
        CONNECTION_E_SASL_VIOLATION,

        CONNECTION_E_EOF,
        CONNECTION_E_QUOTA,
        CONNECTION_E_UNEXPECTED_FDS,
};

struct Connection {
        Socket socket;
        DispatchFile socket_file;
        SASLServer sasl_server;
        SASLClient sasl_client;

        bool server : 1;
        bool authenticated : 1;
};

#define CONNECTION_NULL(_x) {                                           \
                .socket = SOCKET_NULL((_x).socket),                     \
                .socket_file = DISPATCH_FILE_NULL((_x).socket_file),    \
                .sasl_server = SASL_SERVER_NULL,                        \
                .sasl_client = SASL_CLIENT_NULL,                        \
        }

int connection_init_server(Connection *connection,
                           DispatchContext *dispatch_ctx,
                           DispatchFn dispatch_fn,
                           User *user,
                           const char *guid,
                           int fd);
int connection_init_client(Connection *connection,
                           DispatchContext *dispatch_ctx,
                           DispatchFn dispatch_fn,
                           User *user,
                           int fd);
void connection_deinit(Connection *connection);

int connection_open(Connection *connection);
void connection_shutdown(Connection *connection);
void connection_close(Connection *connection);
int connection_dispatch(Connection *connection, uint32_t events);

int connection_dequeue(Connection *connection, Message **messagep);
int connection_queue(Connection *connection, User *user, Message *message);

C_DEFINE_CLEANUP(Connection *, connection_deinit);

/* inline helpers */

static inline bool connection_is_running(Connection *connection) {
        return socket_is_running(&connection->socket);
}