netbsd32_mqueue.c revision 1.5.2.2
1 1.5.2.2 skrll /* $NetBSD: netbsd32_mqueue.c,v 1.5.2.2 2015/09/22 12:05:55 skrll Exp $ */ 2 1.5.2.2 skrll 3 1.5.2.2 skrll /*- 4 1.5.2.2 skrll * Copyright (c) 2008 The NetBSD Foundation, Inc. 5 1.5.2.2 skrll * All rights reserved. 6 1.5.2.2 skrll * 7 1.5.2.2 skrll * This code is derived from software developed for The NetBSD Foundation. 8 1.5.2.2 skrll * 9 1.5.2.2 skrll * Redistribution and use in source and binary forms, with or without 10 1.5.2.2 skrll * modification, are permitted provided that the following conditions 11 1.5.2.2 skrll * are met: 12 1.5.2.2 skrll * 1. Redistributions of source code must retain the above copyright 13 1.5.2.2 skrll * notice, this list of conditions and the following disclaimer. 14 1.5.2.2 skrll * 2. Redistributions in binary form must reproduce the above copyright 15 1.5.2.2 skrll * notice, this list of conditions and the following disclaimer in the 16 1.5.2.2 skrll * documentation and/or other materials provided with the distribution. 17 1.5.2.2 skrll * 18 1.5.2.2 skrll * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS 19 1.5.2.2 skrll * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED 20 1.5.2.2 skrll * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 21 1.5.2.2 skrll * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS 22 1.5.2.2 skrll * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 23 1.5.2.2 skrll * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 24 1.5.2.2 skrll * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 25 1.5.2.2 skrll * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 26 1.5.2.2 skrll * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) 27 1.5.2.2 skrll * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 28 1.5.2.2 skrll * POSSIBILITY OF SUCH DAMAGE. 29 1.5.2.2 skrll */ 30 1.5.2.2 skrll 31 1.5.2.2 skrll #include <sys/cdefs.h> 32 1.5.2.2 skrll __KERNEL_RCSID(0, "$NetBSD: netbsd32_mqueue.c,v 1.5.2.2 2015/09/22 12:05:55 skrll Exp $"); 33 1.5.2.2 skrll 34 1.5.2.2 skrll #if defined(_KERNEL_OPT) 35 1.5.2.2 skrll #include "opt_compat_netbsd.h" 36 1.5.2.2 skrll #endif 37 1.5.2.2 skrll 38 1.5.2.2 skrll #include <sys/param.h> 39 1.5.2.2 skrll #include <sys/dirent.h> 40 1.5.2.2 skrll #include <sys/filedesc.h> 41 1.5.2.2 skrll #include <sys/fcntl.h> 42 1.5.2.2 skrll #include <sys/module.h> 43 1.5.2.2 skrll 44 1.5.2.2 skrll #include <compat/netbsd32/netbsd32.h> 45 1.5.2.2 skrll #include <compat/netbsd32/netbsd32_syscall.h> 46 1.5.2.2 skrll #include <compat/netbsd32/netbsd32_syscallargs.h> 47 1.5.2.2 skrll #include <compat/netbsd32/netbsd32_conv.h> 48 1.5.2.2 skrll 49 1.5.2.2 skrll 50 1.5.2.2 skrll int 51 1.5.2.2 skrll netbsd32_mq_open(struct lwp *l, const struct netbsd32_mq_open_args *uap, 52 1.5.2.2 skrll register_t *retval) 53 1.5.2.2 skrll { 54 1.5.2.2 skrll /* { 55 1.5.2.2 skrll syscallarg(const netbsd32_charp) name; 56 1.5.2.2 skrll syscallarg(int) oflag; 57 1.5.2.2 skrll syscallarg(mode_t) mode; 58 1.5.2.2 skrll syscallarg(struct netbsd32_mq_attrp_t) attr; 59 1.5.2.2 skrll } */ 60 1.5.2.2 skrll struct netbsd32_mq_attr attr32; 61 1.5.2.2 skrll struct mq_attr *attr = NULL, a; 62 1.5.2.2 skrll int error; 63 1.5.2.2 skrll 64 1.5.2.2 skrll if ((SCARG(uap, oflag) & O_CREAT) && SCARG_P32(uap, attr) != NULL) { 65 1.5.2.2 skrll error = copyin(SCARG_P32(uap, attr), &attr32, sizeof(attr32)); 66 1.5.2.2 skrll if (error) 67 1.5.2.2 skrll return error; 68 1.5.2.2 skrll netbsd32_to_mq_attr(&attr32, &a); 69 1.5.2.2 skrll attr = &a; 70 1.5.2.2 skrll } 71 1.5.2.2 skrll 72 1.5.2.2 skrll return mq_handle_open(l, SCARG_P32(uap, name), SCARG(uap, oflag), 73 1.5.2.2 skrll SCARG(uap, mode), attr, retval); 74 1.5.2.2 skrll } 75 1.5.2.2 skrll 76 1.5.2.2 skrll int 77 1.5.2.2 skrll netbsd32_mq_close(struct lwp *l, const struct netbsd32_mq_close_args *uap, 78 1.5.2.2 skrll register_t *retval) 79 1.5.2.2 skrll { 80 1.5.2.2 skrll /* { 81 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 82 1.5.2.2 skrll } */ 83 1.5.2.2 skrll 84 1.5.2.2 skrll return netbsd32_close(l, (const void*)uap, retval); 85 1.5.2.2 skrll } 86 1.5.2.2 skrll 87 1.5.2.2 skrll int 88 1.5.2.2 skrll netbsd32_mq_unlink(struct lwp *l, const struct netbsd32_mq_unlink_args *uap, 89 1.5.2.2 skrll register_t *retval) 90 1.5.2.2 skrll { 91 1.5.2.2 skrll /* { 92 1.5.2.2 skrll syscallarg(const netbsd32_charp) name; 93 1.5.2.2 skrll } */ 94 1.5.2.2 skrll struct sys_mq_unlink_args ua; 95 1.5.2.2 skrll 96 1.5.2.2 skrll NETBSD32TOP_UAP(name, const char); 97 1.5.2.2 skrll return sys_mq_unlink(l, &ua, retval); 98 1.5.2.2 skrll } 99 1.5.2.2 skrll 100 1.5.2.2 skrll int 101 1.5.2.2 skrll netbsd32_mq_getattr(struct lwp *l, const struct netbsd32_mq_getattr_args *uap, 102 1.5.2.2 skrll register_t *retval) 103 1.5.2.2 skrll { 104 1.5.2.2 skrll /* { 105 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 106 1.5.2.2 skrll syscallarg(netbsd32_mq_attrp_t) mqstat; 107 1.5.2.2 skrll } */ 108 1.5.2.2 skrll struct mqueue *mq; 109 1.5.2.2 skrll struct mq_attr attr; 110 1.5.2.2 skrll struct netbsd32_mq_attr a32; 111 1.5.2.2 skrll int error; 112 1.5.2.2 skrll 113 1.5.2.2 skrll error = mqueue_get(SCARG(uap, mqdes), 0, &mq); 114 1.5.2.2 skrll if (error) 115 1.5.2.2 skrll return error; 116 1.5.2.2 skrll 117 1.5.2.2 skrll memcpy(&attr, &mq->mq_attrib, sizeof(struct mq_attr)); 118 1.5.2.2 skrll mutex_exit(&mq->mq_mtx); 119 1.5.2.2 skrll fd_putfile((int)SCARG(uap, mqdes)); 120 1.5.2.2 skrll netbsd32_from_mq_attr(&attr, &a32); 121 1.5.2.2 skrll return copyout(&a32, SCARG_P32(uap,mqstat), sizeof(a32)); 122 1.5.2.2 skrll } 123 1.5.2.2 skrll 124 1.5.2.2 skrll int 125 1.5.2.2 skrll netbsd32_mq_setattr(struct lwp *l, const struct netbsd32_mq_setattr_args *uap, 126 1.5.2.2 skrll register_t *retval) 127 1.5.2.2 skrll { 128 1.5.2.2 skrll /* { 129 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 130 1.5.2.2 skrll syscallarg(const netbsd32_mq_attrp_t) mqstat; 131 1.5.2.2 skrll syscallarg(netbsd32_mq_attrp_t) omqstat; 132 1.5.2.2 skrll } */ 133 1.5.2.2 skrll struct mqueue *mq; 134 1.5.2.2 skrll struct netbsd32_mq_attr attr32; 135 1.5.2.2 skrll struct mq_attr attr; 136 1.5.2.2 skrll int error, nonblock; 137 1.5.2.2 skrll 138 1.5.2.2 skrll error = copyin(SCARG_P32(uap, mqstat), &attr32, sizeof(attr32)); 139 1.5.2.2 skrll if (error) 140 1.5.2.2 skrll return error; 141 1.5.2.2 skrll netbsd32_to_mq_attr(&attr32, &attr); 142 1.5.2.2 skrll nonblock = (attr.mq_flags & O_NONBLOCK); 143 1.5.2.2 skrll 144 1.5.2.2 skrll error = mqueue_get(SCARG(uap, mqdes), 0, &mq); 145 1.5.2.2 skrll if (error) 146 1.5.2.2 skrll return error; 147 1.5.2.2 skrll 148 1.5.2.2 skrll /* Copy the old attributes, if needed */ 149 1.5.2.2 skrll if (SCARG_P32(uap, omqstat)) 150 1.5.2.2 skrll memcpy(&attr, &mq->mq_attrib, sizeof(struct mq_attr)); 151 1.5.2.2 skrll 152 1.5.2.2 skrll /* Ignore everything, except O_NONBLOCK */ 153 1.5.2.2 skrll if (nonblock) 154 1.5.2.2 skrll mq->mq_attrib.mq_flags |= O_NONBLOCK; 155 1.5.2.2 skrll else 156 1.5.2.2 skrll mq->mq_attrib.mq_flags &= ~O_NONBLOCK; 157 1.5.2.2 skrll 158 1.5.2.2 skrll mutex_exit(&mq->mq_mtx); 159 1.5.2.2 skrll fd_putfile((int)SCARG(uap, mqdes)); 160 1.5.2.2 skrll 161 1.5.2.2 skrll /* 162 1.5.2.2 skrll * Copy the data to the user-space. 163 1.5.2.2 skrll * Note: According to POSIX, the new attributes should not be set in 164 1.5.2.2 skrll * case of fail - this would be violated. 165 1.5.2.2 skrll */ 166 1.5.2.2 skrll if (SCARG_P32(uap, omqstat)) { 167 1.5.2.2 skrll netbsd32_from_mq_attr(&attr, &attr32); 168 1.5.2.2 skrll error = copyout(&attr32, SCARG_P32(uap, omqstat), 169 1.5.2.2 skrll sizeof(attr32)); 170 1.5.2.2 skrll } 171 1.5.2.2 skrll 172 1.5.2.2 skrll return error; 173 1.5.2.2 skrll } 174 1.5.2.2 skrll 175 1.5.2.2 skrll int 176 1.5.2.2 skrll netbsd32_mq_notify(struct lwp *l, const struct netbsd32_mq_notify_args *uap, 177 1.5.2.2 skrll register_t *result) 178 1.5.2.2 skrll { 179 1.5.2.2 skrll /* { 180 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 181 1.5.2.2 skrll syscallarg(const netbsd32_sigeventp_t) notification; 182 1.5.2.2 skrll } */ 183 1.5.2.2 skrll struct mqueue *mq; 184 1.5.2.2 skrll struct netbsd32_sigevent sig32; 185 1.5.2.2 skrll int error; 186 1.5.2.2 skrll 187 1.5.2.2 skrll if (SCARG_P32(uap, notification)) { 188 1.5.2.2 skrll /* Get the signal from user-space */ 189 1.5.2.2 skrll error = copyin(SCARG_P32(uap, notification), &sig32, 190 1.5.2.2 skrll sizeof(sig32)); 191 1.5.2.2 skrll if (error) 192 1.5.2.2 skrll return error; 193 1.5.2.2 skrll if (sig32.sigev_notify == SIGEV_SIGNAL && 194 1.5.2.2 skrll (sig32.sigev_signo <=0 || sig32.sigev_signo >= NSIG)) 195 1.5.2.2 skrll return EINVAL; 196 1.5.2.2 skrll } 197 1.5.2.2 skrll 198 1.5.2.2 skrll error = mqueue_get(SCARG(uap, mqdes), 0, &mq); 199 1.5.2.2 skrll if (error) { 200 1.5.2.2 skrll return error; 201 1.5.2.2 skrll } 202 1.5.2.2 skrll if (SCARG_P32(uap, notification)) { 203 1.5.2.2 skrll /* Register notification: set the signal and target process */ 204 1.5.2.2 skrll if (mq->mq_notify_proc == NULL) { 205 1.5.2.2 skrll netbsd32_to_sigevent(&sig32, &mq->mq_sig_notify); 206 1.5.2.2 skrll mq->mq_notify_proc = l->l_proc; 207 1.5.2.2 skrll } else { 208 1.5.2.2 skrll /* Fail if someone else already registered */ 209 1.5.2.2 skrll error = EBUSY; 210 1.5.2.2 skrll } 211 1.5.2.2 skrll } else { 212 1.5.2.2 skrll /* Unregister the notification */ 213 1.5.2.2 skrll mq->mq_notify_proc = NULL; 214 1.5.2.2 skrll } 215 1.5.2.2 skrll mutex_exit(&mq->mq_mtx); 216 1.5.2.2 skrll fd_putfile((int)SCARG(uap, mqdes)); 217 1.5.2.2 skrll 218 1.5.2.2 skrll return error; 219 1.5.2.2 skrll } 220 1.5.2.2 skrll 221 1.5.2.2 skrll int 222 1.5.2.2 skrll netbsd32_mq_send(struct lwp *l, const struct netbsd32_mq_send_args *uap, 223 1.5.2.2 skrll register_t *result) 224 1.5.2.2 skrll { 225 1.5.2.2 skrll /* { 226 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 227 1.5.2.2 skrll syscallarg(const netbsd32_charp) msg_ptr; 228 1.5.2.2 skrll syscallarg(netbsd32_size_t) msg_len; 229 1.5.2.2 skrll syscallarg(unsigned) msg_prio; 230 1.5.2.2 skrll } */ 231 1.5.2.2 skrll 232 1.5.2.2 skrll 233 1.5.2.2 skrll return mq_send1(SCARG(uap, mqdes), SCARG_P32(uap, msg_ptr), 234 1.5.2.2 skrll SCARG(uap, msg_len), SCARG(uap, msg_prio), NULL); 235 1.5.2.2 skrll } 236 1.5.2.2 skrll 237 1.5.2.2 skrll int 238 1.5.2.2 skrll netbsd32_mq_receive(struct lwp *l, const struct netbsd32_mq_receive_args *uap, 239 1.5.2.2 skrll register_t *retval) 240 1.5.2.2 skrll { 241 1.5.2.2 skrll /* { 242 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 243 1.5.2.2 skrll syscallarg(netbsd32_charp) msg_ptr; 244 1.5.2.2 skrll syscallarg(netbsd32_size_t) msg_len; 245 1.5.2.2 skrll syscallarg(netbsd32_uintp) msg_prio; 246 1.5.2.2 skrll } */ 247 1.5.2.2 skrll ssize_t mlen; 248 1.5.2.2 skrll int error; 249 1.5.2.2 skrll 250 1.5.2.2 skrll error = mq_recv1(SCARG(uap, mqdes), SCARG_P32(uap, msg_ptr), 251 1.5.2.2 skrll SCARG(uap, msg_len), SCARG_P32(uap, msg_prio), NULL, &mlen); 252 1.5.2.2 skrll if (error == 0) 253 1.5.2.2 skrll *retval = mlen; 254 1.5.2.2 skrll 255 1.5.2.2 skrll return error; 256 1.5.2.2 skrll } 257 1.5.2.2 skrll 258 1.5.2.2 skrll int 259 1.5.2.2 skrll netbsd32___mq_timedsend50(struct lwp *l, 260 1.5.2.2 skrll const struct netbsd32___mq_timedsend50_args *uap, register_t *retval) 261 1.5.2.2 skrll { 262 1.5.2.2 skrll /* { 263 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 264 1.5.2.2 skrll syscallarg(const netbsd32_charp) msg_ptr; 265 1.5.2.2 skrll syscallarg(netbsd32_size_t) msg_len; 266 1.5.2.2 skrll syscallarg(unsigned) msg_prio; 267 1.5.2.2 skrll syscallarg(const netbsd32_timespecp_t) abs_timeout; 268 1.5.2.2 skrll } */ 269 1.5.2.2 skrll struct timespec ts, *tsp; 270 1.5.2.2 skrll struct netbsd32_timespec ts32; 271 1.5.2.2 skrll int error; 272 1.5.2.2 skrll 273 1.5.2.2 skrll /* Get and convert time value */ 274 1.5.2.2 skrll if (SCARG_P32(uap, abs_timeout)) { 275 1.5.2.2 skrll error = copyin(SCARG_P32(uap, abs_timeout), &ts32, 276 1.5.2.2 skrll sizeof(ts32)); 277 1.5.2.2 skrll if (error) 278 1.5.2.2 skrll return error; 279 1.5.2.2 skrll netbsd32_to_timespec(&ts32, &ts); 280 1.5.2.2 skrll tsp = &ts; 281 1.5.2.2 skrll } else { 282 1.5.2.2 skrll tsp = NULL; 283 1.5.2.2 skrll } 284 1.5.2.2 skrll 285 1.5.2.2 skrll return mq_send1(SCARG(uap, mqdes), SCARG_P32(uap, msg_ptr), 286 1.5.2.2 skrll SCARG(uap, msg_len), SCARG(uap, msg_prio), tsp); 287 1.5.2.2 skrll } 288 1.5.2.2 skrll 289 1.5.2.2 skrll int 290 1.5.2.2 skrll netbsd32___mq_timedreceive50(struct lwp *l, 291 1.5.2.2 skrll const struct netbsd32___mq_timedreceive50_args *uap, register_t *retval) 292 1.5.2.2 skrll { 293 1.5.2.2 skrll /* { 294 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 295 1.5.2.2 skrll syscallarg(netbsd32_charp) msg_ptr; 296 1.5.2.2 skrll syscallarg(netbsd32_size_t) msg_len; 297 1.5.2.2 skrll syscallarg(netbsd32_uintp) msg_prio; 298 1.5.2.2 skrll syscallarg(const netbsd32_timespecp_t) abs_timeout; 299 1.5.2.2 skrll } */ 300 1.5.2.2 skrll struct timespec ts, *tsp; 301 1.5.2.2 skrll struct netbsd32_timespec ts32; 302 1.5.2.2 skrll ssize_t mlen; 303 1.5.2.2 skrll int error; 304 1.5.2.2 skrll 305 1.5.2.2 skrll /* Get and convert time value */ 306 1.5.2.2 skrll if (SCARG_P32(uap, abs_timeout)) { 307 1.5.2.2 skrll error = copyin(SCARG_P32(uap, abs_timeout), &ts32, 308 1.5.2.2 skrll sizeof(ts32)); 309 1.5.2.2 skrll if (error) 310 1.5.2.2 skrll return error; 311 1.5.2.2 skrll netbsd32_to_timespec(&ts32, &ts); 312 1.5.2.2 skrll tsp = &ts; 313 1.5.2.2 skrll } else { 314 1.5.2.2 skrll tsp = NULL; 315 1.5.2.2 skrll } 316 1.5.2.2 skrll 317 1.5.2.2 skrll error = mq_recv1(SCARG(uap, mqdes), SCARG_P32(uap, msg_ptr), 318 1.5.2.2 skrll SCARG(uap, msg_len), SCARG_P32(uap, msg_prio), tsp, &mlen); 319 1.5.2.2 skrll if (error == 0) 320 1.5.2.2 skrll *retval = mlen; 321 1.5.2.2 skrll 322 1.5.2.2 skrll return error; 323 1.5.2.2 skrll } 324 1.5.2.2 skrll 325
Indexes created Tue Sep 23 07:09:52 GMT 2025