1/* Copyright (C) 1995-2022 Free Software Foundation, Inc.
2 This file is part of the GNU C Library.
3
4 The GNU C Library is free software; you can redistribute it and/or
5 modify it under the terms of the GNU Lesser General Public
6 License as published by the Free Software Foundation; either
7 version 2.1 of the License, or (at your option) any later version.
8
9 The GNU C Library is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 Lesser General Public License for more details.
13
14 You should have received a copy of the GNU Lesser General Public
15 License along with the GNU C Library; if not, see
16 <https://www.gnu.org/licenses/>. */
17
18#include <sys/msg.h>
19#include <ipc_priv.h>
20#include <sysdep.h>
21#include <shlib-compat.h>
22#include <errno.h>
23#include <linux/posix_types.h> /* For __kernel_mode_t. */
24
25/* POSIX states ipc_perm mode should have type of mode_t. */
26_Static_assert (sizeof ((struct msqid_ds){0}.msg_perm.mode)
27 == sizeof (mode_t),
28 "sizeof (msqid_ds.msg_perm.mode) != sizeof (mode_t)");
29
30#if __IPC_TIME64 == 0
31typedef struct msqid_ds msgctl_arg_t;
32#else
33# include <struct_kernel_msqid64_ds.h>
34
35static void
36msqid64_to_kmsqid64 (const struct __msqid64_ds *msqid64,
37 struct kernel_msqid64_ds *kmsqid)
38{
39 kmsqid->msg_perm = msqid64->msg_perm;
40 kmsqid->msg_stime = msqid64->msg_stime;
41 kmsqid->msg_stime_high = msqid64->msg_stime >> 32;
42 kmsqid->msg_rtime = msqid64->msg_rtime;
43 kmsqid->msg_rtime_high = msqid64->msg_rtime >> 32;
44 kmsqid->msg_ctime = msqid64->msg_ctime;
45 kmsqid->msg_ctime_high = msqid64->msg_ctime >> 32;
46 kmsqid->msg_cbytes = msqid64->msg_cbytes;
47 kmsqid->msg_qnum = msqid64->msg_qnum;
48 kmsqid->msg_qbytes = msqid64->msg_qbytes;
49 kmsqid->msg_lspid = msqid64->msg_lspid;
50 kmsqid->msg_lrpid = msqid64->msg_lrpid;
51}
52
53static void
54kmsqid64_to_msqid64 (const struct kernel_msqid64_ds *kmsqid,
55 struct __msqid64_ds *msqid64)
56{
57 msqid64->msg_perm = kmsqid->msg_perm;
58 msqid64->msg_stime = kmsqid->msg_stime
59 | ((__time64_t) kmsqid->msg_stime_high << 32);
60 msqid64->msg_rtime = kmsqid->msg_rtime
61 | ((__time64_t) kmsqid->msg_rtime_high << 32);
62 msqid64->msg_ctime = kmsqid->msg_ctime
63 | ((__time64_t) kmsqid->msg_ctime_high << 32);
64 msqid64->msg_cbytes = kmsqid->msg_cbytes;
65 msqid64->msg_qnum = kmsqid->msg_qnum;
66 msqid64->msg_qbytes = kmsqid->msg_qbytes;
67 msqid64->msg_lspid = kmsqid->msg_lspid;
68 msqid64->msg_lrpid = kmsqid->msg_lrpid;
69}
70
71typedef struct kernel_msqid64_ds msgctl_arg_t;
72#endif
73
74static int
75msgctl_syscall (int msqid, int cmd, msgctl_arg_t *buf)
76{
77#ifdef __ASSUME_DIRECT_SYSVIPC_SYSCALLS
78 return INLINE_SYSCALL_CALL (msgctl, msqid, cmd | __IPC_64, buf);
79#else
80 return INLINE_SYSCALL_CALL (ipc, IPCOP_msgctl, msqid, cmd | __IPC_64, 0,
81 buf);
82#endif
83}
84
85int
86__msgctl64 (int msqid, int cmd, struct __msqid64_ds *buf)
87{
88#if __IPC_TIME64
89 struct kernel_msqid64_ds ksemid, *arg = NULL;
90#else
91 msgctl_arg_t *arg;
92#endif
93
94 switch (cmd)
95 {
96 case IPC_RMID:
97 arg = NULL;
98 break;
99
100 case IPC_SET:
101 case IPC_STAT:
102 case MSG_STAT:
103 case MSG_STAT_ANY:
104#if __IPC_TIME64
105 if (buf != NULL)
106 {
107 msqid64_to_kmsqid64 (buf, &ksemid);
108 arg = &ksemid;
109 }
110# ifdef __ASSUME_SYSVIPC_BROKEN_MODE_T
111 if (cmd == IPC_SET)
112 arg->msg_perm.mode *= 0x10000U;
113# endif
114#else
115 arg = buf;
116#endif
117 break;
118
119 case IPC_INFO:
120 case MSG_INFO:
121 /* This is a Linux extension where kernel returns a 'struct msginfo'
122 instead. */
123 arg = (__typeof__ (arg)) buf;
124 break;
125
126 default:
127 __set_errno (EINVAL);
128 return -1;
129 }
130
131 int ret = msgctl_syscall (msqid, cmd, arg);
132 if (ret < 0)
133 return ret;
134
135 switch (cmd)
136 {
137 case IPC_STAT:
138 case MSG_STAT:
139 case MSG_STAT_ANY:
140#ifdef __ASSUME_SYSVIPC_BROKEN_MODE_T
141 arg->msg_perm.mode >>= 16;
142#else
143 /* Old Linux kernel versions might not clear the mode padding. */
144 if (sizeof ((struct msqid_ds){0}.msg_perm.mode)
145 != sizeof (__kernel_mode_t))
146 arg->msg_perm.mode &= 0xFFFF;
147#endif
148
149#if __IPC_TIME64
150 kmsqid64_to_msqid64 (arg, buf);
151#endif
152 }
153
154 return ret;
155}
156#if __TIMESIZE != 64
157libc_hidden_def (__msgctl64)
158
159static void
160msqid_to_msqid64 (struct __msqid64_ds *mq64, const struct msqid_ds *mq)
161{
162 mq64->msg_perm = mq->msg_perm;
163 mq64->msg_stime = mq->msg_stime
164 | ((__time64_t) mq->__msg_stime_high << 32);
165 mq64->msg_rtime = mq->msg_rtime
166 | ((__time64_t) mq->__msg_rtime_high << 32);
167 mq64->msg_ctime = mq->msg_ctime
168 | ((__time64_t) mq->__msg_ctime_high << 32);
169 mq64->msg_cbytes = mq->msg_cbytes;
170 mq64->msg_qnum = mq->msg_qnum;
171 mq64->msg_qbytes = mq->msg_qbytes;
172 mq64->msg_lspid = mq->msg_lspid;
173 mq64->msg_lrpid = mq->msg_lrpid;
174}
175
176static void
177msqid64_to_msqid (struct msqid_ds *mq, const struct __msqid64_ds *mq64)
178{
179 mq->msg_perm = mq64->msg_perm;
180 mq->msg_stime = mq64->msg_stime;
181 mq->__msg_stime_high = 0;
182 mq->msg_rtime = mq64->msg_rtime;
183 mq->__msg_rtime_high = 0;
184 mq->msg_ctime = mq64->msg_ctime;
185 mq->__msg_ctime_high = 0;
186 mq->msg_cbytes = mq64->msg_cbytes;
187 mq->msg_qnum = mq64->msg_qnum;
188 mq->msg_qbytes = mq64->msg_qbytes;
189 mq->msg_lspid = mq64->msg_lspid;
190 mq->msg_lrpid = mq64->msg_lrpid;
191}
192
193int
194__msgctl (int msqid, int cmd, struct msqid_ds *buf)
195{
196 struct __msqid64_ds msqid64, *buf64 = NULL;
197 if (buf != NULL)
198 {
199 /* This is a Linux extension where kernel returns a 'struct msginfo'
200 instead. */
201 if (cmd == IPC_INFO || cmd == MSG_INFO)
202 buf64 = (struct __msqid64_ds *) buf;
203 else
204 {
205 msqid_to_msqid64 (&msqid64, buf);
206 buf64 = &msqid64;
207 }
208 }
209
210 int ret = __msgctl64 (msqid, cmd, buf64);
211 if (ret < 0)
212 return ret;
213
214 switch (cmd)
215 {
216 case IPC_STAT:
217 case MSG_STAT:
218 case MSG_STAT_ANY:
219 msqid64_to_msqid (buf, buf64);
220 }
221
222 return ret;
223}
224#endif
225
226#ifndef DEFAULT_VERSION
227# ifndef __ASSUME_SYSVIPC_BROKEN_MODE_T
228# define DEFAULT_VERSION GLIBC_2_2
229# else
230# define DEFAULT_VERSION GLIBC_2_31
231# endif
232#endif
233versioned_symbol (libc, __msgctl, msgctl, DEFAULT_VERSION);
234
235#if defined __ASSUME_SYSVIPC_BROKEN_MODE_T \
236 && SHLIB_COMPAT (libc, GLIBC_2_2, GLIBC_2_31)
237int
238attribute_compat_text_section
239__msgctl_mode16 (int msqid, int cmd, struct msqid_ds *buf)
240{
241 return msgctl_syscall (msqid, cmd, (msgctl_arg_t *) buf);
242}
243compat_symbol (libc, __msgctl_mode16, msgctl, GLIBC_2_2);
244#endif
245
246#if SHLIB_COMPAT (libc, GLIBC_2_0, GLIBC_2_2)
247struct __old_msqid_ds
248{
249 struct __old_ipc_perm msg_perm; /* structure describing operation permission */
250 struct msg *__msg_first; /* pointer to first message on queue */
251 struct msg *__msg_last; /* pointer to last message on queue */
252 __time_t msg_stime; /* time of last msgsnd command */
253 __time_t msg_rtime; /* time of last msgrcv command */
254 __time_t msg_ctime; /* time of last change */
255 struct wait_queue *__wwait; /* ??? */
256 struct wait_queue *__rwait; /* ??? */
257 unsigned short int __msg_cbytes; /* current number of bytes on queue */
258 unsigned short int msg_qnum; /* number of messages currently on queue */
259 unsigned short int msg_qbytes; /* max number of bytes allowed on queue */
260 __ipc_pid_t msg_lspid; /* pid of last msgsnd() */
261 __ipc_pid_t msg_lrpid; /* pid of last msgrcv() */
262};
263
264int
265attribute_compat_text_section
266__old_msgctl (int msqid, int cmd, struct __old_msqid_ds *buf)
267{
268#if defined __ASSUME_DIRECT_SYSVIPC_SYSCALLS \
269 && !defined __ASSUME_SYSVIPC_DEFAULT_IPC_64
270 /* For architecture that have wire-up msgctl but also have __IPC_64 to a
271 value different than default (0x0) it means the compat symbol used the
272 __NR_ipc syscall. */
273 return INLINE_SYSCALL_CALL (msgctl, msqid, cmd, buf);
274#else
275 return INLINE_SYSCALL_CALL (ipc, IPCOP_msgctl, msqid, cmd, 0, buf);
276#endif
277}
278compat_symbol (libc, __old_msgctl, msgctl, GLIBC_2_0);
279#endif
280