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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
/* sys/msg.h
Copyright 2002 Red Hat Inc.
Written by Conrad Scott <conrad.scott@dsl.pipex.com>
This file is part of Cygwin.
This software is a copyrighted work licensed under the terms of the
Cygwin license. Please consult the file "CYGWIN_LICENSE" for
details. */
#ifndef _SYS_MSG_H
#define _SYS_MSG_H
#include <cygwin/ipc.h>
#ifdef __cplusplus
extern "C"
{
#endif
/* Message operation flags:
*/
#define MSG_NOERROR 0x01 /* No error if big message. */
/* Command definitions for the semctl () function:
*/
#define MSG_STAT 0x2000 /* For ipcs(8) */
#define MSG_INFO 0x2001 /* For ipcs(8) */
/* Used for the number of messages in the message queue.
*/
typedef long int msgqnum_t;
/* Used for the number of bytes allowed in a message queue.
*/
typedef long int msglen_t;
struct msqid_ds
{
struct ipc_perm msg_perm; /* Operation permission structure. */
msglen_t msg_cbytes; /* Number of bytes currently on queue. */
msgqnum_t msg_qnum; /* Number of messages currently on queue. */
msglen_t msg_qbytes; /* Maximum number of bytes allowed on queue. */
pid_t msg_lspid; /* Process ID of last msgsnd (). */
pid_t msg_lrpid; /* Process ID of last msgrcv (). */
timestruc_t msg_stim; /* Time of last msgsnd (). */
timestruc_t msg_rtim; /* Time of last msgrcv (). */
timestruc_t msg_ctim; /* Time of last change. */
long msg_spare4[2];
};
#define msg_stime msg_stim.tv_sec
#define msg_rtime msg_rtim.tv_sec
#define msg_ctime msg_ctim.tv_sec
/* Buffer type for msgctl (IPC_INFO, ...) as used by ipcs(8).
*/
struct msginfo
{
unsigned long msgpool; /* Maximum number of message bytes,
system wide. */
unsigned long msgmax; /* Maximum number of bytes per
message. */
unsigned long msgmnb; /* Maximum number of bytes on any one
message queue. */
unsigned long msgmni; /* Maximum number of message queues,
system wide. */
unsigned long msgtql; /* Maximum number of messages, system
wide. */
unsigned long msg_spare[4];
};
/* Buffer type for msgctl (MSG_INFO, ...) as used by ipcs(8).
*/
struct msg_info
{
unsigned long msg_ids; /* Number of allocated queues. */
unsigned long msg_num; /* Number of messages, system wide. */
unsigned long msg_tot; /* Size in bytes of messages, system wide. */
};
int msgctl (int msqid, int cmd, struct msqid_ds *buf);
int msgget (key_t key, int msgflg);
ssize_t msgrcv (int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg);
int msgsnd (int msqid, const void *msgp, size_t msgsz, int msgflg);
#ifdef __cplusplus
}
#endif
#endif /* _SYS_MSG_H */
|
