netbsd32_mqueue.c revision 1.5.2.3
1 1.5.2.3 skrll /* $NetBSD: netbsd32_mqueue.c,v 1.5.2.3 2015/12/27 12:09:47 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.3 skrll __KERNEL_RCSID(0, "$NetBSD: netbsd32_mqueue.c,v 1.5.2.3 2015/12/27 12:09:47 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.3 skrll #include <sys/syscallvar.h> 44 1.5.2.2 skrll 45 1.5.2.2 skrll #include <compat/netbsd32/netbsd32.h> 46 1.5.2.2 skrll #include <compat/netbsd32/netbsd32_syscall.h> 47 1.5.2.2 skrll #include <compat/netbsd32/netbsd32_syscallargs.h> 48 1.5.2.2 skrll #include <compat/netbsd32/netbsd32_conv.h> 49 1.5.2.2 skrll 50 1.5.2.3 skrll extern struct emul emul_netbsd32; 51 1.5.2.2 skrll 52 1.5.2.2 skrll int 53 1.5.2.2 skrll netbsd32_mq_open(struct lwp *l, const struct netbsd32_mq_open_args *uap, 54 1.5.2.2 skrll register_t *retval) 55 1.5.2.2 skrll { 56 1.5.2.2 skrll /* { 57 1.5.2.2 skrll syscallarg(const netbsd32_charp) name; 58 1.5.2.2 skrll syscallarg(int) oflag; 59 1.5.2.2 skrll syscallarg(mode_t) mode; 60 1.5.2.2 skrll syscallarg(struct netbsd32_mq_attrp_t) attr; 61 1.5.2.2 skrll } */ 62 1.5.2.2 skrll struct netbsd32_mq_attr attr32; 63 1.5.2.2 skrll struct mq_attr *attr = NULL, a; 64 1.5.2.2 skrll int error; 65 1.5.2.2 skrll 66 1.5.2.2 skrll if ((SCARG(uap, oflag) & O_CREAT) && SCARG_P32(uap, attr) != NULL) { 67 1.5.2.2 skrll error = copyin(SCARG_P32(uap, attr), &attr32, sizeof(attr32)); 68 1.5.2.2 skrll if (error) 69 1.5.2.2 skrll return error; 70 1.5.2.2 skrll netbsd32_to_mq_attr(&attr32, &a); 71 1.5.2.2 skrll attr = &a; 72 1.5.2.2 skrll } 73 1.5.2.2 skrll 74 1.5.2.2 skrll return mq_handle_open(l, SCARG_P32(uap, name), SCARG(uap, oflag), 75 1.5.2.2 skrll SCARG(uap, mode), attr, retval); 76 1.5.2.2 skrll } 77 1.5.2.2 skrll 78 1.5.2.2 skrll int 79 1.5.2.2 skrll netbsd32_mq_close(struct lwp *l, const struct netbsd32_mq_close_args *uap, 80 1.5.2.2 skrll register_t *retval) 81 1.5.2.2 skrll { 82 1.5.2.2 skrll /* { 83 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 84 1.5.2.2 skrll } */ 85 1.5.2.2 skrll 86 1.5.2.2 skrll return netbsd32_close(l, (const void*)uap, retval); 87 1.5.2.2 skrll } 88 1.5.2.2 skrll 89 1.5.2.2 skrll int 90 1.5.2.2 skrll netbsd32_mq_unlink(struct lwp *l, const struct netbsd32_mq_unlink_args *uap, 91 1.5.2.2 skrll register_t *retval) 92 1.5.2.2 skrll { 93 1.5.2.2 skrll /* { 94 1.5.2.2 skrll syscallarg(const netbsd32_charp) name; 95 1.5.2.2 skrll } */ 96 1.5.2.2 skrll struct sys_mq_unlink_args ua; 97 1.5.2.2 skrll 98 1.5.2.2 skrll NETBSD32TOP_UAP(name, const char); 99 1.5.2.2 skrll return sys_mq_unlink(l, &ua, retval); 100 1.5.2.2 skrll } 101 1.5.2.2 skrll 102 1.5.2.2 skrll int 103 1.5.2.2 skrll netbsd32_mq_getattr(struct lwp *l, const struct netbsd32_mq_getattr_args *uap, 104 1.5.2.2 skrll register_t *retval) 105 1.5.2.2 skrll { 106 1.5.2.2 skrll /* { 107 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 108 1.5.2.2 skrll syscallarg(netbsd32_mq_attrp_t) mqstat; 109 1.5.2.2 skrll } */ 110 1.5.2.2 skrll struct mqueue *mq; 111 1.5.2.2 skrll struct mq_attr attr; 112 1.5.2.2 skrll struct netbsd32_mq_attr a32; 113 1.5.2.2 skrll int error; 114 1.5.2.2 skrll 115 1.5.2.2 skrll error = mqueue_get(SCARG(uap, mqdes), 0, &mq); 116 1.5.2.2 skrll if (error) 117 1.5.2.2 skrll return error; 118 1.5.2.2 skrll 119 1.5.2.2 skrll memcpy(&attr, &mq->mq_attrib, sizeof(struct mq_attr)); 120 1.5.2.2 skrll mutex_exit(&mq->mq_mtx); 121 1.5.2.2 skrll fd_putfile((int)SCARG(uap, mqdes)); 122 1.5.2.2 skrll netbsd32_from_mq_attr(&attr, &a32); 123 1.5.2.2 skrll return copyout(&a32, SCARG_P32(uap,mqstat), sizeof(a32)); 124 1.5.2.2 skrll } 125 1.5.2.2 skrll 126 1.5.2.2 skrll int 127 1.5.2.2 skrll netbsd32_mq_setattr(struct lwp *l, const struct netbsd32_mq_setattr_args *uap, 128 1.5.2.2 skrll register_t *retval) 129 1.5.2.2 skrll { 130 1.5.2.2 skrll /* { 131 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 132 1.5.2.2 skrll syscallarg(const netbsd32_mq_attrp_t) mqstat; 133 1.5.2.2 skrll syscallarg(netbsd32_mq_attrp_t) omqstat; 134 1.5.2.2 skrll } */ 135 1.5.2.2 skrll struct mqueue *mq; 136 1.5.2.2 skrll struct netbsd32_mq_attr attr32; 137 1.5.2.2 skrll struct mq_attr attr; 138 1.5.2.2 skrll int error, nonblock; 139 1.5.2.2 skrll 140 1.5.2.2 skrll error = copyin(SCARG_P32(uap, mqstat), &attr32, sizeof(attr32)); 141 1.5.2.2 skrll if (error) 142 1.5.2.2 skrll return error; 143 1.5.2.2 skrll netbsd32_to_mq_attr(&attr32, &attr); 144 1.5.2.2 skrll nonblock = (attr.mq_flags & O_NONBLOCK); 145 1.5.2.2 skrll 146 1.5.2.2 skrll error = mqueue_get(SCARG(uap, mqdes), 0, &mq); 147 1.5.2.2 skrll if (error) 148 1.5.2.2 skrll return error; 149 1.5.2.2 skrll 150 1.5.2.2 skrll /* Copy the old attributes, if needed */ 151 1.5.2.2 skrll if (SCARG_P32(uap, omqstat)) 152 1.5.2.2 skrll memcpy(&attr, &mq->mq_attrib, sizeof(struct mq_attr)); 153 1.5.2.2 skrll 154 1.5.2.2 skrll /* Ignore everything, except O_NONBLOCK */ 155 1.5.2.2 skrll if (nonblock) 156 1.5.2.2 skrll mq->mq_attrib.mq_flags |= O_NONBLOCK; 157 1.5.2.2 skrll else 158 1.5.2.2 skrll mq->mq_attrib.mq_flags &= ~O_NONBLOCK; 159 1.5.2.2 skrll 160 1.5.2.2 skrll mutex_exit(&mq->mq_mtx); 161 1.5.2.2 skrll fd_putfile((int)SCARG(uap, mqdes)); 162 1.5.2.2 skrll 163 1.5.2.2 skrll /* 164 1.5.2.2 skrll * Copy the data to the user-space. 165 1.5.2.2 skrll * Note: According to POSIX, the new attributes should not be set in 166 1.5.2.2 skrll * case of fail - this would be violated. 167 1.5.2.2 skrll */ 168 1.5.2.2 skrll if (SCARG_P32(uap, omqstat)) { 169 1.5.2.2 skrll netbsd32_from_mq_attr(&attr, &attr32); 170 1.5.2.2 skrll error = copyout(&attr32, SCARG_P32(uap, omqstat), 171 1.5.2.2 skrll sizeof(attr32)); 172 1.5.2.2 skrll } 173 1.5.2.2 skrll 174 1.5.2.2 skrll return error; 175 1.5.2.2 skrll } 176 1.5.2.2 skrll 177 1.5.2.2 skrll int 178 1.5.2.2 skrll netbsd32_mq_notify(struct lwp *l, const struct netbsd32_mq_notify_args *uap, 179 1.5.2.2 skrll register_t *result) 180 1.5.2.2 skrll { 181 1.5.2.2 skrll /* { 182 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 183 1.5.2.2 skrll syscallarg(const netbsd32_sigeventp_t) notification; 184 1.5.2.2 skrll } */ 185 1.5.2.2 skrll struct mqueue *mq; 186 1.5.2.2 skrll struct netbsd32_sigevent sig32; 187 1.5.2.2 skrll int error; 188 1.5.2.2 skrll 189 1.5.2.2 skrll if (SCARG_P32(uap, notification)) { 190 1.5.2.2 skrll /* Get the signal from user-space */ 191 1.5.2.2 skrll error = copyin(SCARG_P32(uap, notification), &sig32, 192 1.5.2.2 skrll sizeof(sig32)); 193 1.5.2.2 skrll if (error) 194 1.5.2.2 skrll return error; 195 1.5.2.2 skrll if (sig32.sigev_notify == SIGEV_SIGNAL && 196 1.5.2.2 skrll (sig32.sigev_signo <=0 || sig32.sigev_signo >= NSIG)) 197 1.5.2.2 skrll return EINVAL; 198 1.5.2.2 skrll } 199 1.5.2.2 skrll 200 1.5.2.2 skrll error = mqueue_get(SCARG(uap, mqdes), 0, &mq); 201 1.5.2.2 skrll if (error) { 202 1.5.2.2 skrll return error; 203 1.5.2.2 skrll } 204 1.5.2.2 skrll if (SCARG_P32(uap, notification)) { 205 1.5.2.2 skrll /* Register notification: set the signal and target process */ 206 1.5.2.2 skrll if (mq->mq_notify_proc == NULL) { 207 1.5.2.2 skrll netbsd32_to_sigevent(&sig32, &mq->mq_sig_notify); 208 1.5.2.2 skrll mq->mq_notify_proc = l->l_proc; 209 1.5.2.2 skrll } else { 210 1.5.2.2 skrll /* Fail if someone else already registered */ 211 1.5.2.2 skrll error = EBUSY; 212 1.5.2.2 skrll } 213 1.5.2.2 skrll } else { 214 1.5.2.2 skrll /* Unregister the notification */ 215 1.5.2.2 skrll mq->mq_notify_proc = NULL; 216 1.5.2.2 skrll } 217 1.5.2.2 skrll mutex_exit(&mq->mq_mtx); 218 1.5.2.2 skrll fd_putfile((int)SCARG(uap, mqdes)); 219 1.5.2.2 skrll 220 1.5.2.2 skrll return error; 221 1.5.2.2 skrll } 222 1.5.2.2 skrll 223 1.5.2.2 skrll int 224 1.5.2.2 skrll netbsd32_mq_send(struct lwp *l, const struct netbsd32_mq_send_args *uap, 225 1.5.2.2 skrll register_t *result) 226 1.5.2.2 skrll { 227 1.5.2.2 skrll /* { 228 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 229 1.5.2.2 skrll syscallarg(const netbsd32_charp) msg_ptr; 230 1.5.2.2 skrll syscallarg(netbsd32_size_t) msg_len; 231 1.5.2.2 skrll syscallarg(unsigned) msg_prio; 232 1.5.2.2 skrll } */ 233 1.5.2.2 skrll 234 1.5.2.2 skrll 235 1.5.2.2 skrll return mq_send1(SCARG(uap, mqdes), SCARG_P32(uap, msg_ptr), 236 1.5.2.2 skrll SCARG(uap, msg_len), SCARG(uap, msg_prio), NULL); 237 1.5.2.2 skrll } 238 1.5.2.2 skrll 239 1.5.2.2 skrll int 240 1.5.2.2 skrll netbsd32_mq_receive(struct lwp *l, const struct netbsd32_mq_receive_args *uap, 241 1.5.2.2 skrll register_t *retval) 242 1.5.2.2 skrll { 243 1.5.2.2 skrll /* { 244 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 245 1.5.2.2 skrll syscallarg(netbsd32_charp) msg_ptr; 246 1.5.2.2 skrll syscallarg(netbsd32_size_t) msg_len; 247 1.5.2.2 skrll syscallarg(netbsd32_uintp) msg_prio; 248 1.5.2.2 skrll } */ 249 1.5.2.2 skrll ssize_t mlen; 250 1.5.2.2 skrll int error; 251 1.5.2.2 skrll 252 1.5.2.2 skrll error = mq_recv1(SCARG(uap, mqdes), SCARG_P32(uap, msg_ptr), 253 1.5.2.2 skrll SCARG(uap, msg_len), SCARG_P32(uap, msg_prio), NULL, &mlen); 254 1.5.2.2 skrll if (error == 0) 255 1.5.2.2 skrll *retval = mlen; 256 1.5.2.2 skrll 257 1.5.2.2 skrll return error; 258 1.5.2.2 skrll } 259 1.5.2.2 skrll 260 1.5.2.2 skrll int 261 1.5.2.2 skrll netbsd32___mq_timedsend50(struct lwp *l, 262 1.5.2.2 skrll const struct netbsd32___mq_timedsend50_args *uap, register_t *retval) 263 1.5.2.2 skrll { 264 1.5.2.2 skrll /* { 265 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 266 1.5.2.2 skrll syscallarg(const netbsd32_charp) msg_ptr; 267 1.5.2.2 skrll syscallarg(netbsd32_size_t) msg_len; 268 1.5.2.2 skrll syscallarg(unsigned) msg_prio; 269 1.5.2.2 skrll syscallarg(const netbsd32_timespecp_t) abs_timeout; 270 1.5.2.2 skrll } */ 271 1.5.2.2 skrll struct timespec ts, *tsp; 272 1.5.2.2 skrll struct netbsd32_timespec ts32; 273 1.5.2.2 skrll int error; 274 1.5.2.2 skrll 275 1.5.2.2 skrll /* Get and convert time value */ 276 1.5.2.2 skrll if (SCARG_P32(uap, abs_timeout)) { 277 1.5.2.2 skrll error = copyin(SCARG_P32(uap, abs_timeout), &ts32, 278 1.5.2.2 skrll sizeof(ts32)); 279 1.5.2.2 skrll if (error) 280 1.5.2.2 skrll return error; 281 1.5.2.2 skrll netbsd32_to_timespec(&ts32, &ts); 282 1.5.2.2 skrll tsp = &ts; 283 1.5.2.2 skrll } else { 284 1.5.2.2 skrll tsp = NULL; 285 1.5.2.2 skrll } 286 1.5.2.2 skrll 287 1.5.2.2 skrll return mq_send1(SCARG(uap, mqdes), SCARG_P32(uap, msg_ptr), 288 1.5.2.2 skrll SCARG(uap, msg_len), SCARG(uap, msg_prio), tsp); 289 1.5.2.2 skrll } 290 1.5.2.2 skrll 291 1.5.2.2 skrll int 292 1.5.2.2 skrll netbsd32___mq_timedreceive50(struct lwp *l, 293 1.5.2.2 skrll const struct netbsd32___mq_timedreceive50_args *uap, register_t *retval) 294 1.5.2.2 skrll { 295 1.5.2.2 skrll /* { 296 1.5.2.2 skrll syscallarg(mqd_t) mqdes; 297 1.5.2.2 skrll syscallarg(netbsd32_charp) msg_ptr; 298 1.5.2.2 skrll syscallarg(netbsd32_size_t) msg_len; 299 1.5.2.2 skrll syscallarg(netbsd32_uintp) msg_prio; 300 1.5.2.2 skrll syscallarg(const netbsd32_timespecp_t) abs_timeout; 301 1.5.2.2 skrll } */ 302 1.5.2.2 skrll struct timespec ts, *tsp; 303 1.5.2.2 skrll struct netbsd32_timespec ts32; 304 1.5.2.2 skrll ssize_t mlen; 305 1.5.2.2 skrll int error; 306 1.5.2.2 skrll 307 1.5.2.2 skrll /* Get and convert time value */ 308 1.5.2.2 skrll if (SCARG_P32(uap, abs_timeout)) { 309 1.5.2.2 skrll error = copyin(SCARG_P32(uap, abs_timeout), &ts32, 310 1.5.2.2 skrll sizeof(ts32)); 311 1.5.2.2 skrll if (error) 312 1.5.2.2 skrll return error; 313 1.5.2.2 skrll netbsd32_to_timespec(&ts32, &ts); 314 1.5.2.2 skrll tsp = &ts; 315 1.5.2.2 skrll } else { 316 1.5.2.2 skrll tsp = NULL; 317 1.5.2.2 skrll } 318 1.5.2.2 skrll 319 1.5.2.2 skrll error = mq_recv1(SCARG(uap, mqdes), SCARG_P32(uap, msg_ptr), 320 1.5.2.2 skrll SCARG(uap, msg_len), SCARG_P32(uap, msg_prio), tsp, &mlen); 321 1.5.2.2 skrll if (error == 0) 322 1.5.2.2 skrll *retval = mlen; 323 1.5.2.2 skrll 324 1.5.2.2 skrll return error; 325 1.5.2.2 skrll } 326 1.5.2.2 skrll 327 1.5.2.3 skrll #ifdef COMPAT_50 328 1.5.2.3 skrll 329 1.5.2.3 skrll int 330 1.5.2.3 skrll compat_50_netbsd32_mq_timedsend(struct lwp *l, 331 1.5.2.3 skrll const struct compat_50_netbsd32_mq_timedsend_args *uap, 332 1.5.2.3 skrll register_t *retval) 333 1.5.2.3 skrll { 334 1.5.2.3 skrll /* { 335 1.5.2.3 skrll syscallarg(mqd_t) mqdes; 336 1.5.2.3 skrll syscallarg(const netbsd32_charp) msg_ptr; 337 1.5.2.3 skrll syscallarg(netbsd32_size_t) msg_len; 338 1.5.2.3 skrll syscallarg(unsigned) msg_prio; 339 1.5.2.3 skrll syscallarg(const netbsd32_timespec50p_t) abs_timeout; 340 1.5.2.3 skrll } */ 341 1.5.2.3 skrll struct timespec ts, *tsp; 342 1.5.2.3 skrll struct netbsd32_timespec50 ts32; 343 1.5.2.3 skrll int error; 344 1.5.2.3 skrll 345 1.5.2.3 skrll /* Get and convert time value */ 346 1.5.2.3 skrll if (SCARG_P32(uap, abs_timeout)) { 347 1.5.2.3 skrll error = copyin(SCARG_P32(uap, abs_timeout), &ts32, 348 1.5.2.3 skrll sizeof(ts32)); 349 1.5.2.3 skrll if (error) 350 1.5.2.3 skrll return error; 351 1.5.2.3 skrll netbsd32_to_timespec50(&ts32, &ts); 352 1.5.2.3 skrll tsp = &ts; 353 1.5.2.3 skrll } else { 354 1.5.2.3 skrll tsp = NULL; 355 1.5.2.3 skrll } 356 1.5.2.3 skrll 357 1.5.2.3 skrll return mq_send1(SCARG(uap, mqdes), SCARG_P32(uap, msg_ptr), 358 1.5.2.3 skrll SCARG(uap, msg_len), SCARG(uap, msg_prio), tsp); 359 1.5.2.3 skrll } 360 1.5.2.3 skrll 361 1.5.2.3 skrll int 362 1.5.2.3 skrll compat_50_netbsd32_mq_timedreceive(struct lwp *l, 363 1.5.2.3 skrll const struct compat_50_netbsd32_mq_timedreceive_args *uap, 364 1.5.2.3 skrll register_t *retval) 365 1.5.2.3 skrll { 366 1.5.2.3 skrll /* { 367 1.5.2.3 skrll syscallarg(mqd_t) mqdes; 368 1.5.2.3 skrll syscallarg(netbsd32_charp) msg_ptr; 369 1.5.2.3 skrll syscallarg(netbsd32_size_t) msg_len; 370 1.5.2.3 skrll syscallarg(netbsd32_uintp) msg_prio; 371 1.5.2.3 skrll syscallarg(const netbsd32_timespec50p_t) abs_timeout; 372 1.5.2.3 skrll } */ 373 1.5.2.3 skrll struct timespec ts, *tsp; 374 1.5.2.3 skrll struct netbsd32_timespec50 ts32; 375 1.5.2.3 skrll ssize_t mlen; 376 1.5.2.3 skrll int error; 377 1.5.2.3 skrll 378 1.5.2.3 skrll /* Get and convert time value */ 379 1.5.2.3 skrll if (SCARG_P32(uap, abs_timeout)) { 380 1.5.2.3 skrll error = copyin(SCARG_P32(uap, abs_timeout), &ts32, 381 1.5.2.3 skrll sizeof(ts32)); 382 1.5.2.3 skrll if (error) 383 1.5.2.3 skrll return error; 384 1.5.2.3 skrll netbsd32_to_timespec50(&ts32, &ts); 385 1.5.2.3 skrll tsp = &ts; 386 1.5.2.3 skrll } else { 387 1.5.2.3 skrll tsp = NULL; 388 1.5.2.3 skrll } 389 1.5.2.3 skrll 390 1.5.2.3 skrll error = mq_recv1(SCARG(uap, mqdes), SCARG_P32(uap, msg_ptr), 391 1.5.2.3 skrll SCARG(uap, msg_len), SCARG_P32(uap, msg_prio), tsp, &mlen); 392 1.5.2.3 skrll if (error == 0) 393 1.5.2.3 skrll *retval = mlen; 394 1.5.2.3 skrll 395 1.5.2.3 skrll return error; 396 1.5.2.3 skrll } 397 1.5.2.3 skrll 398 1.5.2.3 skrll #endif /* COMPAT_50 */ 399 1.5.2.3 skrll 400 1.5.2.3 skrll #define _PKG_ENTRY(name) \ 401 1.5.2.3 skrll { NETBSD32_SYS_ ## name, 0, (sy_call_t *)name } 402 1.5.2.3 skrll 403 1.5.2.3 skrll static const struct syscall_package compat_mqueue_syscalls[] = { 404 1.5.2.3 skrll _PKG_ENTRY(netbsd32_mq_open), 405 1.5.2.3 skrll _PKG_ENTRY(netbsd32_mq_close), 406 1.5.2.3 skrll _PKG_ENTRY(netbsd32_mq_unlink), 407 1.5.2.3 skrll _PKG_ENTRY(netbsd32_mq_getattr), 408 1.5.2.3 skrll _PKG_ENTRY(netbsd32_mq_setattr), 409 1.5.2.3 skrll _PKG_ENTRY(netbsd32_mq_notify), 410 1.5.2.3 skrll _PKG_ENTRY(netbsd32_mq_send), 411 1.5.2.3 skrll _PKG_ENTRY(netbsd32_mq_receive), 412 1.5.2.3 skrll _PKG_ENTRY(netbsd32___mq_timedsend50), 413 1.5.2.3 skrll _PKG_ENTRY(netbsd32___mq_timedreceive50), 414 1.5.2.3 skrll #ifdef COMPAT_50 415 1.5.2.3 skrll _PKG_ENTRY(compat_50_netbsd32_mq_timedsend), 416 1.5.2.3 skrll _PKG_ENTRY(compat_50_netbsd32_mq_timedreceive), 417 1.5.2.3 skrll #endif 418 1.5.2.3 skrll {0, 0, NULL} 419 1.5.2.3 skrll }; 420 1.5.2.3 skrll 421 1.5.2.3 skrll MODULE(MODULE_CLASS_EXEC, compat_netbsd32_mqueue, "mqueue,compat_netbsd32"); 422 1.5.2.3 skrll 423 1.5.2.3 skrll static int 424 1.5.2.3 skrll compat_netbsd32_mqueue_modcmd(modcmd_t cmd, void *arg) 425 1.5.2.3 skrll { 426 1.5.2.3 skrll int error; 427 1.5.2.3 skrll 428 1.5.2.3 skrll switch (cmd) { 429 1.5.2.3 skrll case MODULE_CMD_INIT: 430 1.5.2.3 skrll error = syscall_establish(&emul_netbsd32, 431 1.5.2.3 skrll compat_mqueue_syscalls); 432 1.5.2.3 skrll break; 433 1.5.2.3 skrll case MODULE_CMD_FINI: 434 1.5.2.3 skrll error = syscall_disestablish(&emul_netbsd32, 435 1.5.2.3 skrll compat_mqueue_syscalls); 436 1.5.2.3 skrll break; 437 1.5.2.3 skrll default: 438 1.5.2.3 skrll error = ENOTTY; 439 1.5.2.3 skrll break; 440 1.5.2.3 skrll } 441 1.5.2.3 skrll return error; 442 1.5.2.3 skrll } 443
Indexes created Tue Sep 23 22:09:46 GMT 2025