FreeBSD/Linux Kernel Cross Reference
sys/sys/mqueue.h
1 /* $NetBSD: mqueue.h,v 1.4.16.2 2009/10/16 06:37:51 snj Exp $ */
2
3 /*
4 * Copyright (c) 2007-2009 Mindaugas Rasiukevicius <rmind at NetBSD org>
5 * All rights reserved.
6 *
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
9 * are met:
10 * 1. Redistributions of source code must retain the above copyright
11 * notice, this list of conditions and the following disclaimer.
12 * 2. Redistributions in binary form must reproduce the above copyright
13 * notice, this list of conditions and the following disclaimer in the
14 * documentation and/or other materials provided with the distribution.
15 *
16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
17 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19 * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
20 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
22 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
24 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
26 * SUCH DAMAGE.
27 */
28
29 #ifndef _SYS_MQUEUE_H_
30 #define _SYS_MQUEUE_H_
31
32 /* Maximal number of mqueue descriptors, that process could open */
33 #define MQ_OPEN_MAX 512
34
35 /* Maximal priority of the message */
36 #define MQ_PRIO_MAX 32
37
38 struct mq_attr {
39 long mq_flags; /* Flags of message queue */
40 long mq_maxmsg; /* Maximum number of messages */
41 long mq_msgsize; /* Maximum size of the message */
42 long mq_curmsgs; /* Count of the queued messages */
43 };
44
45 /* Internal kernel data */
46 #ifdef _KERNEL
47
48 #include <sys/condvar.h>
49 #include <sys/mutex.h>
50 #include <sys/queue.h>
51 #include <sys/selinfo.h>
52 #include <sys/types.h>
53
54 /*
55 * Flags below are used in mq_flags for internal
56 * purposes, this is appropriate according to POSIX.
57 */
58
59 /* Message queue is unlinking */
60 #define MQ_UNLINK 0x10000000
61 /* There are receive-waiters */
62 #define MQ_RECEIVE 0x20000000
63
64 /* Maximal length of mqueue name */
65 #define MQ_NAMELEN (NAME_MAX + 1)
66
67 /* Default size of the message */
68 #define MQ_DEF_MSGSIZE 1024
69
70 /* Structure of the message queue */
71 struct mqueue {
72 char mq_name[MQ_NAMELEN];
73 kmutex_t mq_mtx;
74 kcondvar_t mq_send_cv;
75 kcondvar_t mq_recv_cv;
76 struct mq_attr mq_attrib;
77 /* Notification */
78 struct selinfo mq_rsel;
79 struct selinfo mq_wsel;
80 struct sigevent mq_sig_notify;
81 struct proc * mq_notify_proc;
82 /* Permissions */
83 mode_t mq_mode;
84 uid_t mq_euid;
85 gid_t mq_egid;
86 /* Reference counter, head of the message queue */
87 u_int mq_refcnt;
88 TAILQ_HEAD(, mq_msg) mq_head;
89 /* Entry of the global list */
90 LIST_ENTRY(mqueue) mq_list;
91 };
92
93 /* Structure of the message */
94 struct mq_msg {
95 TAILQ_ENTRY(mq_msg) msg_queue;
96 size_t msg_len;
97 u_int msg_prio;
98 uint8_t msg_ptr[1];
99 };
100
101 /* Prototypes */
102 void mqueue_sysinit(void);
103 void mqueue_print_list(void (*pr)(const char *, ...));
104
105 #endif /* _KERNEL */
106
107 #endif /* _SYS_MQUEUE_H_ */
Cache object: fb68af370cf4b54fb8869cc917446294
|