mqueue.h

mgcp协议源代码和测试程序,还有一个编译器

#ifndef __MQUEUE_H__
#define __MQUEUE_H__

#ifdef __cplusplus
extern "C" {
#endif


typedef unsigned int mqd_t;

struct mq_attr
{
	long mq_flags;   /* Message queue flags. */
	long mq_maxmsg;  /* Maximum number of messages. */
	long mq_msgsize; /* Maximum message size. */
	long mq_curmsgs; /* Number of messages currently queued. */
};

#define O_RDONLY    0x00000000	/* Open read-only */
#define O_WRONLY    0x00000001	/* Open write-only */
#define O_RDWR      0x00000002	/* Reading and writing */
#define O_CREAT     0x00000100	/* Create file if it doesn't exist already */
#define O_EXCL      0x00000400	/* Error if create and file exists */
#define O_NONBLOCK  0x00001000	/* Do not block on open */

int mq_close(mqd_t mqdes);
mqd_t mq_open(const char *name, int oflag, ...);
int mq_receive(mqd_t mqdes, char *msg_ptr, size_t msg_len, unsigned *msg_prio);
int mq_send(mqd_t mqdes, const char *msg_ptr, size_t msg_len, unsigned msg_prio);
int mq_timedreceive(mqd_t mqdes, char *msg_ptr, size_t msg_len,
					unsigned *msg_prio, const struct timespec *abs_timeout);
int mq_timedsend(mqd_t mqdes, const char *msg_ptr, size_t msg_len,
				 unsigned msg_prio, const struct timespec *abs_timeout);
int mq_unlink(const char *name);


#ifdef __cplusplus
}
#endif

#endif