mq.h

Go to the documentation of this file.

/*
Copyright (C) 2020- The University of Notre Dame
This software is distributed under the GNU General Public License.
See the file COPYING for details.
*/

#ifndef MQ_H
#define MQ_H

#include <stddef.h>
#include <time.h>

#include "buffer.h"

typedef enum {
        MQ_MSG_NONE = 0,
        MQ_MSG_BUFFER,
        MQ_MSG_FD,
} mq_msg_t;


//---------Basic Functions----------------//

struct mq *mq_connect(const char *addr, int port);

struct mq *mq_serve(const char *addr, int port);

void mq_close(struct mq *mq);

struct mq *mq_accept(struct mq *server);

int mq_wait(struct mq *mq, time_t stoptime);

void mq_set_tag(struct mq *mq, void *tag);

void *mq_get_tag(struct mq *mq);

int mq_address_local(struct mq *mq, char *addr, int *port);

int mq_address_remote(struct mq *mq, char *addr, int *port);

int mq_geterror(struct mq *mq);

//------------Polling API-----------------//

struct mq_poll *mq_poll_create(void);

void mq_poll_delete(struct mq_poll *p);

int mq_poll_add(struct mq_poll *p, struct mq *mq);

int mq_poll_rm(struct mq_poll *p, struct mq *mq);

int mq_poll_wait(struct mq_poll *p, time_t stoptime);

struct mq *mq_poll_readable(struct mq_poll *p);

struct mq *mq_poll_acceptable(struct mq_poll *p);

struct mq *mq_poll_error(struct mq_poll *p);


//------------Send/Recv-------------------//

int mq_send_buffer(struct mq *mq, buffer_t *buf, size_t maxlen);

int mq_send_fd(struct mq *mq, int fd, size_t maxlen);

int mq_store_buffer(struct mq *mq, buffer_t *buf, size_t maxlen);

int mq_store_fd(struct mq *mq, int fd, size_t maxlen);

mq_msg_t mq_recv(struct mq *mq, size_t *length);

#endif