mq_ntf.h


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

#ifndef __MQ_NTF_H
#define __MQ_NTF_H

#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <mqueue.h>

#include "debug.h"


//async io multiplexer
typedef struct mq_ntf_io_mplx
{
	struct timeval tv;
	fd_set io_fds;
} mq_ntf_io_mplx;

#define MQ_OUT  1
#define MQ_IN   2

/*
supposed format agni-[id]-[in/out]
in is for input of thread (send to in and thread will recieve),
out if for output of thread (read from out to recieve from thread)
*/
#define MQ_PREFIX "/agni-"
typedef struct mq_ntf_mdt
{
	int id;
	mqd_t mq_in;
	mqd_t mq_out;
	//mq_ntf_io_mplx io_mplx;
	//_Atomic int used; nado?
} mq_ntf_mdt;

mq_ntf_mdt *mq_ntf_create(int id);
int mq_ntf_open(mq_ntf_mdt *mq, int id);
int mq_ntf_select(mq_ntf_mdt *mq, int dir);
int mq_ntf_read(mq_ntf_mdt *mq, int dir, char *buf, size_t size);
int mq_ntf_write(mq_ntf_mdt *mq, int dir, const char *buf, size_t size);
int mq_ntf_count(mq_ntf_mdt *mq, int dir);
int mq_ntf_close(mq_ntf_mdt *mq);
int mq_drain_q(mqd_t mqd);
int mq_ntf_drain(mq_ntf_mdt *mq);
int mq_ntf_getattr(mq_ntf_mdt *mq, int dir, struct mq_attr **attr);
void mq_ntf_free(mq_ntf_mdt *mq);

#endif