File: | kern/sysv_sem.c |
Warning: | line 667, column 11 Copies out a struct with uncleared padding (>= 6 bytes) |
1 | /*- | |||
2 | * Implementation of SVID semaphores | |||
3 | * | |||
4 | * Author: Daniel Boulet | |||
5 | * | |||
6 | * This software is provided ``AS IS'' without any warranties of any kind. | |||
7 | */ | |||
8 | /*- | |||
9 | * Copyright (c) 2003-2005 McAfee, Inc. | |||
10 | * All rights reserved. | |||
11 | * | |||
12 | * This software was developed for the FreeBSD Project in part by McAfee | |||
13 | * Research, the Security Research Division of McAfee, Inc under DARPA/SPAWAR | |||
14 | * contract N66001-01-C-8035 ("CBOSS"), as part of the DARPA CHATS research | |||
15 | * program. | |||
16 | * | |||
17 | * Redistribution and use in source and binary forms, with or without | |||
18 | * modification, are permitted provided that the following conditions | |||
19 | * are met: | |||
20 | * 1. Redistributions of source code must retain the above copyright | |||
21 | * notice, this list of conditions and the following disclaimer. | |||
22 | * 2. Redistributions in binary form must reproduce the above copyright | |||
23 | * notice, this list of conditions and the following disclaimer in the | |||
24 | * documentation and/or other materials provided with the distribution. | |||
25 | * | |||
26 | * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND | |||
27 | * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE | |||
28 | * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE | |||
29 | * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE | |||
30 | * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL | |||
31 | * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS | |||
32 | * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) | |||
33 | * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT | |||
34 | * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY | |||
35 | * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF | |||
36 | * SUCH DAMAGE. | |||
37 | */ | |||
38 | ||||
39 | #include <sys/cdefs.h> | |||
40 | __FBSDID("$FreeBSD: releng/11.0/sys/kern/sysv_sem.c 298819 2016-04-29 22:15:33Z pfg $")__asm__(".ident\t\"" "$FreeBSD: releng/11.0/sys/kern/sysv_sem.c 298819 2016-04-29 22:15:33Z pfg $" "\""); | |||
41 | ||||
42 | #include "opt_compat.h" | |||
43 | #include "opt_sysvipc.h" | |||
44 | ||||
45 | #include <sys/param.h> | |||
46 | #include <sys/systm.h> | |||
47 | #include <sys/sysproto.h> | |||
48 | #include <sys/eventhandler.h> | |||
49 | #include <sys/kernel.h> | |||
50 | #include <sys/proc.h> | |||
51 | #include <sys/lock.h> | |||
52 | #include <sys/module.h> | |||
53 | #include <sys/mutex.h> | |||
54 | #include <sys/racct.h> | |||
55 | #include <sys/sem.h> | |||
56 | #include <sys/sx.h> | |||
57 | #include <sys/syscall.h> | |||
58 | #include <sys/syscallsubr.h> | |||
59 | #include <sys/sysent.h> | |||
60 | #include <sys/sysctl.h> | |||
61 | #include <sys/uio.h> | |||
62 | #include <sys/malloc.h> | |||
63 | #include <sys/jail.h> | |||
64 | ||||
65 | #include <security/mac/mac_framework.h> | |||
66 | ||||
67 | FEATURE(sysv_sem, "System V semaphores support")static struct sysctl_oid sysctl___kern_features_sysv_sem = { . oid_parent = ((&(&sysctl___kern_features)->oid_children )), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | (0x80000000 | 0x00008000)), .oid_arg1 = ( ((int *)((void *)0))), .oid_arg2 = (1), .oid_name = ("sysv_sem" ), .oid_handler = (sysctl_handle_int), .oid_fmt = ("I"), .oid_descr = "System V semaphores support" }; __asm__(".globl " "__start_set_sysctl_set" ); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_features_sysv_sem __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_features_sysv_sem); _Static_assert ((((0x80000000 | 0x00008000) & 0xf) == 0 || ((0x80000000 | 0x00008000) & 0) == 2) && sizeof(int) == sizeof( *(((int *)((void *)0)))), "compile-time assertion failed"); | |||
68 | ||||
69 | static MALLOC_DEFINE(M_SEM, "sem", "SVID compatible semaphores")struct malloc_type M_SEM[1] = { { ((void *)0), 877983977, "sem" , ((void *)0) } }; static struct sysinit M_SEM_init_sys_init = { SI_SUB_KMEM, SI_ORDER_THIRD, (sysinit_cfunc_t)(sysinit_nfunc_t )malloc_init, ((void *)(M_SEM)) }; __asm__(".globl " "__start_set_sysinit_set" ); __asm__(".globl " "__stop_set_sysinit_set"); static void const * const __set_sysinit_set_sym_M_SEM_init_sys_init __attribute__ ((__section__("set_" "sysinit_set"))) __attribute__((__used__ )) = &(M_SEM_init_sys_init); static struct sysinit M_SEM_uninit_sys_uninit = { SI_SUB_KMEM, SI_ORDER_ANY, (sysinit_cfunc_t)(sysinit_nfunc_t )malloc_uninit, ((void *)(M_SEM)) }; __asm__(".globl " "__start_set_sysuninit_set" ); __asm__(".globl " "__stop_set_sysuninit_set"); static void const * const __set_sysuninit_set_sym_M_SEM_uninit_sys_uninit __attribute__((__section__("set_" "sysuninit_set"))) __attribute__ ((__used__)) = &(M_SEM_uninit_sys_uninit); | |||
70 | ||||
71 | #ifdef SEM_DEBUG | |||
72 | #define DPRINTF(a) printf a | |||
73 | #else | |||
74 | #define DPRINTF(a) | |||
75 | #endif | |||
76 | ||||
77 | static int seminit(void); | |||
78 | static int sysvsem_modload(struct module *, int, void *); | |||
79 | static int semunload(void); | |||
80 | static void semexit_myhook(void *arg, struct proc *p); | |||
81 | static int sysctl_sema(SYSCTL_HANDLER_ARGSstruct sysctl_oid *oidp, void *arg1, intmax_t arg2, struct sysctl_req *req); | |||
82 | static int semvalid(int semid, struct prison *rpr, | |||
83 | struct semid_kernel *semakptr); | |||
84 | static void sem_remove(int semidx, struct ucred *cred); | |||
85 | static struct prison *sem_find_prison(struct ucred *); | |||
86 | static int sem_prison_cansee(struct prison *, struct semid_kernel *); | |||
87 | static int sem_prison_check(void *, void *); | |||
88 | static int sem_prison_set(void *, void *); | |||
89 | static int sem_prison_get(void *, void *); | |||
90 | static int sem_prison_remove(void *, void *); | |||
91 | static void sem_prison_cleanup(struct prison *); | |||
92 | ||||
93 | #ifndef _SYS_SYSPROTO_H_ | |||
94 | struct __semctl_args; | |||
95 | int __semctl(struct thread *td, struct __semctl_args *uap); | |||
96 | struct semget_args; | |||
97 | int semget(struct thread *td, struct semget_args *uap); | |||
98 | struct semop_args; | |||
99 | int semop(struct thread *td, struct semop_args *uap); | |||
100 | #endif | |||
101 | ||||
102 | static struct sem_undo *semu_alloc(struct thread *td); | |||
103 | static int semundo_adjust(struct thread *td, struct sem_undo **supptr, | |||
104 | int semid, int semseq, int semnum, int adjval); | |||
105 | static void semundo_clear(int semid, int semnum); | |||
106 | ||||
107 | static struct mtx sem_mtx; /* semaphore global lock */ | |||
108 | static struct mtx sem_undo_mtx; | |||
109 | static int semtot = 0; | |||
110 | static struct semid_kernel *sema; /* semaphore id pool */ | |||
111 | static struct mtx *sema_mtx; /* semaphore id pool mutexes*/ | |||
112 | static struct sem *sem; /* semaphore pool */ | |||
113 | LIST_HEAD(, sem_undo)struct { struct sem_undo *lh_first; } semu_list; /* list of active undo structures */ | |||
114 | LIST_HEAD(, sem_undo)struct { struct sem_undo *lh_first; } semu_free_list; /* list of free undo structures */ | |||
115 | static int *semu; /* undo structure pool */ | |||
116 | static eventhandler_tag semexit_tag; | |||
117 | static unsigned sem_prison_slot; /* prison OSD slot */ | |||
118 | ||||
119 | #define SEMUNDO_MTXsem_undo_mtx sem_undo_mtx | |||
120 | #define SEMUNDO_LOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sem_undo_mtx))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, 0x00000004, ( _tid)))) __mtx_lock_sleep(&(((((&sem_undo_mtx)))))-> mtx_lock, _tid, (((0))), ((((void *)0))), ((0))); else do { ( void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire ->id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); mtx_lock(&SEMUNDO_MTX)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sem_undo_mtx))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, 0x00000004, ( _tid)))) __mtx_lock_sleep(&(((((&sem_undo_mtx)))))-> mtx_lock, _tid, (((0))), ((((void *)0))), ((0))); else do { ( void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire ->id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
121 | #define SEMUNDO_UNLOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sem_undo_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release-> id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sem_undo_mtx))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sem_undo_mtx)))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0); mtx_unlock(&SEMUNDO_MTX)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sem_undo_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release-> id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sem_undo_mtx))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sem_undo_mtx)))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0); | |||
122 | #define SEMUNDO_LOCKASSERT(how)(void)0; mtx_assert(&SEMUNDO_MTX, (how))(void)0; | |||
123 | ||||
124 | struct sem { | |||
125 | u_short semval; /* semaphore value */ | |||
126 | pid_t sempid; /* pid of last operation */ | |||
127 | u_short semncnt; /* # awaiting semval > cval */ | |||
128 | u_short semzcnt; /* # awaiting semval = 0 */ | |||
129 | }; | |||
130 | ||||
131 | /* | |||
132 | * Undo structure (one per process) | |||
133 | */ | |||
134 | struct sem_undo { | |||
135 | LIST_ENTRY(sem_undo)struct { struct sem_undo *le_next; struct sem_undo **le_prev; } un_next; /* ptr to next active undo structure */ | |||
136 | struct proc *un_proc; /* owner of this structure */ | |||
137 | short un_cnt; /* # of active entries */ | |||
138 | struct undo { | |||
139 | short un_adjval; /* adjust on exit values */ | |||
140 | short un_num; /* semaphore # */ | |||
141 | int un_id; /* semid */ | |||
142 | unsigned short un_seq; | |||
143 | } un_ent[1]; /* undo entries */ | |||
144 | }; | |||
145 | ||||
146 | /* | |||
147 | * Configuration parameters | |||
148 | */ | |||
149 | #ifndef SEMMNI50 | |||
150 | #define SEMMNI50 50 /* # of semaphore identifiers */ | |||
151 | #endif | |||
152 | #ifndef SEMMNS340 | |||
153 | #define SEMMNS340 340 /* # of semaphores in system */ | |||
154 | #endif | |||
155 | #ifndef SEMUME50 | |||
156 | #define SEMUME50 50 /* max # of undo entries per process */ | |||
157 | #endif | |||
158 | #ifndef SEMMNU150 | |||
159 | #define SEMMNU150 150 /* # of undo structures in system */ | |||
160 | #endif | |||
161 | ||||
162 | /* shouldn't need tuning */ | |||
163 | #ifndef SEMMSL340 | |||
164 | #define SEMMSL340 SEMMNS340 /* max # of semaphores per id */ | |||
165 | #endif | |||
166 | #ifndef SEMOPM100 | |||
167 | #define SEMOPM100 100 /* max # of operations per semop call */ | |||
168 | #endif | |||
169 | ||||
170 | #define SEMVMX32767 32767 /* semaphore maximum value */ | |||
171 | #define SEMAEM16384 16384 /* adjust on exit max value */ | |||
172 | ||||
173 | /* | |||
174 | * Due to the way semaphore memory is allocated, we have to ensure that | |||
175 | * SEMUSZ is properly aligned. | |||
176 | */ | |||
177 | ||||
178 | #define SEM_ALIGN(bytes)(((bytes)+((sizeof(long))-1))&(~((sizeof(long))-1))) roundup2(bytes, sizeof(long))(((bytes)+((sizeof(long))-1))&(~((sizeof(long))-1))) | |||
179 | ||||
180 | /* actual size of an undo structure */ | |||
181 | #define SEMUSZ(((__builtin_offsetof(struct sem_undo, un_ent[50]))+((sizeof( long))-1))&(~((sizeof(long))-1))) SEM_ALIGN(offsetof(struct sem_undo, un_ent[SEMUME]))(((__builtin_offsetof(struct sem_undo, un_ent[50]))+((sizeof( long))-1))&(~((sizeof(long))-1))) | |||
182 | ||||
183 | /* | |||
184 | * Macro to find a particular sem_undo vector | |||
185 | */ | |||
186 | #define SEMU(ix)((struct sem_undo *)(((intptr_t)semu)+ix * seminfo.semusz)) \ | |||
187 | ((struct sem_undo *)(((intptr_t)semu)+ix * seminfo.semusz)) | |||
188 | ||||
189 | /* | |||
190 | * semaphore info struct | |||
191 | */ | |||
192 | struct seminfo seminfo = { | |||
193 | SEMMNI50, /* # of semaphore identifiers */ | |||
194 | SEMMNS340, /* # of semaphores in system */ | |||
195 | SEMMNU150, /* # of undo structures in system */ | |||
196 | SEMMSL340, /* max # of semaphores per id */ | |||
197 | SEMOPM100, /* max # of operations per semop call */ | |||
198 | SEMUME50, /* max # of undo entries per process */ | |||
199 | SEMUSZ(((__builtin_offsetof(struct sem_undo, un_ent[50]))+((sizeof( long))-1))&(~((sizeof(long))-1))), /* size in bytes of undo structure */ | |||
200 | SEMVMX32767, /* semaphore maximum value */ | |||
201 | SEMAEM16384 /* adjust on exit max value */ | |||
202 | }; | |||
203 | ||||
204 | SYSCTL_INT(_kern_ipc, OID_AUTO, semmni, CTLFLAG_RDTUN, &seminfo.semmni, 0,static struct sysctl_oid sysctl___kern_ipc_semmni = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | ((0x80000000|0x00080000))), .oid_arg1 = (&seminfo.semmni ), .oid_arg2 = (0), .oid_name = ("semmni"), .oid_handler = (sysctl_handle_int ), .oid_fmt = ("I"), .oid_descr = "Number of semaphore identifiers" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semmni __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semmni); _Static_assert (((((0x80000000|0x00080000)) & 0xf) == 0 || (((0x80000000 |0x00080000)) & 0) == 2) && sizeof(int) == sizeof (*(&seminfo.semmni)), "compile-time assertion failed") | |||
205 | "Number of semaphore identifiers")static struct sysctl_oid sysctl___kern_ipc_semmni = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | ((0x80000000|0x00080000))), .oid_arg1 = (&seminfo.semmni ), .oid_arg2 = (0), .oid_name = ("semmni"), .oid_handler = (sysctl_handle_int ), .oid_fmt = ("I"), .oid_descr = "Number of semaphore identifiers" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semmni __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semmni); _Static_assert (((((0x80000000|0x00080000)) & 0xf) == 0 || (((0x80000000 |0x00080000)) & 0) == 2) && sizeof(int) == sizeof (*(&seminfo.semmni)), "compile-time assertion failed"); | |||
206 | SYSCTL_INT(_kern_ipc, OID_AUTO, semmns, CTLFLAG_RDTUN, &seminfo.semmns, 0,static struct sysctl_oid sysctl___kern_ipc_semmns = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | ((0x80000000|0x00080000))), .oid_arg1 = (&seminfo.semmns ), .oid_arg2 = (0), .oid_name = ("semmns"), .oid_handler = (sysctl_handle_int ), .oid_fmt = ("I"), .oid_descr = "Maximum number of semaphores in the system" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semmns __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semmns); _Static_assert (((((0x80000000|0x00080000)) & 0xf) == 0 || (((0x80000000 |0x00080000)) & 0) == 2) && sizeof(int) == sizeof (*(&seminfo.semmns)), "compile-time assertion failed") | |||
207 | "Maximum number of semaphores in the system")static struct sysctl_oid sysctl___kern_ipc_semmns = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | ((0x80000000|0x00080000))), .oid_arg1 = (&seminfo.semmns ), .oid_arg2 = (0), .oid_name = ("semmns"), .oid_handler = (sysctl_handle_int ), .oid_fmt = ("I"), .oid_descr = "Maximum number of semaphores in the system" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semmns __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semmns); _Static_assert (((((0x80000000|0x00080000)) & 0xf) == 0 || (((0x80000000 |0x00080000)) & 0) == 2) && sizeof(int) == sizeof (*(&seminfo.semmns)), "compile-time assertion failed"); | |||
208 | SYSCTL_INT(_kern_ipc, OID_AUTO, semmnu, CTLFLAG_RDTUN, &seminfo.semmnu, 0,static struct sysctl_oid sysctl___kern_ipc_semmnu = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | ((0x80000000|0x00080000))), .oid_arg1 = (&seminfo.semmnu ), .oid_arg2 = (0), .oid_name = ("semmnu"), .oid_handler = (sysctl_handle_int ), .oid_fmt = ("I"), .oid_descr = "Maximum number of undo structures in the system" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semmnu __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semmnu); _Static_assert (((((0x80000000|0x00080000)) & 0xf) == 0 || (((0x80000000 |0x00080000)) & 0) == 2) && sizeof(int) == sizeof (*(&seminfo.semmnu)), "compile-time assertion failed") | |||
209 | "Maximum number of undo structures in the system")static struct sysctl_oid sysctl___kern_ipc_semmnu = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | ((0x80000000|0x00080000))), .oid_arg1 = (&seminfo.semmnu ), .oid_arg2 = (0), .oid_name = ("semmnu"), .oid_handler = (sysctl_handle_int ), .oid_fmt = ("I"), .oid_descr = "Maximum number of undo structures in the system" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semmnu __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semmnu); _Static_assert (((((0x80000000|0x00080000)) & 0xf) == 0 || (((0x80000000 |0x00080000)) & 0) == 2) && sizeof(int) == sizeof (*(&seminfo.semmnu)), "compile-time assertion failed"); | |||
210 | SYSCTL_INT(_kern_ipc, OID_AUTO, semmsl, CTLFLAG_RWTUN, &seminfo.semmsl, 0,static struct sysctl_oid sysctl___kern_ipc_semmsl = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | (((0x80000000|0x40000000)|0x00080000))), .oid_arg1 = (& seminfo.semmsl), .oid_arg2 = (0), .oid_name = ("semmsl"), .oid_handler = (sysctl_handle_int), .oid_fmt = ("I"), .oid_descr = "Max semaphores per id" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semmsl __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semmsl); _Static_assert ((((((0x80000000|0x40000000)|0x00080000)) & 0xf) == 0 || ( (((0x80000000|0x40000000)|0x00080000)) & 0) == 2) && sizeof(int) == sizeof(*(&seminfo.semmsl)), "compile-time assertion failed" ) | |||
211 | "Max semaphores per id")static struct sysctl_oid sysctl___kern_ipc_semmsl = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | (((0x80000000|0x40000000)|0x00080000))), .oid_arg1 = (& seminfo.semmsl), .oid_arg2 = (0), .oid_name = ("semmsl"), .oid_handler = (sysctl_handle_int), .oid_fmt = ("I"), .oid_descr = "Max semaphores per id" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semmsl __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semmsl); _Static_assert ((((((0x80000000|0x40000000)|0x00080000)) & 0xf) == 0 || ( (((0x80000000|0x40000000)|0x00080000)) & 0) == 2) && sizeof(int) == sizeof(*(&seminfo.semmsl)), "compile-time assertion failed" ); | |||
212 | SYSCTL_INT(_kern_ipc, OID_AUTO, semopm, CTLFLAG_RDTUN, &seminfo.semopm, 0,static struct sysctl_oid sysctl___kern_ipc_semopm = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | ((0x80000000|0x00080000))), .oid_arg1 = (&seminfo.semopm ), .oid_arg2 = (0), .oid_name = ("semopm"), .oid_handler = (sysctl_handle_int ), .oid_fmt = ("I"), .oid_descr = "Max operations per semop call" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semopm __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semopm); _Static_assert (((((0x80000000|0x00080000)) & 0xf) == 0 || (((0x80000000 |0x00080000)) & 0) == 2) && sizeof(int) == sizeof (*(&seminfo.semopm)), "compile-time assertion failed") | |||
213 | "Max operations per semop call")static struct sysctl_oid sysctl___kern_ipc_semopm = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | ((0x80000000|0x00080000))), .oid_arg1 = (&seminfo.semopm ), .oid_arg2 = (0), .oid_name = ("semopm"), .oid_handler = (sysctl_handle_int ), .oid_fmt = ("I"), .oid_descr = "Max operations per semop call" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semopm __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semopm); _Static_assert (((((0x80000000|0x00080000)) & 0xf) == 0 || (((0x80000000 |0x00080000)) & 0) == 2) && sizeof(int) == sizeof (*(&seminfo.semopm)), "compile-time assertion failed"); | |||
214 | SYSCTL_INT(_kern_ipc, OID_AUTO, semume, CTLFLAG_RDTUN, &seminfo.semume, 0,static struct sysctl_oid sysctl___kern_ipc_semume = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | ((0x80000000|0x00080000))), .oid_arg1 = (&seminfo.semume ), .oid_arg2 = (0), .oid_name = ("semume"), .oid_handler = (sysctl_handle_int ), .oid_fmt = ("I"), .oid_descr = "Max undo entries per process" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semume __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semume); _Static_assert (((((0x80000000|0x00080000)) & 0xf) == 0 || (((0x80000000 |0x00080000)) & 0) == 2) && sizeof(int) == sizeof (*(&seminfo.semume)), "compile-time assertion failed") | |||
215 | "Max undo entries per process")static struct sysctl_oid sysctl___kern_ipc_semume = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | ((0x80000000|0x00080000))), .oid_arg1 = (&seminfo.semume ), .oid_arg2 = (0), .oid_name = ("semume"), .oid_handler = (sysctl_handle_int ), .oid_fmt = ("I"), .oid_descr = "Max undo entries per process" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semume __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semume); _Static_assert (((((0x80000000|0x00080000)) & 0xf) == 0 || (((0x80000000 |0x00080000)) & 0) == 2) && sizeof(int) == sizeof (*(&seminfo.semume)), "compile-time assertion failed"); | |||
216 | SYSCTL_INT(_kern_ipc, OID_AUTO, semusz, CTLFLAG_RDTUN, &seminfo.semusz, 0,static struct sysctl_oid sysctl___kern_ipc_semusz = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | ((0x80000000|0x00080000))), .oid_arg1 = (&seminfo.semusz ), .oid_arg2 = (0), .oid_name = ("semusz"), .oid_handler = (sysctl_handle_int ), .oid_fmt = ("I"), .oid_descr = "Size in bytes of undo structure" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semusz __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semusz); _Static_assert (((((0x80000000|0x00080000)) & 0xf) == 0 || (((0x80000000 |0x00080000)) & 0) == 2) && sizeof(int) == sizeof (*(&seminfo.semusz)), "compile-time assertion failed") | |||
217 | "Size in bytes of undo structure")static struct sysctl_oid sysctl___kern_ipc_semusz = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | ((0x80000000|0x00080000))), .oid_arg1 = (&seminfo.semusz ), .oid_arg2 = (0), .oid_name = ("semusz"), .oid_handler = (sysctl_handle_int ), .oid_fmt = ("I"), .oid_descr = "Size in bytes of undo structure" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semusz __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semusz); _Static_assert (((((0x80000000|0x00080000)) & 0xf) == 0 || (((0x80000000 |0x00080000)) & 0) == 2) && sizeof(int) == sizeof (*(&seminfo.semusz)), "compile-time assertion failed"); | |||
218 | SYSCTL_INT(_kern_ipc, OID_AUTO, semvmx, CTLFLAG_RWTUN, &seminfo.semvmx, 0,static struct sysctl_oid sysctl___kern_ipc_semvmx = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | (((0x80000000|0x40000000)|0x00080000))), .oid_arg1 = (& seminfo.semvmx), .oid_arg2 = (0), .oid_name = ("semvmx"), .oid_handler = (sysctl_handle_int), .oid_fmt = ("I"), .oid_descr = "Semaphore maximum value" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semvmx __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semvmx); _Static_assert ((((((0x80000000|0x40000000)|0x00080000)) & 0xf) == 0 || ( (((0x80000000|0x40000000)|0x00080000)) & 0) == 2) && sizeof(int) == sizeof(*(&seminfo.semvmx)), "compile-time assertion failed" ) | |||
219 | "Semaphore maximum value")static struct sysctl_oid sysctl___kern_ipc_semvmx = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | (((0x80000000|0x40000000)|0x00080000))), .oid_arg1 = (& seminfo.semvmx), .oid_arg2 = (0), .oid_name = ("semvmx"), .oid_handler = (sysctl_handle_int), .oid_fmt = ("I"), .oid_descr = "Semaphore maximum value" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semvmx __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semvmx); _Static_assert ((((((0x80000000|0x40000000)|0x00080000)) & 0xf) == 0 || ( (((0x80000000|0x40000000)|0x00080000)) & 0) == 2) && sizeof(int) == sizeof(*(&seminfo.semvmx)), "compile-time assertion failed" ); | |||
220 | SYSCTL_INT(_kern_ipc, OID_AUTO, semaem, CTLFLAG_RWTUN, &seminfo.semaem, 0,static struct sysctl_oid sysctl___kern_ipc_semaem = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | (((0x80000000|0x40000000)|0x00080000))), .oid_arg1 = (& seminfo.semaem), .oid_arg2 = (0), .oid_name = ("semaem"), .oid_handler = (sysctl_handle_int), .oid_fmt = ("I"), .oid_descr = "Adjust on exit max value" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semaem __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semaem); _Static_assert ((((((0x80000000|0x40000000)|0x00080000)) & 0xf) == 0 || ( (((0x80000000|0x40000000)|0x00080000)) & 0) == 2) && sizeof(int) == sizeof(*(&seminfo.semaem)), "compile-time assertion failed" ) | |||
221 | "Adjust on exit max value")static struct sysctl_oid sysctl___kern_ipc_semaem = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (2 | 0x00040000 | (((0x80000000|0x40000000)|0x00080000))), .oid_arg1 = (& seminfo.semaem), .oid_arg2 = (0), .oid_name = ("semaem"), .oid_handler = (sysctl_handle_int), .oid_fmt = ("I"), .oid_descr = "Adjust on exit max value" }; __asm__(".globl " "__start_set_sysctl_set"); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_semaem __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___kern_ipc_semaem); _Static_assert ((((((0x80000000|0x40000000)|0x00080000)) & 0xf) == 0 || ( (((0x80000000|0x40000000)|0x00080000)) & 0) == 2) && sizeof(int) == sizeof(*(&seminfo.semaem)), "compile-time assertion failed" ); | |||
222 | SYSCTL_PROC(_kern_ipc, OID_AUTO, sema,static struct sysctl_oid sysctl___kern_ipc_sema = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = ((5 | 0x80000000 | 0x00040000)), .oid_arg1 = (((void *)0)), .oid_arg2 = (0), . oid_name = ("sema"), .oid_handler = (sysctl_sema), .oid_fmt = (""), .oid_descr = "Semaphore id pool" }; __asm__(".globl " "__start_set_sysctl_set" ); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_sema __attribute__ ((__section__("set_" "sysctl_set"))) __attribute__((__used__) ) = &(sysctl___kern_ipc_sema); _Static_assert(((5 | 0x80000000 | 0x00040000) & 0xf) != 0, "compile-time assertion failed" ) | |||
223 | CTLTYPE_OPAQUE | CTLFLAG_RD | CTLFLAG_MPSAFE,static struct sysctl_oid sysctl___kern_ipc_sema = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = ((5 | 0x80000000 | 0x00040000)), .oid_arg1 = (((void *)0)), .oid_arg2 = (0), . oid_name = ("sema"), .oid_handler = (sysctl_sema), .oid_fmt = (""), .oid_descr = "Semaphore id pool" }; __asm__(".globl " "__start_set_sysctl_set" ); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_sema __attribute__ ((__section__("set_" "sysctl_set"))) __attribute__((__used__) ) = &(sysctl___kern_ipc_sema); _Static_assert(((5 | 0x80000000 | 0x00040000) & 0xf) != 0, "compile-time assertion failed" ) | |||
224 | NULL, 0, sysctl_sema, "", "Semaphore id pool")static struct sysctl_oid sysctl___kern_ipc_sema = { .oid_parent = ((&(&sysctl___kern_ipc)->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = ((5 | 0x80000000 | 0x00040000)), .oid_arg1 = (((void *)0)), .oid_arg2 = (0), . oid_name = ("sema"), .oid_handler = (sysctl_sema), .oid_fmt = (""), .oid_descr = "Semaphore id pool" }; __asm__(".globl " "__start_set_sysctl_set" ); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___kern_ipc_sema __attribute__ ((__section__("set_" "sysctl_set"))) __attribute__((__used__) ) = &(sysctl___kern_ipc_sema); _Static_assert(((5 | 0x80000000 | 0x00040000) & 0xf) != 0, "compile-time assertion failed" ); | |||
225 | ||||
226 | static struct syscall_helper_data sem_syscalls[] = { | |||
227 | SYSCALL_INIT_HELPER(__semctl){ .new_sysent = { .sy_narg = (sizeof(struct __semctl_args ) / sizeof(register_t)), .sy_call = (sy_call_t *)& sys___semctl , .sy_auevent = 98 }, .syscall_no = 510 }, | |||
228 | SYSCALL_INIT_HELPER(semget){ .new_sysent = { .sy_narg = (sizeof(struct semget_args ) / sizeof (register_t)), .sy_call = (sy_call_t *)& sys_semget, .sy_auevent = 109 }, .syscall_no = 221 }, | |||
229 | SYSCALL_INIT_HELPER(semop){ .new_sysent = { .sy_narg = (sizeof(struct semop_args ) / sizeof (register_t)), .sy_call = (sy_call_t *)& sys_semop, .sy_auevent = 110 }, .syscall_no = 222 }, | |||
230 | #if defined(COMPAT_FREEBSD41) || defined(COMPAT_FREEBSD51) || \ | |||
231 | defined(COMPAT_FREEBSD61) || defined(COMPAT_FREEBSD71) | |||
232 | SYSCALL_INIT_HELPER(semsys){ .new_sysent = { .sy_narg = (sizeof(struct semsys_args ) / sizeof (register_t)), .sy_call = (sy_call_t *)& sys_semsys, .sy_auevent = 63 }, .syscall_no = 169 }, | |||
233 | SYSCALL_INIT_HELPER_COMPAT(freebsd7___semctl){ .new_sysent = { .sy_narg = (sizeof(struct freebsd7___semctl_args ) / sizeof(register_t)), .sy_call = (sy_call_t *)& freebsd7___semctl , .sy_auevent = 98 }, .syscall_no = 220 }, | |||
234 | #endif | |||
235 | SYSCALL_INIT_LAST{ .syscall_no = (-1) } | |||
236 | }; | |||
237 | ||||
238 | #ifdef COMPAT_FREEBSD321 | |||
239 | #include <compat/freebsd32/freebsd32.h> | |||
240 | #include <compat/freebsd32/freebsd32_ipc.h> | |||
241 | #include <compat/freebsd32/freebsd32_proto.h> | |||
242 | #include <compat/freebsd32/freebsd32_signal.h> | |||
243 | #include <compat/freebsd32/freebsd32_syscall.h> | |||
244 | #include <compat/freebsd32/freebsd32_util.h> | |||
245 | ||||
246 | static struct syscall_helper_data sem32_syscalls[] = { | |||
247 | SYSCALL32_INIT_HELPER(freebsd32_semctl){ .new_sysent = { .sy_narg = (sizeof(struct freebsd32_semctl_args ) / sizeof(register_t)), .sy_call = (sy_call_t *)& freebsd32_semctl , }, .syscall_no = 510 }, | |||
248 | SYSCALL32_INIT_HELPER_COMPAT(semget){ .new_sysent = { .sy_narg = (sizeof(struct semget_args ) / sizeof (register_t)), .sy_call = (sy_call_t *)& sys_semget, }, . syscall_no = 221 }, | |||
249 | SYSCALL32_INIT_HELPER_COMPAT(semop){ .new_sysent = { .sy_narg = (sizeof(struct semop_args ) / sizeof (register_t)), .sy_call = (sy_call_t *)& sys_semop, }, .syscall_no = 222 }, | |||
250 | SYSCALL32_INIT_HELPER(freebsd32_semsys){ .new_sysent = { .sy_narg = (sizeof(struct freebsd32_semsys_args ) / sizeof(register_t)), .sy_call = (sy_call_t *)& freebsd32_semsys , }, .syscall_no = 169 }, | |||
251 | #if defined(COMPAT_FREEBSD41) || defined(COMPAT_FREEBSD51) || \ | |||
252 | defined(COMPAT_FREEBSD61) || defined(COMPAT_FREEBSD71) | |||
253 | SYSCALL32_INIT_HELPER(freebsd7_freebsd32_semctl){ .new_sysent = { .sy_narg = (sizeof(struct freebsd7_freebsd32_semctl_args ) / sizeof(register_t)), .sy_call = (sy_call_t *)& freebsd7_freebsd32_semctl , }, .syscall_no = 220 }, | |||
254 | #endif | |||
255 | SYSCALL_INIT_LAST{ .syscall_no = (-1) } | |||
256 | }; | |||
257 | #endif | |||
258 | ||||
259 | static int | |||
260 | seminit(void) | |||
261 | { | |||
262 | struct prison *pr; | |||
263 | void **rsv; | |||
264 | int i, error; | |||
265 | osd_method_t methods[PR_MAXMETHOD6] = { | |||
266 | [PR_METHOD_CHECK3] = sem_prison_check, | |||
267 | [PR_METHOD_SET2] = sem_prison_set, | |||
268 | [PR_METHOD_GET1] = sem_prison_get, | |||
269 | [PR_METHOD_REMOVE5] = sem_prison_remove, | |||
270 | }; | |||
271 | ||||
272 | sem = malloc(sizeof(struct sem) * seminfo.semmns, M_SEM, M_WAITOK0x0002); | |||
273 | sema = malloc(sizeof(struct semid_kernel) * seminfo.semmni, M_SEM, | |||
274 | M_WAITOK0x0002); | |||
275 | sema_mtx = malloc(sizeof(struct mtx) * seminfo.semmni, M_SEM, | |||
276 | M_WAITOK0x0002 | M_ZERO0x0100); | |||
277 | semu = malloc(seminfo.semmnu * seminfo.semusz, M_SEM, M_WAITOK0x0002); | |||
278 | ||||
279 | for (i = 0; i < seminfo.semmni; i++) { | |||
280 | sema[i].u.sem_base = 0; | |||
281 | sema[i].u.sem_perm.mode = 0; | |||
282 | sema[i].u.sem_perm.seq = 0; | |||
283 | #ifdef MAC1 | |||
284 | mac_sysvsem_init(&sema[i]); | |||
285 | #endif | |||
286 | } | |||
287 | for (i = 0; i < seminfo.semmni; i++) | |||
288 | mtx_init(&sema_mtx[i], "semid", NULL, MTX_DEF)_mtx_init(&(&sema_mtx[i])->mtx_lock, "semid", ((void *)0), 0x00000000); | |||
289 | LIST_INIT(&semu_free_list)do { (((&semu_free_list))->lh_first) = ((void *)0); } while (0); | |||
290 | for (i = 0; i < seminfo.semmnu; i++) { | |||
291 | struct sem_undo *suptr = SEMU(i)((struct sem_undo *)(((intptr_t)semu)+i * seminfo.semusz)); | |||
292 | suptr->un_proc = NULL((void *)0); | |||
293 | LIST_INSERT_HEAD(&semu_free_list, suptr, un_next)do { ; if (((((suptr))->un_next.le_next) = (((&semu_free_list ))->lh_first)) != ((void *)0)) (((&semu_free_list))-> lh_first)->un_next.le_prev = &(((suptr))->un_next.le_next ); (((&semu_free_list))->lh_first) = (suptr); (suptr)-> un_next.le_prev = &(((&semu_free_list))->lh_first) ; } while (0); | |||
294 | } | |||
295 | LIST_INIT(&semu_list)do { (((&semu_list))->lh_first) = ((void *)0); } while (0); | |||
296 | mtx_init(&sem_mtx, "sem", NULL, MTX_DEF)_mtx_init(&(&sem_mtx)->mtx_lock, "sem", ((void *)0 ), 0x00000000); | |||
297 | mtx_init(&sem_undo_mtx, "semu", NULL, MTX_DEF)_mtx_init(&(&sem_undo_mtx)->mtx_lock, "semu", ((void *)0), 0x00000000); | |||
298 | semexit_tag = EVENTHANDLER_REGISTER(process_exit, semexit_myhook, NULL,eventhandler_register(((void *)0), "process_exit", semexit_myhook , ((void *)0), 10000) | |||
299 | EVENTHANDLER_PRI_ANY)eventhandler_register(((void *)0), "process_exit", semexit_myhook , ((void *)0), 10000); | |||
300 | ||||
301 | /* Set current prisons according to their allow.sysvipc. */ | |||
302 | sem_prison_slot = osd_jail_register(NULL, methods)osd_register(1, (((void *)0)), (methods)); | |||
303 | rsv = osd_reserve(sem_prison_slot); | |||
304 | prison_lock(&prison0); | |||
305 | (void)osd_jail_set_reserved(&prison0, sem_prison_slot, rsv, &prison0)osd_set_reserved(1, &(&prison0)->pr_osd, (sem_prison_slot ), (rsv), (&prison0)); | |||
306 | prison_unlock(&prison0); | |||
307 | rsv = NULL((void *)0); | |||
308 | sx_slock(&allprison_lock)(void)__sx_slock(((&allprison_lock)), 0, (((void *)0)), ( 0)); | |||
309 | TAILQ_FOREACH(pr, &allprison, pr_list)for ((pr) = (((&allprison))->tqh_first); (pr); (pr) = ( ((pr))->pr_list.tqe_next)) { | |||
310 | if (rsv == NULL((void *)0)) | |||
311 | rsv = osd_reserve(sem_prison_slot); | |||
312 | prison_lock(pr); | |||
313 | if ((pr->pr_allow & PR_ALLOW_SYSVIPC0x0002) && pr->pr_ref > 0) { | |||
314 | (void)osd_jail_set_reserved(pr, sem_prison_slot, rsv,osd_set_reserved(1, &(pr)->pr_osd, (sem_prison_slot), ( rsv), (&prison0)) | |||
315 | &prison0)osd_set_reserved(1, &(pr)->pr_osd, (sem_prison_slot), ( rsv), (&prison0)); | |||
316 | rsv = NULL((void *)0); | |||
317 | } | |||
318 | prison_unlock(pr); | |||
319 | } | |||
320 | if (rsv != NULL((void *)0)) | |||
321 | osd_free_reserved(rsv); | |||
322 | sx_sunlock(&allprison_lock)__sx_sunlock(((&allprison_lock)), (((void *)0)), (0)); | |||
323 | ||||
324 | error = syscall_helper_register(sem_syscalls, SY_THR_STATIC_KLD0x1); | |||
325 | if (error != 0) | |||
326 | return (error); | |||
327 | #ifdef COMPAT_FREEBSD321 | |||
328 | error = syscall32_helper_register(sem32_syscalls, SY_THR_STATIC_KLD0x1); | |||
329 | if (error != 0) | |||
330 | return (error); | |||
331 | #endif | |||
332 | return (0); | |||
333 | } | |||
334 | ||||
335 | static int | |||
336 | semunload(void) | |||
337 | { | |||
338 | int i; | |||
339 | ||||
340 | /* XXXKIB */ | |||
341 | if (semtot != 0) | |||
342 | return (EBUSY16); | |||
343 | ||||
344 | #ifdef COMPAT_FREEBSD321 | |||
345 | syscall32_helper_unregister(sem32_syscalls); | |||
346 | #endif | |||
347 | syscall_helper_unregister(sem_syscalls); | |||
348 | EVENTHANDLER_DEREGISTER(process_exit, semexit_tag)do { struct eventhandler_list *_el; if ((_el = eventhandler_find_list ("process_exit")) != ((void *)0)) eventhandler_deregister(_el , semexit_tag); } while(0); | |||
349 | if (sem_prison_slot != 0) | |||
350 | osd_jail_deregister(sem_prison_slot)osd_deregister(1, (sem_prison_slot)); | |||
351 | #ifdef MAC1 | |||
352 | for (i = 0; i < seminfo.semmni; i++) | |||
353 | mac_sysvsem_destroy(&sema[i]); | |||
354 | #endif | |||
355 | free(sem, M_SEM); | |||
356 | free(sema, M_SEM); | |||
357 | free(semu, M_SEM); | |||
358 | for (i = 0; i < seminfo.semmni; i++) | |||
359 | mtx_destroy(&sema_mtx[i])_mtx_destroy(&(&sema_mtx[i])->mtx_lock); | |||
360 | free(sema_mtx, M_SEM); | |||
361 | mtx_destroy(&sem_mtx)_mtx_destroy(&(&sem_mtx)->mtx_lock); | |||
362 | mtx_destroy(&sem_undo_mtx)_mtx_destroy(&(&sem_undo_mtx)->mtx_lock); | |||
363 | return (0); | |||
364 | } | |||
365 | ||||
366 | static int | |||
367 | sysvsem_modload(struct module *module, int cmd, void *arg) | |||
368 | { | |||
369 | int error = 0; | |||
370 | ||||
371 | switch (cmd) { | |||
372 | case MOD_LOAD: | |||
373 | error = seminit(); | |||
374 | if (error != 0) | |||
375 | semunload(); | |||
376 | break; | |||
377 | case MOD_UNLOAD: | |||
378 | error = semunload(); | |||
379 | break; | |||
380 | case MOD_SHUTDOWN: | |||
381 | break; | |||
382 | default: | |||
383 | error = EINVAL22; | |||
384 | break; | |||
385 | } | |||
386 | return (error); | |||
387 | } | |||
388 | ||||
389 | static moduledata_t sysvsem_mod = { | |||
390 | "sysvsem", | |||
391 | &sysvsem_modload, | |||
392 | NULL((void *)0) | |||
393 | }; | |||
394 | ||||
395 | DECLARE_MODULE(sysvsem, sysvsem_mod, SI_SUB_SYSV_SEM, SI_ORDER_FIRST)static struct mod_depend _sysvsem_depend_on_kernel __attribute__ ((__section__(".data"))) = { 1100122, 1100122, (((((1100122)+ ((100000)-1))/(100000))*(100000)) - 1) }; static struct mod_metadata _mod_metadata_md_sysvsem_on_kernel = { 1, 1, &_sysvsem_depend_on_kernel , "kernel" }; __asm__(".globl " "__start_set_modmetadata_set" ); __asm__(".globl " "__stop_set_modmetadata_set"); static void const * const __set_modmetadata_set_sym__mod_metadata_md_sysvsem_on_kernel __attribute__((__section__("set_" "modmetadata_set"))) __attribute__ ((__used__)) = &(_mod_metadata_md_sysvsem_on_kernel); static struct mod_metadata _mod_metadata_md_sysvsem = { 1, 2, & sysvsem_mod, "sysvsem" }; __asm__(".globl " "__start_set_modmetadata_set" ); __asm__(".globl " "__stop_set_modmetadata_set"); static void const * const __set_modmetadata_set_sym__mod_metadata_md_sysvsem __attribute__((__section__("set_" "modmetadata_set"))) __attribute__ ((__used__)) = &(_mod_metadata_md_sysvsem); static struct sysinit sysvsemmodule_sys_init = { SI_SUB_SYSV_SEM, SI_ORDER_FIRST , (sysinit_cfunc_t)(sysinit_nfunc_t)module_register_init, ((void *)(&sysvsem_mod)) }; __asm__(".globl " "__start_set_sysinit_set" ); __asm__(".globl " "__stop_set_sysinit_set"); static void const * const __set_sysinit_set_sym_sysvsemmodule_sys_init __attribute__ ((__section__("set_" "sysinit_set"))) __attribute__((__used__ )) = &(sysvsemmodule_sys_init); struct __hack; | |||
396 | MODULE_VERSION(sysvsem, 1)static struct mod_version _sysvsem_version __attribute__((__section__ (".data"))) = { 1 }; static struct mod_metadata _mod_metadata_sysvsem_version = { 1, 3, &_sysvsem_version, "sysvsem" }; __asm__(".globl " "__start_set_modmetadata_set"); __asm__(".globl " "__stop_set_modmetadata_set" ); static void const * const __set_modmetadata_set_sym__mod_metadata_sysvsem_version __attribute__((__section__("set_" "modmetadata_set"))) __attribute__ ((__used__)) = &(_mod_metadata_sysvsem_version); | |||
397 | ||||
398 | /* | |||
399 | * Allocate a new sem_undo structure for a process | |||
400 | * (returns ptr to structure or NULL if no more room) | |||
401 | */ | |||
402 | ||||
403 | static struct sem_undo * | |||
404 | semu_alloc(struct thread *td) | |||
405 | { | |||
406 | struct sem_undo *suptr; | |||
407 | ||||
408 | SEMUNDO_LOCKASSERT(MA_OWNED)(void)0;; | |||
409 | if ((suptr = LIST_FIRST(&semu_free_list)((&semu_free_list)->lh_first)) == NULL((void *)0)) | |||
410 | return (NULL((void *)0)); | |||
411 | LIST_REMOVE(suptr, un_next)do { ; ; ; ; if ((((suptr))->un_next.le_next) != ((void *) 0)) (((suptr))->un_next.le_next)->un_next.le_prev = (suptr )->un_next.le_prev; *(suptr)->un_next.le_prev = (((suptr ))->un_next.le_next); ; ; } while (0); | |||
412 | LIST_INSERT_HEAD(&semu_list, suptr, un_next)do { ; if (((((suptr))->un_next.le_next) = (((&semu_list ))->lh_first)) != ((void *)0)) (((&semu_list))->lh_first )->un_next.le_prev = &(((suptr))->un_next.le_next); (((&semu_list))->lh_first) = (suptr); (suptr)->un_next .le_prev = &(((&semu_list))->lh_first); } while (0 ); | |||
413 | suptr->un_cnt = 0; | |||
414 | suptr->un_proc = td->td_proc; | |||
415 | return (suptr); | |||
416 | } | |||
417 | ||||
418 | static int | |||
419 | semu_try_free(struct sem_undo *suptr) | |||
420 | { | |||
421 | ||||
422 | SEMUNDO_LOCKASSERT(MA_OWNED)(void)0;; | |||
423 | ||||
424 | if (suptr->un_cnt != 0) | |||
425 | return (0); | |||
426 | LIST_REMOVE(suptr, un_next)do { ; ; ; ; if ((((suptr))->un_next.le_next) != ((void *) 0)) (((suptr))->un_next.le_next)->un_next.le_prev = (suptr )->un_next.le_prev; *(suptr)->un_next.le_prev = (((suptr ))->un_next.le_next); ; ; } while (0); | |||
427 | LIST_INSERT_HEAD(&semu_free_list, suptr, un_next)do { ; if (((((suptr))->un_next.le_next) = (((&semu_free_list ))->lh_first)) != ((void *)0)) (((&semu_free_list))-> lh_first)->un_next.le_prev = &(((suptr))->un_next.le_next ); (((&semu_free_list))->lh_first) = (suptr); (suptr)-> un_next.le_prev = &(((&semu_free_list))->lh_first) ; } while (0); | |||
428 | return (1); | |||
429 | } | |||
430 | ||||
431 | /* | |||
432 | * Adjust a particular entry for a particular proc | |||
433 | */ | |||
434 | ||||
435 | static int | |||
436 | semundo_adjust(struct thread *td, struct sem_undo **supptr, int semid, | |||
437 | int semseq, int semnum, int adjval) | |||
438 | { | |||
439 | struct proc *p = td->td_proc; | |||
440 | struct sem_undo *suptr; | |||
441 | struct undo *sunptr; | |||
442 | int i; | |||
443 | ||||
444 | SEMUNDO_LOCKASSERT(MA_OWNED)(void)0;; | |||
445 | /* Look for and remember the sem_undo if the caller doesn't provide | |||
446 | it */ | |||
447 | ||||
448 | suptr = *supptr; | |||
449 | if (suptr == NULL((void *)0)) { | |||
450 | LIST_FOREACH(suptr, &semu_list, un_next)for ((suptr) = (((&semu_list))->lh_first); (suptr); (suptr ) = (((suptr))->un_next.le_next)) { | |||
451 | if (suptr->un_proc == p) { | |||
452 | *supptr = suptr; | |||
453 | break; | |||
454 | } | |||
455 | } | |||
456 | if (suptr == NULL((void *)0)) { | |||
457 | if (adjval == 0) | |||
458 | return(0); | |||
459 | suptr = semu_alloc(td); | |||
460 | if (suptr == NULL((void *)0)) | |||
461 | return (ENOSPC28); | |||
462 | *supptr = suptr; | |||
463 | } | |||
464 | } | |||
465 | ||||
466 | /* | |||
467 | * Look for the requested entry and adjust it (delete if adjval becomes | |||
468 | * 0). | |||
469 | */ | |||
470 | sunptr = &suptr->un_ent[0]; | |||
471 | for (i = 0; i < suptr->un_cnt; i++, sunptr++) { | |||
472 | if (sunptr->un_id != semid || sunptr->un_num != semnum) | |||
473 | continue; | |||
474 | if (adjval != 0) { | |||
475 | adjval += sunptr->un_adjval; | |||
476 | if (adjval > seminfo.semaem || adjval < -seminfo.semaem) | |||
477 | return (ERANGE34); | |||
478 | } | |||
479 | sunptr->un_adjval = adjval; | |||
480 | if (sunptr->un_adjval == 0) { | |||
481 | suptr->un_cnt--; | |||
482 | if (i < suptr->un_cnt) | |||
483 | suptr->un_ent[i] = | |||
484 | suptr->un_ent[suptr->un_cnt]; | |||
485 | if (suptr->un_cnt == 0) | |||
486 | semu_try_free(suptr); | |||
487 | } | |||
488 | return (0); | |||
489 | } | |||
490 | ||||
491 | /* Didn't find the right entry - create it */ | |||
492 | if (adjval == 0) | |||
493 | return (0); | |||
494 | if (adjval > seminfo.semaem || adjval < -seminfo.semaem) | |||
495 | return (ERANGE34); | |||
496 | if (suptr->un_cnt != seminfo.semume) { | |||
497 | sunptr = &suptr->un_ent[suptr->un_cnt]; | |||
498 | suptr->un_cnt++; | |||
499 | sunptr->un_adjval = adjval; | |||
500 | sunptr->un_id = semid; | |||
501 | sunptr->un_num = semnum; | |||
502 | sunptr->un_seq = semseq; | |||
503 | } else | |||
504 | return (EINVAL22); | |||
505 | return (0); | |||
506 | } | |||
507 | ||||
508 | static void | |||
509 | semundo_clear(int semid, int semnum) | |||
510 | { | |||
511 | struct sem_undo *suptr, *suptr1; | |||
512 | struct undo *sunptr; | |||
513 | int i; | |||
514 | ||||
515 | SEMUNDO_LOCKASSERT(MA_OWNED)(void)0;; | |||
516 | LIST_FOREACH_SAFE(suptr, &semu_list, un_next, suptr1)for ((suptr) = (((&semu_list))->lh_first); (suptr) && ((suptr1) = (((suptr))->un_next.le_next), 1); (suptr) = ( suptr1)) { | |||
517 | sunptr = &suptr->un_ent[0]; | |||
518 | for (i = 0; i < suptr->un_cnt; i++, sunptr++) { | |||
519 | if (sunptr->un_id != semid) | |||
520 | continue; | |||
521 | if (semnum == -1 || sunptr->un_num == semnum) { | |||
522 | suptr->un_cnt--; | |||
523 | if (i < suptr->un_cnt) { | |||
524 | suptr->un_ent[i] = | |||
525 | suptr->un_ent[suptr->un_cnt]; | |||
526 | continue; | |||
527 | } | |||
528 | semu_try_free(suptr); | |||
529 | } | |||
530 | if (semnum != -1) | |||
531 | break; | |||
532 | } | |||
533 | } | |||
534 | } | |||
535 | ||||
536 | static int | |||
537 | semvalid(int semid, struct prison *rpr, struct semid_kernel *semakptr) | |||
538 | { | |||
539 | ||||
540 | return ((semakptr->u.sem_perm.mode & SEM_ALLOC01000) == 0 || | |||
541 | semakptr->u.sem_perm.seq != IPCID_TO_SEQ(semid)(((semid) >> 16) & 0xffff) || | |||
542 | sem_prison_cansee(rpr, semakptr) ? EINVAL22 : 0); | |||
543 | } | |||
544 | ||||
545 | static void | |||
546 | sem_remove(int semidx, struct ucred *cred) | |||
547 | { | |||
548 | struct semid_kernel *semakptr; | |||
549 | int i; | |||
550 | ||||
551 | KASSERT(semidx >= 0 && semidx < seminfo.semmni,do { } while (0) | |||
552 | ("semidx out of bounds"))do { } while (0); | |||
553 | semakptr = &sema[semidx]; | |||
554 | semakptr->u.sem_perm.cuid = cred ? cred->cr_uid : 0; | |||
555 | semakptr->u.sem_perm.uid = cred ? cred->cr_uid : 0; | |||
556 | semakptr->u.sem_perm.mode = 0; | |||
557 | racct_sub_cred(semakptr->cred, RACCT_NSEM15, semakptr->u.sem_nsems); | |||
558 | crfree(semakptr->cred); | |||
559 | semakptr->cred = NULL((void *)0); | |||
560 | SEMUNDO_LOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sem_undo_mtx))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, 0x00000004, ( _tid)))) __mtx_lock_sleep(&(((((&sem_undo_mtx)))))-> mtx_lock, _tid, (((0))), ((((void *)0))), ((0))); else do { ( void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire ->id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0);; | |||
561 | semundo_clear(semidx, -1); | |||
562 | SEMUNDO_UNLOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sem_undo_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release-> id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sem_undo_mtx))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sem_undo_mtx)))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0);; | |||
563 | #ifdef MAC1 | |||
564 | mac_sysvsem_cleanup(semakptr); | |||
565 | #endif | |||
566 | wakeup(semakptr); | |||
567 | for (i = 0; i < seminfo.semmni; i++) { | |||
568 | if ((sema[i].u.sem_perm.mode & SEM_ALLOC01000) && | |||
569 | sema[i].u.sem_base > semakptr->u.sem_base) | |||
570 | mtx_lock_flags(&sema_mtx[i], LOP_DUPOK)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sema_mtx[i])))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&((((&sema_mtx[i]))))->mtx_lock, 0x00000004, (_tid )))) __mtx_lock_sleep(&((((&sema_mtx[i]))))->mtx_lock , _tid, (((0x00000010))), ((((void *)0))), ((0))); else do { ( void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire ->id, (uintptr_t) ((&sema_mtx[i])), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
571 | } | |||
572 | for (i = semakptr->u.sem_base - sem; i < semtot; i++) | |||
573 | sem[i] = sem[i + semakptr->u.sem_nsems]; | |||
574 | for (i = 0; i < seminfo.semmni; i++) { | |||
575 | if ((sema[i].u.sem_perm.mode & SEM_ALLOC01000) && | |||
576 | sema[i].u.sem_base > semakptr->u.sem_base) { | |||
577 | sema[i].u.sem_base -= semakptr->u.sem_nsems; | |||
578 | mtx_unlock(&sema_mtx[i])do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sema_mtx[i]))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release-> id, (uintptr_t) (((&sema_mtx[i]))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sema_mtx[i]))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sema_mtx[i])))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sema_mtx[i])))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0); | |||
579 | } | |||
580 | } | |||
581 | semtot -= semakptr->u.sem_nsems; | |||
582 | } | |||
583 | ||||
584 | static struct prison * | |||
585 | sem_find_prison(struct ucred *cred) | |||
586 | { | |||
587 | struct prison *pr, *rpr; | |||
588 | ||||
589 | pr = cred->cr_prison; | |||
590 | prison_lock(pr); | |||
591 | rpr = osd_jail_get(pr, sem_prison_slot)osd_get(1, &(pr)->pr_osd, (sem_prison_slot)); | |||
592 | prison_unlock(pr); | |||
593 | return rpr; | |||
594 | } | |||
595 | ||||
596 | static int | |||
597 | sem_prison_cansee(struct prison *rpr, struct semid_kernel *semakptr) | |||
598 | { | |||
599 | ||||
600 | if (semakptr->cred == NULL((void *)0) || | |||
601 | !(rpr == semakptr->cred->cr_prison || | |||
602 | prison_ischild(rpr, semakptr->cred->cr_prison))) | |||
603 | return (EINVAL22); | |||
604 | return (0); | |||
605 | } | |||
606 | ||||
607 | /* | |||
608 | * Note that the user-mode half of this passes a union, not a pointer. | |||
609 | */ | |||
610 | #ifndef _SYS_SYSPROTO_H_ | |||
611 | struct __semctl_args { | |||
612 | int semid; | |||
613 | int semnum; | |||
614 | int cmd; | |||
615 | union semun *arg; | |||
616 | }; | |||
617 | #endif | |||
618 | int | |||
619 | sys___semctl(struct thread *td, struct __semctl_args *uap) | |||
620 | { | |||
621 | struct semid_ds dsbuf; | |||
622 | union semun arg, semun; | |||
623 | register_t rval; | |||
624 | int error; | |||
625 | ||||
626 | switch (uap->cmd) { | |||
| ||||
627 | case SEM_STAT10: | |||
628 | case IPC_SET1: | |||
629 | case IPC_STAT2: | |||
630 | case GETALL6: | |||
631 | case SETVAL8: | |||
632 | case SETALL9: | |||
633 | error = copyin(uap->arg, &arg, sizeof(arg)); | |||
634 | if (error) | |||
635 | return (error); | |||
636 | break; | |||
637 | } | |||
638 | ||||
639 | switch (uap->cmd) { | |||
640 | case SEM_STAT10: | |||
641 | case IPC_STAT2: | |||
642 | semun.buf = &dsbuf; | |||
643 | break; | |||
644 | case IPC_SET1: | |||
645 | error = copyin(arg.buf, &dsbuf, sizeof(dsbuf)); | |||
646 | if (error) | |||
647 | return (error); | |||
648 | semun.buf = &dsbuf; | |||
649 | break; | |||
650 | case GETALL6: | |||
651 | case SETALL9: | |||
652 | semun.array = arg.array; | |||
653 | break; | |||
654 | case SETVAL8: | |||
655 | semun.val = arg.val; | |||
656 | break; | |||
657 | } | |||
658 | ||||
659 | error = kern_semctl(td, uap->semid, uap->semnum, uap->cmd, &semun, | |||
660 | &rval); | |||
661 | if (error) | |||
662 | return (error); | |||
663 | ||||
664 | switch (uap->cmd) { | |||
665 | case SEM_STAT10: | |||
666 | case IPC_STAT2: | |||
667 | error = copyout(&dsbuf, arg.buf, sizeof(dsbuf)); | |||
| ||||
668 | break; | |||
669 | } | |||
670 | ||||
671 | if (error == 0) | |||
672 | td->td_retvaltd_uretoff.tdu_retval[0] = rval; | |||
673 | return (error); | |||
674 | } | |||
675 | ||||
676 | int | |||
677 | kern_semctl(struct thread *td, int semid, int semnum, int cmd, | |||
678 | union semun *arg, register_t *rval) | |||
679 | { | |||
680 | u_short *array; | |||
681 | struct ucred *cred = td->td_ucred; | |||
682 | int i, error; | |||
683 | struct prison *rpr; | |||
684 | struct semid_ds *sbuf; | |||
685 | struct semid_kernel *semakptr; | |||
686 | struct mtx *sema_mtxp; | |||
687 | u_short usval, count; | |||
688 | int semidx; | |||
689 | ||||
690 | DPRINTF(("call to semctl(%d, %d, %d, 0x%p)\n", | |||
691 | semid, semnum, cmd, arg)); | |||
692 | ||||
693 | rpr = sem_find_prison(td->td_ucred); | |||
694 | if (sem == NULL((void *)0)) | |||
695 | return (ENOSYS78); | |||
696 | ||||
697 | array = NULL((void *)0); | |||
698 | ||||
699 | switch(cmd) { | |||
700 | case SEM_STAT10: | |||
701 | /* | |||
702 | * For this command we assume semid is an array index | |||
703 | * rather than an IPC id. | |||
704 | */ | |||
705 | if (semid < 0 || semid >= seminfo.semmni) | |||
706 | return (EINVAL22); | |||
707 | semakptr = &sema[semid]; | |||
708 | sema_mtxp = &sema_mtx[semid]; | |||
709 | mtx_lock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( sema_mtxp))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((sema_mtxp)))))->mtx_lock, 0x00000004, (_tid)))) __mtx_lock_sleep(&(((((sema_mtxp)))))->mtx_lock, _tid , (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire->id , (uintptr_t) (((sema_mtxp))), (uintptr_t) 0, (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
710 | if ((semakptr->u.sem_perm.mode & SEM_ALLOC01000) == 0) { | |||
711 | error = EINVAL22; | |||
712 | goto done2; | |||
713 | } | |||
714 | if ((error = sem_prison_cansee(rpr, semakptr))) | |||
715 | goto done2; | |||
716 | if ((error = ipcperm(td, &semakptr->u.sem_perm, IPC_R000400))) | |||
717 | goto done2; | |||
718 | #ifdef MAC1 | |||
719 | error = mac_sysvsem_check_semctl(cred, semakptr, cmd); | |||
720 | if (error != 0) | |||
721 | goto done2; | |||
722 | #endif | |||
723 | bcopy(&semakptr->u, arg->buf, sizeof(struct semid_ds)); | |||
724 | if (cred->cr_prison != semakptr->cred->cr_prison) | |||
725 | arg->buf->sem_perm.key = IPC_PRIVATE(key_t)0; | |||
726 | *rval = IXSEQ_TO_IPCID(semid, semakptr->u.sem_perm)(((semakptr->u.sem_perm.seq) << 16) | (semid & 0xffff )); | |||
727 | mtx_unlock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((sema_mtxp ))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect ((sdt_lockstat___adaptive__release->id), 0)) (*sdt_probe_func )(sdt_lockstat___adaptive__release->id, (uintptr_t) (((sema_mtxp ))), (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((sema_mtxp))))->mtx_lock != _tid || !atomic_cmpset_long(&(((((sema_mtxp)))))-> mtx_lock, (_tid), 0x00000004)) __mtx_unlock_sleep(&(((((sema_mtxp )))))->mtx_lock, (((0))), ((((void *)0))), ((0))); } while (0); | |||
728 | return (0); | |||
729 | } | |||
730 | ||||
731 | semidx = IPCID_TO_IX(semid)((semid) & 0xffff); | |||
732 | if (semidx < 0 || semidx >= seminfo.semmni) | |||
733 | return (EINVAL22); | |||
734 | ||||
735 | semakptr = &sema[semidx]; | |||
736 | sema_mtxp = &sema_mtx[semidx]; | |||
737 | if (cmd == IPC_RMID0) | |||
738 | mtx_lock(&sem_mtx)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sem_mtx))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sem_mtx)))))->mtx_lock, 0x00000004, (_tid) ))) __mtx_lock_sleep(&(((((&sem_mtx)))))->mtx_lock , _tid, (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire-> id, (uintptr_t) (((&sem_mtx))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
739 | mtx_lock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( sema_mtxp))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((sema_mtxp)))))->mtx_lock, 0x00000004, (_tid)))) __mtx_lock_sleep(&(((((sema_mtxp)))))->mtx_lock, _tid , (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire->id , (uintptr_t) (((sema_mtxp))), (uintptr_t) 0, (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
740 | ||||
741 | #ifdef MAC1 | |||
742 | error = mac_sysvsem_check_semctl(cred, semakptr, cmd); | |||
743 | if (error != 0) | |||
744 | goto done2; | |||
745 | #endif | |||
746 | ||||
747 | error = 0; | |||
748 | *rval = 0; | |||
749 | ||||
750 | switch (cmd) { | |||
751 | case IPC_RMID0: | |||
752 | if ((error = semvalid(semid, rpr, semakptr)) != 0) | |||
753 | goto done2; | |||
754 | if ((error = ipcperm(td, &semakptr->u.sem_perm, IPC_M010000))) | |||
755 | goto done2; | |||
756 | sem_remove(semidx, cred); | |||
757 | break; | |||
758 | ||||
759 | case IPC_SET1: | |||
760 | if ((error = semvalid(semid, rpr, semakptr)) != 0) | |||
761 | goto done2; | |||
762 | if ((error = ipcperm(td, &semakptr->u.sem_perm, IPC_M010000))) | |||
763 | goto done2; | |||
764 | sbuf = arg->buf; | |||
765 | semakptr->u.sem_perm.uid = sbuf->sem_perm.uid; | |||
766 | semakptr->u.sem_perm.gid = sbuf->sem_perm.gid; | |||
767 | semakptr->u.sem_perm.mode = (semakptr->u.sem_perm.mode & | |||
768 | ~0777) | (sbuf->sem_perm.mode & 0777); | |||
769 | semakptr->u.sem_ctime = time_second; | |||
770 | break; | |||
771 | ||||
772 | case IPC_STAT2: | |||
773 | if ((error = semvalid(semid, rpr, semakptr)) != 0) | |||
774 | goto done2; | |||
775 | if ((error = ipcperm(td, &semakptr->u.sem_perm, IPC_R000400))) | |||
776 | goto done2; | |||
777 | bcopy(&semakptr->u, arg->buf, sizeof(struct semid_ds)); | |||
778 | if (cred->cr_prison != semakptr->cred->cr_prison) | |||
779 | arg->buf->sem_perm.key = IPC_PRIVATE(key_t)0; | |||
780 | break; | |||
781 | ||||
782 | case GETNCNT3: | |||
783 | if ((error = semvalid(semid, rpr, semakptr)) != 0) | |||
784 | goto done2; | |||
785 | if ((error = ipcperm(td, &semakptr->u.sem_perm, IPC_R000400))) | |||
786 | goto done2; | |||
787 | if (semnum < 0 || semnum >= semakptr->u.sem_nsems) { | |||
788 | error = EINVAL22; | |||
789 | goto done2; | |||
790 | } | |||
791 | *rval = semakptr->u.sem_base[semnum].semncnt; | |||
792 | break; | |||
793 | ||||
794 | case GETPID4: | |||
795 | if ((error = semvalid(semid, rpr, semakptr)) != 0) | |||
796 | goto done2; | |||
797 | if ((error = ipcperm(td, &semakptr->u.sem_perm, IPC_R000400))) | |||
798 | goto done2; | |||
799 | if (semnum < 0 || semnum >= semakptr->u.sem_nsems) { | |||
800 | error = EINVAL22; | |||
801 | goto done2; | |||
802 | } | |||
803 | *rval = semakptr->u.sem_base[semnum].sempid; | |||
804 | break; | |||
805 | ||||
806 | case GETVAL5: | |||
807 | if ((error = semvalid(semid, rpr, semakptr)) != 0) | |||
808 | goto done2; | |||
809 | if ((error = ipcperm(td, &semakptr->u.sem_perm, IPC_R000400))) | |||
810 | goto done2; | |||
811 | if (semnum < 0 || semnum >= semakptr->u.sem_nsems) { | |||
812 | error = EINVAL22; | |||
813 | goto done2; | |||
814 | } | |||
815 | *rval = semakptr->u.sem_base[semnum].semval; | |||
816 | break; | |||
817 | ||||
818 | case GETALL6: | |||
819 | /* | |||
820 | * Unfortunately, callers of this function don't know | |||
821 | * in advance how many semaphores are in this set. | |||
822 | * While we could just allocate the maximum size array | |||
823 | * and pass the actual size back to the caller, that | |||
824 | * won't work for SETALL since we can't copyin() more | |||
825 | * data than the user specified as we may return a | |||
826 | * spurious EFAULT. | |||
827 | * | |||
828 | * Note that the number of semaphores in a set is | |||
829 | * fixed for the life of that set. The only way that | |||
830 | * the 'count' could change while are blocked in | |||
831 | * malloc() is if this semaphore set were destroyed | |||
832 | * and a new one created with the same index. | |||
833 | * However, semvalid() will catch that due to the | |||
834 | * sequence number unless exactly 0x8000 (or a | |||
835 | * multiple thereof) semaphore sets for the same index | |||
836 | * are created and destroyed while we are in malloc! | |||
837 | * | |||
838 | */ | |||
839 | count = semakptr->u.sem_nsems; | |||
840 | mtx_unlock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((sema_mtxp ))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect ((sdt_lockstat___adaptive__release->id), 0)) (*sdt_probe_func )(sdt_lockstat___adaptive__release->id, (uintptr_t) (((sema_mtxp ))), (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((sema_mtxp))))->mtx_lock != _tid || !atomic_cmpset_long(&(((((sema_mtxp)))))-> mtx_lock, (_tid), 0x00000004)) __mtx_unlock_sleep(&(((((sema_mtxp )))))->mtx_lock, (((0))), ((((void *)0))), ((0))); } while (0); | |||
841 | array = malloc(sizeof(*array) * count, M_TEMP, M_WAITOK0x0002); | |||
842 | mtx_lock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( sema_mtxp))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((sema_mtxp)))))->mtx_lock, 0x00000004, (_tid)))) __mtx_lock_sleep(&(((((sema_mtxp)))))->mtx_lock, _tid , (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire->id , (uintptr_t) (((sema_mtxp))), (uintptr_t) 0, (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
843 | if ((error = semvalid(semid, rpr, semakptr)) != 0) | |||
844 | goto done2; | |||
845 | KASSERT(count == semakptr->u.sem_nsems, ("nsems changed"))do { } while (0); | |||
846 | if ((error = ipcperm(td, &semakptr->u.sem_perm, IPC_R000400))) | |||
847 | goto done2; | |||
848 | for (i = 0; i < semakptr->u.sem_nsems; i++) | |||
849 | array[i] = semakptr->u.sem_base[i].semval; | |||
850 | mtx_unlock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((sema_mtxp ))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect ((sdt_lockstat___adaptive__release->id), 0)) (*sdt_probe_func )(sdt_lockstat___adaptive__release->id, (uintptr_t) (((sema_mtxp ))), (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((sema_mtxp))))->mtx_lock != _tid || !atomic_cmpset_long(&(((((sema_mtxp)))))-> mtx_lock, (_tid), 0x00000004)) __mtx_unlock_sleep(&(((((sema_mtxp )))))->mtx_lock, (((0))), ((((void *)0))), ((0))); } while (0); | |||
851 | error = copyout(array, arg->array, count * sizeof(*array)); | |||
852 | mtx_lock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( sema_mtxp))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((sema_mtxp)))))->mtx_lock, 0x00000004, (_tid)))) __mtx_lock_sleep(&(((((sema_mtxp)))))->mtx_lock, _tid , (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire->id , (uintptr_t) (((sema_mtxp))), (uintptr_t) 0, (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
853 | break; | |||
854 | ||||
855 | case GETZCNT7: | |||
856 | if ((error = semvalid(semid, rpr, semakptr)) != 0) | |||
857 | goto done2; | |||
858 | if ((error = ipcperm(td, &semakptr->u.sem_perm, IPC_R000400))) | |||
859 | goto done2; | |||
860 | if (semnum < 0 || semnum >= semakptr->u.sem_nsems) { | |||
861 | error = EINVAL22; | |||
862 | goto done2; | |||
863 | } | |||
864 | *rval = semakptr->u.sem_base[semnum].semzcnt; | |||
865 | break; | |||
866 | ||||
867 | case SETVAL8: | |||
868 | if ((error = semvalid(semid, rpr, semakptr)) != 0) | |||
869 | goto done2; | |||
870 | if ((error = ipcperm(td, &semakptr->u.sem_perm, IPC_W000200))) | |||
871 | goto done2; | |||
872 | if (semnum < 0 || semnum >= semakptr->u.sem_nsems) { | |||
873 | error = EINVAL22; | |||
874 | goto done2; | |||
875 | } | |||
876 | if (arg->val < 0 || arg->val > seminfo.semvmx) { | |||
877 | error = ERANGE34; | |||
878 | goto done2; | |||
879 | } | |||
880 | semakptr->u.sem_base[semnum].semval = arg->val; | |||
881 | SEMUNDO_LOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sem_undo_mtx))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, 0x00000004, ( _tid)))) __mtx_lock_sleep(&(((((&sem_undo_mtx)))))-> mtx_lock, _tid, (((0))), ((((void *)0))), ((0))); else do { ( void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire ->id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0);; | |||
882 | semundo_clear(semidx, semnum); | |||
883 | SEMUNDO_UNLOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sem_undo_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release-> id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sem_undo_mtx))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sem_undo_mtx)))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0);; | |||
884 | wakeup(semakptr); | |||
885 | break; | |||
886 | ||||
887 | case SETALL9: | |||
888 | /* | |||
889 | * See comment on GETALL for why 'count' shouldn't change | |||
890 | * and why we require a userland buffer. | |||
891 | */ | |||
892 | count = semakptr->u.sem_nsems; | |||
893 | mtx_unlock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((sema_mtxp ))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect ((sdt_lockstat___adaptive__release->id), 0)) (*sdt_probe_func )(sdt_lockstat___adaptive__release->id, (uintptr_t) (((sema_mtxp ))), (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((sema_mtxp))))->mtx_lock != _tid || !atomic_cmpset_long(&(((((sema_mtxp)))))-> mtx_lock, (_tid), 0x00000004)) __mtx_unlock_sleep(&(((((sema_mtxp )))))->mtx_lock, (((0))), ((((void *)0))), ((0))); } while (0); | |||
894 | array = malloc(sizeof(*array) * count, M_TEMP, M_WAITOK0x0002); | |||
895 | error = copyin(arg->array, array, count * sizeof(*array)); | |||
896 | mtx_lock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( sema_mtxp))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((sema_mtxp)))))->mtx_lock, 0x00000004, (_tid)))) __mtx_lock_sleep(&(((((sema_mtxp)))))->mtx_lock, _tid , (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire->id , (uintptr_t) (((sema_mtxp))), (uintptr_t) 0, (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
897 | if (error) | |||
898 | break; | |||
899 | if ((error = semvalid(semid, rpr, semakptr)) != 0) | |||
900 | goto done2; | |||
901 | KASSERT(count == semakptr->u.sem_nsems, ("nsems changed"))do { } while (0); | |||
902 | if ((error = ipcperm(td, &semakptr->u.sem_perm, IPC_W000200))) | |||
903 | goto done2; | |||
904 | for (i = 0; i < semakptr->u.sem_nsems; i++) { | |||
905 | usval = array[i]; | |||
906 | if (usval > seminfo.semvmx) { | |||
907 | error = ERANGE34; | |||
908 | break; | |||
909 | } | |||
910 | semakptr->u.sem_base[i].semval = usval; | |||
911 | } | |||
912 | SEMUNDO_LOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sem_undo_mtx))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, 0x00000004, ( _tid)))) __mtx_lock_sleep(&(((((&sem_undo_mtx)))))-> mtx_lock, _tid, (((0))), ((((void *)0))), ((0))); else do { ( void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire ->id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0);; | |||
913 | semundo_clear(semidx, -1); | |||
914 | SEMUNDO_UNLOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sem_undo_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release-> id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sem_undo_mtx))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sem_undo_mtx)))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0);; | |||
915 | wakeup(semakptr); | |||
916 | break; | |||
917 | ||||
918 | default: | |||
919 | error = EINVAL22; | |||
920 | break; | |||
921 | } | |||
922 | ||||
923 | done2: | |||
924 | mtx_unlock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((sema_mtxp ))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect ((sdt_lockstat___adaptive__release->id), 0)) (*sdt_probe_func )(sdt_lockstat___adaptive__release->id, (uintptr_t) (((sema_mtxp ))), (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((sema_mtxp))))->mtx_lock != _tid || !atomic_cmpset_long(&(((((sema_mtxp)))))-> mtx_lock, (_tid), 0x00000004)) __mtx_unlock_sleep(&(((((sema_mtxp )))))->mtx_lock, (((0))), ((((void *)0))), ((0))); } while (0); | |||
925 | if (cmd == IPC_RMID0) | |||
926 | mtx_unlock(&sem_mtx)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sem_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release->id , (uintptr_t) (((&sem_mtx))), (uintptr_t) 0, (uintptr_t) 0 , (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sem_mtx))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sem_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sem_mtx)))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0); | |||
927 | if (array != NULL((void *)0)) | |||
928 | free(array, M_TEMP); | |||
929 | return(error); | |||
930 | } | |||
931 | ||||
932 | #ifndef _SYS_SYSPROTO_H_ | |||
933 | struct semget_args { | |||
934 | key_t key; | |||
935 | int nsems; | |||
936 | int semflg; | |||
937 | }; | |||
938 | #endif | |||
939 | int | |||
940 | sys_semget(struct thread *td, struct semget_args *uap) | |||
941 | { | |||
942 | int semid, error = 0; | |||
943 | int key = uap->key; | |||
944 | int nsems = uap->nsems; | |||
945 | int semflg = uap->semflg; | |||
946 | struct ucred *cred = td->td_ucred; | |||
947 | ||||
948 | DPRINTF(("semget(0x%x, %d, 0%o)\n", key, nsems, semflg)); | |||
949 | ||||
950 | if (sem_find_prison(cred) == NULL((void *)0)) | |||
951 | return (ENOSYS78); | |||
952 | ||||
953 | mtx_lock(&sem_mtx)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sem_mtx))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sem_mtx)))))->mtx_lock, 0x00000004, (_tid) ))) __mtx_lock_sleep(&(((((&sem_mtx)))))->mtx_lock , _tid, (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire-> id, (uintptr_t) (((&sem_mtx))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
954 | if (key != IPC_PRIVATE(key_t)0) { | |||
955 | for (semid = 0; semid < seminfo.semmni; semid++) { | |||
956 | if ((sema[semid].u.sem_perm.mode & SEM_ALLOC01000) && | |||
957 | sema[semid].cred != NULL((void *)0) && | |||
958 | sema[semid].cred->cr_prison == cred->cr_prison && | |||
959 | sema[semid].u.sem_perm.key == key) | |||
960 | break; | |||
961 | } | |||
962 | if (semid < seminfo.semmni) { | |||
963 | DPRINTF(("found public key\n")); | |||
964 | if ((semflg & IPC_CREAT001000) && (semflg & IPC_EXCL002000)) { | |||
965 | DPRINTF(("not exclusive\n")); | |||
966 | error = EEXIST17; | |||
967 | goto done2; | |||
968 | } | |||
969 | if ((error = ipcperm(td, &sema[semid].u.sem_perm, | |||
970 | semflg & 0700))) { | |||
971 | goto done2; | |||
972 | } | |||
973 | if (nsems > 0 && sema[semid].u.sem_nsems < nsems) { | |||
974 | DPRINTF(("too small\n")); | |||
975 | error = EINVAL22; | |||
976 | goto done2; | |||
977 | } | |||
978 | #ifdef MAC1 | |||
979 | error = mac_sysvsem_check_semget(cred, &sema[semid]); | |||
980 | if (error != 0) | |||
981 | goto done2; | |||
982 | #endif | |||
983 | goto found; | |||
984 | } | |||
985 | } | |||
986 | ||||
987 | DPRINTF(("need to allocate the semid_kernel\n")); | |||
988 | if (key == IPC_PRIVATE(key_t)0 || (semflg & IPC_CREAT001000)) { | |||
989 | if (nsems <= 0 || nsems > seminfo.semmsl) { | |||
990 | DPRINTF(("nsems out of range (0<%d<=%d)\n", nsems, | |||
991 | seminfo.semmsl)); | |||
992 | error = EINVAL22; | |||
993 | goto done2; | |||
994 | } | |||
995 | if (nsems > seminfo.semmns - semtot) { | |||
996 | DPRINTF(( | |||
997 | "not enough semaphores left (need %d, got %d)\n", | |||
998 | nsems, seminfo.semmns - semtot)); | |||
999 | error = ENOSPC28; | |||
1000 | goto done2; | |||
1001 | } | |||
1002 | for (semid = 0; semid < seminfo.semmni; semid++) { | |||
1003 | if ((sema[semid].u.sem_perm.mode & SEM_ALLOC01000) == 0) | |||
1004 | break; | |||
1005 | } | |||
1006 | if (semid == seminfo.semmni) { | |||
1007 | DPRINTF(("no more semid_kernel's available\n")); | |||
1008 | error = ENOSPC28; | |||
1009 | goto done2; | |||
1010 | } | |||
1011 | #ifdef RACCT1 | |||
1012 | if (racct_enable) { | |||
1013 | PROC_LOCK(td->td_proc)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &(td->td_proc)->p_mtx))))->mtx_lock != 0x00000004 || !atomic_cmpset_long(&(((((&(td->td_proc)->p_mtx )))))->mtx_lock, 0x00000004, (_tid)))) __mtx_lock_sleep(& (((((&(td->td_proc)->p_mtx)))))->mtx_lock, _tid, (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire->id , (uintptr_t) (((&(td->td_proc)->p_mtx))), (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0 ); } while (0); } while (0); | |||
1014 | error = racct_add(td->td_proc, RACCT_NSEM15, nsems); | |||
1015 | PROC_UNLOCK(td->td_proc)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& (td->td_proc)->p_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release ->id, (uintptr_t) (((&(td->td_proc)->p_mtx))), ( uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&(td->td_proc)->p_mtx ))))->mtx_lock != _tid || !atomic_cmpset_long(&(((((& (td->td_proc)->p_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&(td->td_proc)->p_mtx )))))->mtx_lock, (((0))), ((((void *)0))), ((0))); } while (0); | |||
1016 | if (error != 0) { | |||
1017 | error = ENOSPC28; | |||
1018 | goto done2; | |||
1019 | } | |||
1020 | } | |||
1021 | #endif | |||
1022 | DPRINTF(("semid %d is available\n", semid)); | |||
1023 | mtx_lock(&sema_mtx[semid])do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sema_mtx[semid]))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sema_mtx[semid])))))->mtx_lock, 0x00000004 , (_tid)))) __mtx_lock_sleep(&(((((&sema_mtx[semid])) )))->mtx_lock, _tid, (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire ->id, (uintptr_t) (((&sema_mtx[semid]))), (uintptr_t) 0 , (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
1024 | KASSERT((sema[semid].u.sem_perm.mode & SEM_ALLOC) == 0,do { } while (0) | |||
1025 | ("Lost semaphore %d", semid))do { } while (0); | |||
1026 | sema[semid].u.sem_perm.key = key; | |||
1027 | sema[semid].u.sem_perm.cuid = cred->cr_uid; | |||
1028 | sema[semid].u.sem_perm.uid = cred->cr_uid; | |||
1029 | sema[semid].u.sem_perm.cgid = cred->cr_gidcr_groups[0]; | |||
1030 | sema[semid].u.sem_perm.gid = cred->cr_gidcr_groups[0]; | |||
1031 | sema[semid].u.sem_perm.mode = (semflg & 0777) | SEM_ALLOC01000; | |||
1032 | sema[semid].cred = crhold(cred); | |||
1033 | sema[semid].u.sem_perm.seq = | |||
1034 | (sema[semid].u.sem_perm.seq + 1) & 0x7fff; | |||
1035 | sema[semid].u.sem_nsems = nsems; | |||
1036 | sema[semid].u.sem_otime = 0; | |||
1037 | sema[semid].u.sem_ctime = time_second; | |||
1038 | sema[semid].u.sem_base = &sem[semtot]; | |||
1039 | semtot += nsems; | |||
1040 | bzero(sema[semid].u.sem_base, | |||
1041 | sizeof(sema[semid].u.sem_base[0])*nsems); | |||
1042 | #ifdef MAC1 | |||
1043 | mac_sysvsem_create(cred, &sema[semid]); | |||
1044 | #endif | |||
1045 | mtx_unlock(&sema_mtx[semid])do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sema_mtx[semid]))))->lock_object.lo_data == 0) do { (void) 0; do { if (__builtin_expect((sdt_lockstat___adaptive__release ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release ->id, (uintptr_t) (((&sema_mtx[semid]))), (uintptr_t) 0 , (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sema_mtx[semid]))))->mtx_lock != _tid || !atomic_cmpset_long(&(((((&sema_mtx[semid])))))-> mtx_lock, (_tid), 0x00000004)) __mtx_unlock_sleep(&(((((& sema_mtx[semid])))))->mtx_lock, (((0))), ((((void *)0))), ( (0))); } while (0); | |||
1046 | DPRINTF(("sembase = %p, next = %p\n", | |||
1047 | sema[semid].u.sem_base, &sem[semtot])); | |||
1048 | } else { | |||
1049 | DPRINTF(("didn't find it and wasn't asked to create it\n")); | |||
1050 | error = ENOENT2; | |||
1051 | goto done2; | |||
1052 | } | |||
1053 | ||||
1054 | found: | |||
1055 | td->td_retvaltd_uretoff.tdu_retval[0] = IXSEQ_TO_IPCID(semid, sema[semid].u.sem_perm)(((sema[semid].u.sem_perm.seq) << 16) | (semid & 0xffff )); | |||
1056 | done2: | |||
1057 | mtx_unlock(&sem_mtx)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sem_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release->id , (uintptr_t) (((&sem_mtx))), (uintptr_t) 0, (uintptr_t) 0 , (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sem_mtx))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sem_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sem_mtx)))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0); | |||
1058 | return (error); | |||
1059 | } | |||
1060 | ||||
1061 | #ifndef _SYS_SYSPROTO_H_ | |||
1062 | struct semop_args { | |||
1063 | int semid; | |||
1064 | struct sembuf *sops; | |||
1065 | size_t nsops; | |||
1066 | }; | |||
1067 | #endif | |||
1068 | int | |||
1069 | sys_semop(struct thread *td, struct semop_args *uap) | |||
1070 | { | |||
1071 | #define SMALL_SOPS8 8 | |||
1072 | struct sembuf small_sops[SMALL_SOPS8]; | |||
1073 | int semid = uap->semid; | |||
1074 | size_t nsops = uap->nsops; | |||
1075 | struct prison *rpr; | |||
1076 | struct sembuf *sops; | |||
1077 | struct semid_kernel *semakptr; | |||
1078 | struct sembuf *sopptr = NULL((void *)0); | |||
1079 | struct sem *semptr = NULL((void *)0); | |||
1080 | struct sem_undo *suptr; | |||
1081 | struct mtx *sema_mtxp; | |||
1082 | size_t i, j, k; | |||
1083 | int error; | |||
1084 | int do_wakeup, do_undos; | |||
1085 | unsigned short seq; | |||
1086 | ||||
1087 | #ifdef SEM_DEBUG | |||
1088 | sops = NULL((void *)0); | |||
1089 | #endif | |||
1090 | DPRINTF(("call to semop(%d, %p, %u)\n", semid, sops, nsops)); | |||
1091 | ||||
1092 | rpr = sem_find_prison(td->td_ucred); | |||
1093 | if (sem == NULL((void *)0)) | |||
1094 | return (ENOSYS78); | |||
1095 | ||||
1096 | semid = IPCID_TO_IX(semid)((semid) & 0xffff); /* Convert back to zero origin */ | |||
1097 | ||||
1098 | if (semid < 0 || semid >= seminfo.semmni) | |||
1099 | return (EINVAL22); | |||
1100 | ||||
1101 | /* Allocate memory for sem_ops */ | |||
1102 | if (nsops <= SMALL_SOPS8) | |||
1103 | sops = small_sops; | |||
1104 | else if (nsops > seminfo.semopm) { | |||
1105 | DPRINTF(("too many sops (max=%d, nsops=%d)\n", seminfo.semopm, | |||
1106 | nsops)); | |||
1107 | return (E2BIG7); | |||
1108 | } else { | |||
1109 | #ifdef RACCT1 | |||
1110 | if (racct_enable) { | |||
1111 | PROC_LOCK(td->td_proc)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &(td->td_proc)->p_mtx))))->mtx_lock != 0x00000004 || !atomic_cmpset_long(&(((((&(td->td_proc)->p_mtx )))))->mtx_lock, 0x00000004, (_tid)))) __mtx_lock_sleep(& (((((&(td->td_proc)->p_mtx)))))->mtx_lock, _tid, (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire->id , (uintptr_t) (((&(td->td_proc)->p_mtx))), (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0 ); } while (0); } while (0); | |||
1112 | if (nsops > | |||
1113 | racct_get_available(td->td_proc, RACCT_NSEMOP16)) { | |||
1114 | PROC_UNLOCK(td->td_proc)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& (td->td_proc)->p_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release ->id, (uintptr_t) (((&(td->td_proc)->p_mtx))), ( uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&(td->td_proc)->p_mtx ))))->mtx_lock != _tid || !atomic_cmpset_long(&(((((& (td->td_proc)->p_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&(td->td_proc)->p_mtx )))))->mtx_lock, (((0))), ((((void *)0))), ((0))); } while (0); | |||
1115 | return (E2BIG7); | |||
1116 | } | |||
1117 | PROC_UNLOCK(td->td_proc)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& (td->td_proc)->p_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release ->id, (uintptr_t) (((&(td->td_proc)->p_mtx))), ( uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&(td->td_proc)->p_mtx ))))->mtx_lock != _tid || !atomic_cmpset_long(&(((((& (td->td_proc)->p_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&(td->td_proc)->p_mtx )))))->mtx_lock, (((0))), ((((void *)0))), ((0))); } while (0); | |||
1118 | } | |||
1119 | #endif | |||
1120 | ||||
1121 | sops = malloc(nsops * sizeof(*sops), M_TEMP, M_WAITOK0x0002); | |||
1122 | } | |||
1123 | if ((error = copyin(uap->sops, sops, nsops * sizeof(sops[0]))) != 0) { | |||
1124 | DPRINTF(("error = %d from copyin(%p, %p, %d)\n", error, | |||
1125 | uap->sops, sops, nsops * sizeof(sops[0]))); | |||
1126 | if (sops != small_sops) | |||
1127 | free(sops, M_SEM); | |||
1128 | return (error); | |||
1129 | } | |||
1130 | ||||
1131 | semakptr = &sema[semid]; | |||
1132 | sema_mtxp = &sema_mtx[semid]; | |||
1133 | mtx_lock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( sema_mtxp))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((sema_mtxp)))))->mtx_lock, 0x00000004, (_tid)))) __mtx_lock_sleep(&(((((sema_mtxp)))))->mtx_lock, _tid , (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire->id , (uintptr_t) (((sema_mtxp))), (uintptr_t) 0, (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
1134 | if ((semakptr->u.sem_perm.mode & SEM_ALLOC01000) == 0) { | |||
1135 | error = EINVAL22; | |||
1136 | goto done2; | |||
1137 | } | |||
1138 | seq = semakptr->u.sem_perm.seq; | |||
1139 | if (seq != IPCID_TO_SEQ(uap->semid)(((uap->semid) >> 16) & 0xffff)) { | |||
1140 | error = EINVAL22; | |||
1141 | goto done2; | |||
1142 | } | |||
1143 | if ((error = sem_prison_cansee(rpr, semakptr)) != 0) | |||
1144 | goto done2; | |||
1145 | /* | |||
1146 | * Initial pass through sops to see what permissions are needed. | |||
1147 | * Also perform any checks that don't need repeating on each | |||
1148 | * attempt to satisfy the request vector. | |||
1149 | */ | |||
1150 | j = 0; /* permission needed */ | |||
1151 | do_undos = 0; | |||
1152 | for (i = 0; i < nsops; i++) { | |||
1153 | sopptr = &sops[i]; | |||
1154 | if (sopptr->sem_num >= semakptr->u.sem_nsems) { | |||
1155 | error = EFBIG27; | |||
1156 | goto done2; | |||
1157 | } | |||
1158 | if (sopptr->sem_flg & SEM_UNDO010000 && sopptr->sem_op != 0) | |||
1159 | do_undos = 1; | |||
1160 | j |= (sopptr->sem_op == 0) ? SEM_R000400 : SEM_A000200; | |||
1161 | } | |||
1162 | ||||
1163 | if ((error = ipcperm(td, &semakptr->u.sem_perm, j))) { | |||
1164 | DPRINTF(("error = %d from ipaccess\n", error)); | |||
1165 | goto done2; | |||
1166 | } | |||
1167 | #ifdef MAC1 | |||
1168 | error = mac_sysvsem_check_semop(td->td_ucred, semakptr, j); | |||
1169 | if (error != 0) | |||
1170 | goto done2; | |||
1171 | #endif | |||
1172 | ||||
1173 | /* | |||
1174 | * Loop trying to satisfy the vector of requests. | |||
1175 | * If we reach a point where we must wait, any requests already | |||
1176 | * performed are rolled back and we go to sleep until some other | |||
1177 | * process wakes us up. At this point, we start all over again. | |||
1178 | * | |||
1179 | * This ensures that from the perspective of other tasks, a set | |||
1180 | * of requests is atomic (never partially satisfied). | |||
1181 | */ | |||
1182 | for (;;) { | |||
1183 | do_wakeup = 0; | |||
1184 | error = 0; /* error return if necessary */ | |||
1185 | ||||
1186 | for (i = 0; i < nsops; i++) { | |||
1187 | sopptr = &sops[i]; | |||
1188 | semptr = &semakptr->u.sem_base[sopptr->sem_num]; | |||
1189 | ||||
1190 | DPRINTF(( | |||
1191 | "semop: semakptr=%p, sem_base=%p, " | |||
1192 | "semptr=%p, sem[%d]=%d : op=%d, flag=%s\n", | |||
1193 | semakptr, semakptr->u.sem_base, semptr, | |||
1194 | sopptr->sem_num, semptr->semval, sopptr->sem_op, | |||
1195 | (sopptr->sem_flg & IPC_NOWAIT) ? | |||
1196 | "nowait" : "wait")); | |||
1197 | ||||
1198 | if (sopptr->sem_op < 0) { | |||
1199 | if (semptr->semval + sopptr->sem_op < 0) { | |||
1200 | DPRINTF(("semop: can't do it now\n")); | |||
1201 | break; | |||
1202 | } else { | |||
1203 | semptr->semval += sopptr->sem_op; | |||
1204 | if (semptr->semval == 0 && | |||
1205 | semptr->semzcnt > 0) | |||
1206 | do_wakeup = 1; | |||
1207 | } | |||
1208 | } else if (sopptr->sem_op == 0) { | |||
1209 | if (semptr->semval != 0) { | |||
1210 | DPRINTF(("semop: not zero now\n")); | |||
1211 | break; | |||
1212 | } | |||
1213 | } else if (semptr->semval + sopptr->sem_op > | |||
1214 | seminfo.semvmx) { | |||
1215 | error = ERANGE34; | |||
1216 | break; | |||
1217 | } else { | |||
1218 | if (semptr->semncnt > 0) | |||
1219 | do_wakeup = 1; | |||
1220 | semptr->semval += sopptr->sem_op; | |||
1221 | } | |||
1222 | } | |||
1223 | ||||
1224 | /* | |||
1225 | * Did we get through the entire vector? | |||
1226 | */ | |||
1227 | if (i >= nsops) | |||
1228 | goto done; | |||
1229 | ||||
1230 | /* | |||
1231 | * No ... rollback anything that we've already done | |||
1232 | */ | |||
1233 | DPRINTF(("semop: rollback 0 through %d\n", i-1)); | |||
1234 | for (j = 0; j < i; j++) | |||
1235 | semakptr->u.sem_base[sops[j].sem_num].semval -= | |||
1236 | sops[j].sem_op; | |||
1237 | ||||
1238 | /* If we detected an error, return it */ | |||
1239 | if (error != 0) | |||
1240 | goto done2; | |||
1241 | ||||
1242 | /* | |||
1243 | * If the request that we couldn't satisfy has the | |||
1244 | * NOWAIT flag set then return with EAGAIN. | |||
1245 | */ | |||
1246 | if (sopptr->sem_flg & IPC_NOWAIT004000) { | |||
1247 | error = EAGAIN35; | |||
1248 | goto done2; | |||
1249 | } | |||
1250 | ||||
1251 | if (sopptr->sem_op == 0) | |||
1252 | semptr->semzcnt++; | |||
1253 | else | |||
1254 | semptr->semncnt++; | |||
1255 | ||||
1256 | DPRINTF(("semop: good night!\n")); | |||
1257 | error = msleep(semakptr, sema_mtxp, (PZERO - 4) | PCATCH,_sleep((semakptr), &(sema_mtxp)->lock_object, ((((80) + 20) - 4) | 0x100), ("semwait"), tick_sbt * (0), 0, 0x0100) | |||
1258 | "semwait", 0)_sleep((semakptr), &(sema_mtxp)->lock_object, ((((80) + 20) - 4) | 0x100), ("semwait"), tick_sbt * (0), 0, 0x0100); | |||
1259 | DPRINTF(("semop: good morning (error=%d)!\n", error)); | |||
1260 | /* return code is checked below, after sem[nz]cnt-- */ | |||
1261 | ||||
1262 | /* | |||
1263 | * Make sure that the semaphore still exists | |||
1264 | */ | |||
1265 | seq = semakptr->u.sem_perm.seq; | |||
1266 | if ((semakptr->u.sem_perm.mode & SEM_ALLOC01000) == 0 || | |||
1267 | seq != IPCID_TO_SEQ(uap->semid)(((uap->semid) >> 16) & 0xffff)) { | |||
1268 | error = EIDRM82; | |||
1269 | goto done2; | |||
1270 | } | |||
1271 | ||||
1272 | /* | |||
1273 | * Renew the semaphore's pointer after wakeup since | |||
1274 | * during msleep sem_base may have been modified and semptr | |||
1275 | * is not valid any more | |||
1276 | */ | |||
1277 | semptr = &semakptr->u.sem_base[sopptr->sem_num]; | |||
1278 | ||||
1279 | /* | |||
1280 | * The semaphore is still alive. Readjust the count of | |||
1281 | * waiting processes. | |||
1282 | */ | |||
1283 | if (sopptr->sem_op == 0) | |||
1284 | semptr->semzcnt--; | |||
1285 | else | |||
1286 | semptr->semncnt--; | |||
1287 | ||||
1288 | /* | |||
1289 | * Is it really morning, or was our sleep interrupted? | |||
1290 | * (Delayed check of msleep() return code because we | |||
1291 | * need to decrement sem[nz]cnt either way.) | |||
1292 | */ | |||
1293 | if (error != 0) { | |||
1294 | error = EINTR4; | |||
1295 | goto done2; | |||
1296 | } | |||
1297 | DPRINTF(("semop: good morning!\n")); | |||
1298 | } | |||
1299 | ||||
1300 | done: | |||
1301 | /* | |||
1302 | * Process any SEM_UNDO requests. | |||
1303 | */ | |||
1304 | if (do_undos) { | |||
1305 | SEMUNDO_LOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sem_undo_mtx))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, 0x00000004, ( _tid)))) __mtx_lock_sleep(&(((((&sem_undo_mtx)))))-> mtx_lock, _tid, (((0))), ((((void *)0))), ((0))); else do { ( void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire ->id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0);; | |||
1306 | suptr = NULL((void *)0); | |||
1307 | for (i = 0; i < nsops; i++) { | |||
1308 | /* | |||
1309 | * We only need to deal with SEM_UNDO's for non-zero | |||
1310 | * op's. | |||
1311 | */ | |||
1312 | int adjval; | |||
1313 | ||||
1314 | if ((sops[i].sem_flg & SEM_UNDO010000) == 0) | |||
1315 | continue; | |||
1316 | adjval = sops[i].sem_op; | |||
1317 | if (adjval == 0) | |||
1318 | continue; | |||
1319 | error = semundo_adjust(td, &suptr, semid, seq, | |||
1320 | sops[i].sem_num, -adjval); | |||
1321 | if (error == 0) | |||
1322 | continue; | |||
1323 | ||||
1324 | /* | |||
1325 | * Oh-Oh! We ran out of either sem_undo's or undo's. | |||
1326 | * Rollback the adjustments to this point and then | |||
1327 | * rollback the semaphore ups and down so we can return | |||
1328 | * with an error with all structures restored. We | |||
1329 | * rollback the undo's in the exact reverse order that | |||
1330 | * we applied them. This guarantees that we won't run | |||
1331 | * out of space as we roll things back out. | |||
1332 | */ | |||
1333 | for (j = 0; j < i; j++) { | |||
1334 | k = i - j - 1; | |||
1335 | if ((sops[k].sem_flg & SEM_UNDO010000) == 0) | |||
1336 | continue; | |||
1337 | adjval = sops[k].sem_op; | |||
1338 | if (adjval == 0) | |||
1339 | continue; | |||
1340 | if (semundo_adjust(td, &suptr, semid, seq, | |||
1341 | sops[k].sem_num, adjval) != 0) | |||
1342 | panic("semop - can't undo undos"); | |||
1343 | } | |||
1344 | ||||
1345 | for (j = 0; j < nsops; j++) | |||
1346 | semakptr->u.sem_base[sops[j].sem_num].semval -= | |||
1347 | sops[j].sem_op; | |||
1348 | ||||
1349 | DPRINTF(("error = %d from semundo_adjust\n", error)); | |||
1350 | SEMUNDO_UNLOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sem_undo_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release-> id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sem_undo_mtx))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sem_undo_mtx)))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0);; | |||
1351 | goto done2; | |||
1352 | } /* loop through the sops */ | |||
1353 | SEMUNDO_UNLOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sem_undo_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release-> id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sem_undo_mtx))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sem_undo_mtx)))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0);; | |||
1354 | } /* if (do_undos) */ | |||
1355 | ||||
1356 | /* We're definitely done - set the sempid's and time */ | |||
1357 | for (i = 0; i < nsops; i++) { | |||
1358 | sopptr = &sops[i]; | |||
1359 | semptr = &semakptr->u.sem_base[sopptr->sem_num]; | |||
1360 | semptr->sempid = td->td_proc->p_pid; | |||
1361 | } | |||
1362 | semakptr->u.sem_otime = time_second; | |||
1363 | ||||
1364 | /* | |||
1365 | * Do a wakeup if any semaphore was up'd whilst something was | |||
1366 | * sleeping on it. | |||
1367 | */ | |||
1368 | if (do_wakeup) { | |||
1369 | DPRINTF(("semop: doing wakeup\n")); | |||
1370 | wakeup(semakptr); | |||
1371 | DPRINTF(("semop: back from wakeup\n")); | |||
1372 | } | |||
1373 | DPRINTF(("semop: done\n")); | |||
1374 | td->td_retvaltd_uretoff.tdu_retval[0] = 0; | |||
1375 | done2: | |||
1376 | mtx_unlock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((sema_mtxp ))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect ((sdt_lockstat___adaptive__release->id), 0)) (*sdt_probe_func )(sdt_lockstat___adaptive__release->id, (uintptr_t) (((sema_mtxp ))), (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((sema_mtxp))))->mtx_lock != _tid || !atomic_cmpset_long(&(((((sema_mtxp)))))-> mtx_lock, (_tid), 0x00000004)) __mtx_unlock_sleep(&(((((sema_mtxp )))))->mtx_lock, (((0))), ((((void *)0))), ((0))); } while (0); | |||
1377 | if (sops != small_sops) | |||
1378 | free(sops, M_SEM); | |||
1379 | return (error); | |||
1380 | } | |||
1381 | ||||
1382 | /* | |||
1383 | * Go through the undo structures for this process and apply the adjustments to | |||
1384 | * semaphores. | |||
1385 | */ | |||
1386 | static void | |||
1387 | semexit_myhook(void *arg, struct proc *p) | |||
1388 | { | |||
1389 | struct sem_undo *suptr; | |||
1390 | struct semid_kernel *semakptr; | |||
1391 | struct mtx *sema_mtxp; | |||
1392 | int semid, semnum, adjval, ix; | |||
1393 | unsigned short seq; | |||
1394 | ||||
1395 | /* | |||
1396 | * Go through the chain of undo vectors looking for one | |||
1397 | * associated with this process. | |||
1398 | */ | |||
1399 | SEMUNDO_LOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sem_undo_mtx))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, 0x00000004, ( _tid)))) __mtx_lock_sleep(&(((((&sem_undo_mtx)))))-> mtx_lock, _tid, (((0))), ((((void *)0))), ((0))); else do { ( void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire ->id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0);; | |||
1400 | LIST_FOREACH(suptr, &semu_list, un_next)for ((suptr) = (((&semu_list))->lh_first); (suptr); (suptr ) = (((suptr))->un_next.le_next)) { | |||
1401 | if (suptr->un_proc == p) | |||
1402 | break; | |||
1403 | } | |||
1404 | if (suptr == NULL((void *)0)) { | |||
1405 | SEMUNDO_UNLOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sem_undo_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release-> id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sem_undo_mtx))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sem_undo_mtx)))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0);; | |||
1406 | return; | |||
1407 | } | |||
1408 | LIST_REMOVE(suptr, un_next)do { ; ; ; ; if ((((suptr))->un_next.le_next) != ((void *) 0)) (((suptr))->un_next.le_next)->un_next.le_prev = (suptr )->un_next.le_prev; *(suptr)->un_next.le_prev = (((suptr ))->un_next.le_next); ; ; } while (0); | |||
1409 | ||||
1410 | DPRINTF(("proc @%p has undo structure with %d entries\n", p, | |||
1411 | suptr->un_cnt)); | |||
1412 | ||||
1413 | /* | |||
1414 | * If there are any active undo elements then process them. | |||
1415 | */ | |||
1416 | if (suptr->un_cnt > 0) { | |||
1417 | SEMUNDO_UNLOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sem_undo_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release-> id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sem_undo_mtx))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sem_undo_mtx)))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0);; | |||
1418 | for (ix = 0; ix < suptr->un_cnt; ix++) { | |||
1419 | semid = suptr->un_ent[ix].un_id; | |||
1420 | semnum = suptr->un_ent[ix].un_num; | |||
1421 | adjval = suptr->un_ent[ix].un_adjval; | |||
1422 | seq = suptr->un_ent[ix].un_seq; | |||
1423 | semakptr = &sema[semid]; | |||
1424 | sema_mtxp = &sema_mtx[semid]; | |||
1425 | ||||
1426 | mtx_lock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( sema_mtxp))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((sema_mtxp)))))->mtx_lock, 0x00000004, (_tid)))) __mtx_lock_sleep(&(((((sema_mtxp)))))->mtx_lock, _tid , (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire->id , (uintptr_t) (((sema_mtxp))), (uintptr_t) 0, (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
1427 | if ((semakptr->u.sem_perm.mode & SEM_ALLOC01000) == 0 || | |||
1428 | (semakptr->u.sem_perm.seq != seq)) { | |||
1429 | mtx_unlock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((sema_mtxp ))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect ((sdt_lockstat___adaptive__release->id), 0)) (*sdt_probe_func )(sdt_lockstat___adaptive__release->id, (uintptr_t) (((sema_mtxp ))), (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((sema_mtxp))))->mtx_lock != _tid || !atomic_cmpset_long(&(((((sema_mtxp)))))-> mtx_lock, (_tid), 0x00000004)) __mtx_unlock_sleep(&(((((sema_mtxp )))))->mtx_lock, (((0))), ((((void *)0))), ((0))); } while (0); | |||
1430 | continue; | |||
1431 | } | |||
1432 | if (semnum >= semakptr->u.sem_nsems) | |||
1433 | panic("semexit - semnum out of range"); | |||
1434 | ||||
1435 | DPRINTF(( | |||
1436 | "semexit: %p id=%d num=%d(adj=%d) ; sem=%d\n", | |||
1437 | suptr->un_proc, suptr->un_ent[ix].un_id, | |||
1438 | suptr->un_ent[ix].un_num, | |||
1439 | suptr->un_ent[ix].un_adjval, | |||
1440 | semakptr->u.sem_base[semnum].semval)); | |||
1441 | ||||
1442 | if (adjval < 0 && semakptr->u.sem_base[semnum].semval < | |||
1443 | -adjval) | |||
1444 | semakptr->u.sem_base[semnum].semval = 0; | |||
1445 | else | |||
1446 | semakptr->u.sem_base[semnum].semval += adjval; | |||
1447 | ||||
1448 | wakeup(semakptr); | |||
1449 | DPRINTF(("semexit: back from wakeup\n")); | |||
1450 | mtx_unlock(sema_mtxp)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((sema_mtxp ))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect ((sdt_lockstat___adaptive__release->id), 0)) (*sdt_probe_func )(sdt_lockstat___adaptive__release->id, (uintptr_t) (((sema_mtxp ))), (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((sema_mtxp))))->mtx_lock != _tid || !atomic_cmpset_long(&(((((sema_mtxp)))))-> mtx_lock, (_tid), 0x00000004)) __mtx_unlock_sleep(&(((((sema_mtxp )))))->mtx_lock, (((0))), ((((void *)0))), ((0))); } while (0); | |||
1451 | } | |||
1452 | SEMUNDO_LOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sem_undo_mtx))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, 0x00000004, ( _tid)))) __mtx_lock_sleep(&(((((&sem_undo_mtx)))))-> mtx_lock, _tid, (((0))), ((((void *)0))), ((0))); else do { ( void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire ->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire ->id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, ( uintptr_t) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0);; | |||
1453 | } | |||
1454 | ||||
1455 | /* | |||
1456 | * Deallocate the undo vector. | |||
1457 | */ | |||
1458 | DPRINTF(("removing vector\n")); | |||
1459 | suptr->un_proc = NULL((void *)0); | |||
1460 | suptr->un_cnt = 0; | |||
1461 | LIST_INSERT_HEAD(&semu_free_list, suptr, un_next)do { ; if (((((suptr))->un_next.le_next) = (((&semu_free_list ))->lh_first)) != ((void *)0)) (((&semu_free_list))-> lh_first)->un_next.le_prev = &(((suptr))->un_next.le_next ); (((&semu_free_list))->lh_first) = (suptr); (suptr)-> un_next.le_prev = &(((&semu_free_list))->lh_first) ; } while (0); | |||
1462 | SEMUNDO_UNLOCK()do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sem_undo_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release-> id, (uintptr_t) (((&sem_undo_mtx))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sem_undo_mtx))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sem_undo_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sem_undo_mtx)))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0);; | |||
1463 | } | |||
1464 | ||||
1465 | static int | |||
1466 | sysctl_sema(SYSCTL_HANDLER_ARGSstruct sysctl_oid *oidp, void *arg1, intmax_t arg2, struct sysctl_req *req) | |||
1467 | { | |||
1468 | struct prison *pr, *rpr; | |||
1469 | struct semid_kernel tsemak; | |||
1470 | int error, i; | |||
1471 | ||||
1472 | pr = req->td->td_ucred->cr_prison; | |||
1473 | rpr = sem_find_prison(req->td->td_ucred); | |||
1474 | error = 0; | |||
1475 | for (i = 0; i < seminfo.semmni; i++) { | |||
1476 | mtx_lock(&sema_mtx[i])do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sema_mtx[i]))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sema_mtx[i])))))->mtx_lock, 0x00000004, (_tid )))) __mtx_lock_sleep(&(((((&sema_mtx[i])))))->mtx_lock , _tid, (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire-> id, (uintptr_t) (((&sema_mtx[i]))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
1477 | if ((sema[i].u.sem_perm.mode & SEM_ALLOC01000) == 0 || | |||
1478 | rpr == NULL((void *)0) || sem_prison_cansee(rpr, &sema[i]) != 0) | |||
1479 | bzero(&tsemak, sizeof(tsemak)); | |||
1480 | else { | |||
1481 | tsemak = sema[i]; | |||
1482 | if (tsemak.cred->cr_prison != pr) | |||
1483 | tsemak.u.sem_perm.key = IPC_PRIVATE(key_t)0; | |||
1484 | } | |||
1485 | mtx_unlock(&sema_mtx[i])do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sema_mtx[i]))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release-> id, (uintptr_t) (((&sema_mtx[i]))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sema_mtx[i]))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sema_mtx[i])))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sema_mtx[i])))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0); | |||
1486 | error = SYSCTL_OUT(req, &tsemak, sizeof(tsemak))(req->oldfunc)(req, &tsemak, sizeof(tsemak)); | |||
1487 | if (error != 0) | |||
1488 | break; | |||
1489 | } | |||
1490 | return (error); | |||
1491 | } | |||
1492 | ||||
1493 | static int | |||
1494 | sem_prison_check(void *obj, void *data) | |||
1495 | { | |||
1496 | struct prison *pr = obj; | |||
1497 | struct prison *prpr; | |||
1498 | struct vfsoptlist *opts = data; | |||
1499 | int error, jsys; | |||
1500 | ||||
1501 | /* | |||
1502 | * sysvsem is a jailsys integer. | |||
1503 | * It must be "disable" if the parent jail is disabled. | |||
1504 | */ | |||
1505 | error = vfs_copyopt(opts, "sysvsem", &jsys, sizeof(jsys)); | |||
1506 | if (error != ENOENT2) { | |||
1507 | if (error != 0) | |||
1508 | return (error); | |||
1509 | switch (jsys) { | |||
1510 | case JAIL_SYS_DISABLE0: | |||
1511 | break; | |||
1512 | case JAIL_SYS_NEW1: | |||
1513 | case JAIL_SYS_INHERIT2: | |||
1514 | prison_lock(pr->pr_parent); | |||
1515 | prpr = osd_jail_get(pr->pr_parent, sem_prison_slot)osd_get(1, &(pr->pr_parent)->pr_osd, (sem_prison_slot )); | |||
1516 | prison_unlock(pr->pr_parent); | |||
1517 | if (prpr == NULL((void *)0)) | |||
1518 | return (EPERM1); | |||
1519 | break; | |||
1520 | default: | |||
1521 | return (EINVAL22); | |||
1522 | } | |||
1523 | } | |||
1524 | ||||
1525 | return (0); | |||
1526 | } | |||
1527 | ||||
1528 | static int | |||
1529 | sem_prison_set(void *obj, void *data) | |||
1530 | { | |||
1531 | struct prison *pr = obj; | |||
1532 | struct prison *tpr, *orpr, *nrpr, *trpr; | |||
1533 | struct vfsoptlist *opts = data; | |||
1534 | void *rsv; | |||
1535 | int jsys, descend; | |||
1536 | ||||
1537 | /* | |||
1538 | * sysvsem controls which jail is the root of the associated sems (this | |||
1539 | * jail or same as the parent), or if the feature is available at all. | |||
1540 | */ | |||
1541 | if (vfs_copyopt(opts, "sysvsem", &jsys, sizeof(jsys)) == ENOENT2) | |||
1542 | jsys = vfs_flagopt(opts, "allow.sysvipc", NULL((void *)0), 0) | |||
1543 | ? JAIL_SYS_INHERIT2 | |||
1544 | : vfs_flagopt(opts, "allow.nosysvipc", NULL((void *)0), 0) | |||
1545 | ? JAIL_SYS_DISABLE0 | |||
1546 | : -1; | |||
1547 | if (jsys == JAIL_SYS_DISABLE0) { | |||
1548 | prison_lock(pr); | |||
1549 | orpr = osd_jail_get(pr, sem_prison_slot)osd_get(1, &(pr)->pr_osd, (sem_prison_slot)); | |||
1550 | if (orpr != NULL((void *)0)) | |||
1551 | osd_jail_del(pr, sem_prison_slot)osd_del(1, &(pr)->pr_osd, (sem_prison_slot)); | |||
1552 | prison_unlock(pr); | |||
1553 | if (orpr != NULL((void *)0)) { | |||
1554 | if (orpr == pr) | |||
1555 | sem_prison_cleanup(pr); | |||
1556 | /* Disable all child jails as well. */ | |||
1557 | FOREACH_PRISON_DESCENDANT(pr, tpr, descend)for ((tpr) = (pr), (descend) = 1; ((tpr) = (((descend) && !((&(tpr)->pr_children)->lh_first == ((void *)0))) ? ((&(tpr)->pr_children)->lh_first) : ((tpr) == (pr ) ? ((void *)0) : (((descend) = ((tpr)->pr_sibling.le_next ) != ((void *)0)) ? ((tpr)->pr_sibling.le_next) : (tpr)-> pr_parent))));) if (!(descend)) ; else { | |||
1558 | prison_lock(tpr); | |||
1559 | trpr = osd_jail_get(tpr, sem_prison_slot)osd_get(1, &(tpr)->pr_osd, (sem_prison_slot)); | |||
1560 | if (trpr != NULL((void *)0)) { | |||
1561 | osd_jail_del(tpr, sem_prison_slot)osd_del(1, &(tpr)->pr_osd, (sem_prison_slot)); | |||
1562 | prison_unlock(tpr); | |||
1563 | if (trpr == tpr) | |||
1564 | sem_prison_cleanup(tpr); | |||
1565 | } else { | |||
1566 | prison_unlock(tpr); | |||
1567 | descend = 0; | |||
1568 | } | |||
1569 | } | |||
1570 | } | |||
1571 | } else if (jsys != -1) { | |||
1572 | if (jsys == JAIL_SYS_NEW1) | |||
1573 | nrpr = pr; | |||
1574 | else { | |||
1575 | prison_lock(pr->pr_parent); | |||
1576 | nrpr = osd_jail_get(pr->pr_parent, sem_prison_slot)osd_get(1, &(pr->pr_parent)->pr_osd, (sem_prison_slot )); | |||
1577 | prison_unlock(pr->pr_parent); | |||
1578 | } | |||
1579 | rsv = osd_reserve(sem_prison_slot); | |||
1580 | prison_lock(pr); | |||
1581 | orpr = osd_jail_get(pr, sem_prison_slot)osd_get(1, &(pr)->pr_osd, (sem_prison_slot)); | |||
1582 | if (orpr != nrpr) | |||
1583 | (void)osd_jail_set_reserved(pr, sem_prison_slot, rsv,osd_set_reserved(1, &(pr)->pr_osd, (sem_prison_slot), ( rsv), (nrpr)) | |||
1584 | nrpr)osd_set_reserved(1, &(pr)->pr_osd, (sem_prison_slot), ( rsv), (nrpr)); | |||
1585 | else | |||
1586 | osd_free_reserved(rsv); | |||
1587 | prison_unlock(pr); | |||
1588 | if (orpr != nrpr) { | |||
1589 | if (orpr == pr) | |||
1590 | sem_prison_cleanup(pr); | |||
1591 | if (orpr != NULL((void *)0)) { | |||
1592 | /* Change child jails matching the old root, */ | |||
1593 | FOREACH_PRISON_DESCENDANT(pr, tpr, descend)for ((tpr) = (pr), (descend) = 1; ((tpr) = (((descend) && !((&(tpr)->pr_children)->lh_first == ((void *)0))) ? ((&(tpr)->pr_children)->lh_first) : ((tpr) == (pr ) ? ((void *)0) : (((descend) = ((tpr)->pr_sibling.le_next ) != ((void *)0)) ? ((tpr)->pr_sibling.le_next) : (tpr)-> pr_parent))));) if (!(descend)) ; else { | |||
1594 | prison_lock(tpr); | |||
1595 | trpr = osd_jail_get(tpr,osd_get(1, &(tpr)->pr_osd, (sem_prison_slot)) | |||
1596 | sem_prison_slot)osd_get(1, &(tpr)->pr_osd, (sem_prison_slot)); | |||
1597 | if (trpr == orpr) { | |||
1598 | (void)osd_jail_set(tpr,osd_set(1, &(tpr)->pr_osd, (sem_prison_slot), (nrpr)) | |||
1599 | sem_prison_slot, nrpr)osd_set(1, &(tpr)->pr_osd, (sem_prison_slot), (nrpr)); | |||
1600 | prison_unlock(tpr); | |||
1601 | if (trpr == tpr) | |||
1602 | sem_prison_cleanup(tpr); | |||
1603 | } else { | |||
1604 | prison_unlock(tpr); | |||
1605 | descend = 0; | |||
1606 | } | |||
1607 | } | |||
1608 | } | |||
1609 | } | |||
1610 | } | |||
1611 | ||||
1612 | return (0); | |||
1613 | } | |||
1614 | ||||
1615 | static int | |||
1616 | sem_prison_get(void *obj, void *data) | |||
1617 | { | |||
1618 | struct prison *pr = obj; | |||
1619 | struct prison *rpr; | |||
1620 | struct vfsoptlist *opts = data; | |||
1621 | int error, jsys; | |||
1622 | ||||
1623 | /* Set sysvsem based on the jail's root prison. */ | |||
1624 | prison_lock(pr); | |||
1625 | rpr = osd_jail_get(pr, sem_prison_slot)osd_get(1, &(pr)->pr_osd, (sem_prison_slot)); | |||
1626 | prison_unlock(pr); | |||
1627 | jsys = rpr == NULL((void *)0) ? JAIL_SYS_DISABLE0 | |||
1628 | : rpr == pr ? JAIL_SYS_NEW1 : JAIL_SYS_INHERIT2; | |||
1629 | error = vfs_setopt(opts, "sysvsem", &jsys, sizeof(jsys)); | |||
1630 | if (error == ENOENT2) | |||
1631 | error = 0; | |||
1632 | return (error); | |||
1633 | } | |||
1634 | ||||
1635 | static int | |||
1636 | sem_prison_remove(void *obj, void *data __unused__attribute__((__unused__))) | |||
1637 | { | |||
1638 | struct prison *pr = obj; | |||
1639 | struct prison *rpr; | |||
1640 | ||||
1641 | prison_lock(pr); | |||
1642 | rpr = osd_jail_get(pr, sem_prison_slot)osd_get(1, &(pr)->pr_osd, (sem_prison_slot)); | |||
1643 | prison_unlock(pr); | |||
1644 | if (rpr == pr) | |||
1645 | sem_prison_cleanup(pr); | |||
1646 | return (0); | |||
1647 | } | |||
1648 | ||||
1649 | static void | |||
1650 | sem_prison_cleanup(struct prison *pr) | |||
1651 | { | |||
1652 | int i; | |||
1653 | ||||
1654 | /* Remove any sems that belong to this jail. */ | |||
1655 | mtx_lock(&sem_mtx)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sem_mtx))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sem_mtx)))))->mtx_lock, 0x00000004, (_tid) ))) __mtx_lock_sleep(&(((((&sem_mtx)))))->mtx_lock , _tid, (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire-> id, (uintptr_t) (((&sem_mtx))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
1656 | for (i = 0; i < seminfo.semmni; i++) { | |||
1657 | if ((sema[i].u.sem_perm.mode & SEM_ALLOC01000) && | |||
1658 | sema[i].cred != NULL((void *)0) && sema[i].cred->cr_prison == pr) { | |||
1659 | mtx_lock(&sema_mtx[i])do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((( &sema_mtx[i]))))->mtx_lock != 0x00000004 || !atomic_cmpset_long (&(((((&sema_mtx[i])))))->mtx_lock, 0x00000004, (_tid )))) __mtx_lock_sleep(&(((((&sema_mtx[i])))))->mtx_lock , _tid, (((0))), ((((void *)0))), ((0))); else do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__acquire-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__acquire-> id, (uintptr_t) (((&sema_mtx[i]))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); } while (0); | |||
1660 | sem_remove(i, NULL((void *)0)); | |||
1661 | mtx_unlock(&sema_mtx[i])do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sema_mtx[i]))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release-> id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release-> id, (uintptr_t) (((&sema_mtx[i]))), (uintptr_t) 0, (uintptr_t ) 0, (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sema_mtx[i]))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sema_mtx[i])))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sema_mtx[i])))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0); | |||
1662 | } | |||
1663 | } | |||
1664 | mtx_unlock(&sem_mtx)do { uintptr_t _tid = (uintptr_t)((__curthread())); if (((((& sem_mtx))))->lock_object.lo_data == 0) do { (void)0; do { if (__builtin_expect((sdt_lockstat___adaptive__release->id), 0)) (*sdt_probe_func)(sdt_lockstat___adaptive__release->id , (uintptr_t) (((&sem_mtx))), (uintptr_t) 0, (uintptr_t) 0 , (uintptr_t) 0, (uintptr_t) 0); } while (0); } while (0); if (((((&sem_mtx))))->mtx_lock != _tid || !atomic_cmpset_long (&(((((&sem_mtx)))))->mtx_lock, (_tid), 0x00000004 )) __mtx_unlock_sleep(&(((((&sem_mtx)))))->mtx_lock , (((0))), ((((void *)0))), ((0))); } while (0); | |||
1665 | } | |||
1666 | ||||
1667 | SYSCTL_JAIL_PARAM_SYS_NODE(sysvsem, CTLFLAG_RW, "SYSV semaphores")struct sysctl_oid sysctl___security_jail_param_sysvsem = { .oid_parent = ((&(&sysctl___security_jail_param)->oid_children )), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (1|(0)), .oid_arg1 = (((void *)0)), .oid_arg2 = (0), .oid_name = ("sysvsem"), .oid_handler = (0), .oid_fmt = ("N"), .oid_descr = "SYSV semaphores" }; __asm__(".globl " "__start_set_sysctl_set" ); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___security_jail_param_sysvsem __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___security_jail_param_sysvsem); _Static_assert (((0) & 0xf) == 0 || ((0) & 0) == 1, "compile-time assertion failed" ); static struct sysctl_oid sysctl___security_jail_param_sysvsem_ = { .oid_parent = ((&(&sysctl___security_jail_param_sysvsem )->oid_children)), .oid_children = { ((void *)0) }, .oid_number = ((-1)), .oid_kind = (((2 | ((0x80000000|0x40000000))) | 0x00040000 )), .oid_arg1 = (((void *)0)), .oid_arg2 = (0), .oid_name = ( ""), .oid_handler = (sysctl_jail_param), .oid_fmt = ("E,jailsys" ), .oid_descr = "SYSV semaphores" }; __asm__(".globl " "__start_set_sysctl_set" ); __asm__(".globl " "__stop_set_sysctl_set"); static void const * const __set_sysctl_set_sym_sysctl___security_jail_param_sysvsem_ __attribute__((__section__("set_" "sysctl_set"))) __attribute__ ((__used__)) = &(sysctl___security_jail_param_sysvsem_); _Static_assert ((((2 | ((0x80000000|0x40000000))) | 0x00040000) & 0xf) != 0, "compile-time assertion failed"); | |||
1668 | ||||
1669 | #if defined(COMPAT_FREEBSD41) || defined(COMPAT_FREEBSD51) || \ | |||
1670 | defined(COMPAT_FREEBSD61) || defined(COMPAT_FREEBSD71) | |||
1671 | ||||
1672 | /* XXX casting to (sy_call_t *) is bogus, as usual. */ | |||
1673 | static sy_call_t *semcalls[] = { | |||
1674 | (sy_call_t *)freebsd7___semctl, (sy_call_t *)sys_semget, | |||
1675 | (sy_call_t *)sys_semop | |||
1676 | }; | |||
1677 | ||||
1678 | /* | |||
1679 | * Entry point for all SEM calls. | |||
1680 | */ | |||
1681 | int | |||
1682 | sys_semsys(td, uap) | |||
1683 | struct thread *td; | |||
1684 | /* XXX actually varargs. */ | |||
1685 | struct semsys_args /* { | |||
1686 | int which; | |||
1687 | int a2; | |||
1688 | int a3; | |||
1689 | int a4; | |||
1690 | int a5; | |||
1691 | } */ *uap; | |||
1692 | { | |||
1693 | int error; | |||
1694 | ||||
1695 | if (uap->which < 0 || uap->which >= nitems(semcalls)(sizeof((semcalls)) / sizeof((semcalls)[0]))) | |||
1696 | return (EINVAL22); | |||
1697 | error = (*semcalls[uap->which])(td, &uap->a2); | |||
1698 | return (error); | |||
1699 | } | |||
1700 | ||||
1701 | #ifndef CP | |||
1702 | #define CP(src, dst, fld)do { (dst).fld = (src).fld; } while (0) do { (dst).fld = (src).fld; } while (0) | |||
1703 | #endif | |||
1704 | ||||
1705 | #ifndef _SYS_SYSPROTO_H_ | |||
1706 | struct freebsd7___semctl_args { | |||
1707 | int semid; | |||
1708 | int semnum; | |||
1709 | int cmd; | |||
1710 | union semun_old *arg; | |||
1711 | }; | |||
1712 | #endif | |||
1713 | int | |||
1714 | freebsd7___semctl(struct thread *td, struct freebsd7___semctl_args *uap) | |||
1715 | { | |||
1716 | struct semid_ds_old dsold; | |||
1717 | struct semid_ds dsbuf; | |||
1718 | union semun_old arg; | |||
1719 | union semun semun; | |||
1720 | register_t rval; | |||
1721 | int error; | |||
1722 | ||||
1723 | switch (uap->cmd) { | |||
1724 | case SEM_STAT10: | |||
1725 | case IPC_SET1: | |||
1726 | case IPC_STAT2: | |||
1727 | case GETALL6: | |||
1728 | case SETVAL8: | |||
1729 | case SETALL9: | |||
1730 | error = copyin(uap->arg, &arg, sizeof(arg)); | |||
1731 | if (error) | |||
1732 | return (error); | |||
1733 | break; | |||
1734 | } | |||
1735 | ||||
1736 | switch (uap->cmd) { | |||
1737 | case SEM_STAT10: | |||
1738 | case IPC_STAT2: | |||
1739 | semun.buf = &dsbuf; | |||
1740 | break; | |||
1741 | case IPC_SET1: | |||
1742 | error = copyin(arg.buf, &dsold, sizeof(dsold)); | |||
1743 | if (error) | |||
1744 | return (error); | |||
1745 | ipcperm_old2new(&dsold.sem_perm, &dsbuf.sem_perm); | |||
1746 | CP(dsold, dsbuf, sem_base)do { (dsbuf).sem_base = (dsold).sem_base; } while (0); | |||
1747 | CP(dsold, dsbuf, sem_nsems)do { (dsbuf).sem_nsems = (dsold).sem_nsems; } while (0); | |||
1748 | CP(dsold, dsbuf, sem_otime)do { (dsbuf).sem_otime = (dsold).sem_otime; } while (0); | |||
1749 | CP(dsold, dsbuf, sem_ctime)do { (dsbuf).sem_ctime = (dsold).sem_ctime; } while (0); | |||
1750 | semun.buf = &dsbuf; | |||
1751 | break; | |||
1752 | case GETALL6: | |||
1753 | case SETALL9: | |||
1754 | semun.array = arg.array; | |||
1755 | break; | |||
1756 | case SETVAL8: | |||
1757 | semun.val = arg.val; | |||
1758 | break; | |||
1759 | } | |||
1760 | ||||
1761 | error = kern_semctl(td, uap->semid, uap->semnum, uap->cmd, &semun, | |||
1762 | &rval); | |||
1763 | if (error) | |||
1764 | return (error); | |||
1765 | ||||
1766 | switch (uap->cmd) { | |||
1767 | case SEM_STAT10: | |||
1768 | case IPC_STAT2: | |||
1769 | bzero(&dsold, sizeof(dsold)); | |||
1770 | ipcperm_new2old(&dsbuf.sem_perm, &dsold.sem_perm); | |||
1771 | CP(dsbuf, dsold, sem_base)do { (dsold).sem_base = (dsbuf).sem_base; } while (0); | |||
1772 | CP(dsbuf, dsold, sem_nsems)do { (dsold).sem_nsems = (dsbuf).sem_nsems; } while (0); | |||
1773 | CP(dsbuf, dsold, sem_otime)do { (dsold).sem_otime = (dsbuf).sem_otime; } while (0); | |||
1774 | CP(dsbuf, dsold, sem_ctime)do { (dsold).sem_ctime = (dsbuf).sem_ctime; } while (0); | |||
1775 | error = copyout(&dsold, arg.buf, sizeof(dsold)); | |||
1776 | break; | |||
1777 | } | |||
1778 | ||||
1779 | if (error == 0) | |||
1780 | td->td_retvaltd_uretoff.tdu_retval[0] = rval; | |||
1781 | return (error); | |||
1782 | } | |||
1783 | ||||
1784 | #endif /* COMPAT_FREEBSD{4,5,6,7} */ | |||
1785 | ||||
1786 | #ifdef COMPAT_FREEBSD321 | |||
1787 | ||||
1788 | int | |||
1789 | freebsd32_semsys(struct thread *td, struct freebsd32_semsys_args *uap) | |||
1790 | { | |||
1791 | ||||
1792 | #if defined(COMPAT_FREEBSD41) || defined(COMPAT_FREEBSD51) || \ | |||
1793 | defined(COMPAT_FREEBSD61) || defined(COMPAT_FREEBSD71) | |||
1794 | switch (uap->which) { | |||
1795 | case 0: | |||
1796 | return (freebsd7_freebsd32_semctl(td, | |||
1797 | (struct freebsd7_freebsd32_semctl_args *)&uap->a2)); | |||
1798 | default: | |||
1799 | return (sys_semsys(td, (struct semsys_args *)uap)); | |||
1800 | } | |||
1801 | #else | |||
1802 | return (nosys(td, NULL((void *)0))); | |||
1803 | #endif | |||
1804 | } | |||
1805 | ||||
1806 | #if defined(COMPAT_FREEBSD41) || defined(COMPAT_FREEBSD51) || \ | |||
1807 | defined(COMPAT_FREEBSD61) || defined(COMPAT_FREEBSD71) | |||
1808 | int | |||
1809 | freebsd7_freebsd32_semctl(struct thread *td, | |||
1810 | struct freebsd7_freebsd32_semctl_args *uap) | |||
1811 | { | |||
1812 | struct semid_ds32_old dsbuf32; | |||
1813 | struct semid_ds dsbuf; | |||
1814 | union semun semun; | |||
1815 | union semun32 arg; | |||
1816 | register_t rval; | |||
1817 | int error; | |||
1818 | ||||
1819 | switch (uap->cmd) { | |||
1820 | case SEM_STAT10: | |||
1821 | case IPC_SET1: | |||
1822 | case IPC_STAT2: | |||
1823 | case GETALL6: | |||
1824 | case SETVAL8: | |||
1825 | case SETALL9: | |||
1826 | error = copyin(uap->arg, &arg, sizeof(arg)); | |||
1827 | if (error) | |||
1828 | return (error); | |||
1829 | break; | |||
1830 | } | |||
1831 | ||||
1832 | switch (uap->cmd) { | |||
1833 | case SEM_STAT10: | |||
1834 | case IPC_STAT2: | |||
1835 | semun.buf = &dsbuf; | |||
1836 | break; | |||
1837 | case IPC_SET1: | |||
1838 | error = copyin(PTRIN(arg.buf)(void *)(uintptr_t) (arg.buf), &dsbuf32, sizeof(dsbuf32)); | |||
1839 | if (error) | |||
1840 | return (error); | |||
1841 | freebsd32_ipcperm_old_in(&dsbuf32.sem_perm, &dsbuf.sem_perm); | |||
1842 | PTRIN_CP(dsbuf32, dsbuf, sem_base)do { (dsbuf).sem_base = (void *)(uintptr_t) ((dsbuf32).sem_base ); } while (0); | |||
1843 | CP(dsbuf32, dsbuf, sem_nsems)do { (dsbuf).sem_nsems = (dsbuf32).sem_nsems; } while (0); | |||
1844 | CP(dsbuf32, dsbuf, sem_otime)do { (dsbuf).sem_otime = (dsbuf32).sem_otime; } while (0); | |||
1845 | CP(dsbuf32, dsbuf, sem_ctime)do { (dsbuf).sem_ctime = (dsbuf32).sem_ctime; } while (0); | |||
1846 | semun.buf = &dsbuf; | |||
1847 | break; | |||
1848 | case GETALL6: | |||
1849 | case SETALL9: | |||
1850 | semun.array = PTRIN(arg.array)(void *)(uintptr_t) (arg.array); | |||
1851 | break; | |||
1852 | case SETVAL8: | |||
1853 | semun.val = arg.val; | |||
1854 | break; | |||
1855 | } | |||
1856 | ||||
1857 | error = kern_semctl(td, uap->semid, uap->semnum, uap->cmd, &semun, | |||
1858 | &rval); | |||
1859 | if (error) | |||
1860 | return (error); | |||
1861 | ||||
1862 | switch (uap->cmd) { | |||
1863 | case SEM_STAT10: | |||
1864 | case IPC_STAT2: | |||
1865 | bzero(&dsbuf32, sizeof(dsbuf32)); | |||
1866 | freebsd32_ipcperm_old_out(&dsbuf.sem_perm, &dsbuf32.sem_perm); | |||
1867 | PTROUT_CP(dsbuf, dsbuf32, sem_base)do { (dsbuf32).sem_base = (u_int32_t)(uintptr_t) ((dsbuf).sem_base ); } while (0); | |||
1868 | CP(dsbuf, dsbuf32, sem_nsems)do { (dsbuf32).sem_nsems = (dsbuf).sem_nsems; } while (0); | |||
1869 | CP(dsbuf, dsbuf32, sem_otime)do { (dsbuf32).sem_otime = (dsbuf).sem_otime; } while (0); | |||
1870 | CP(dsbuf, dsbuf32, sem_ctime)do { (dsbuf32).sem_ctime = (dsbuf).sem_ctime; } while (0); | |||
1871 | error = copyout(&dsbuf32, PTRIN(arg.buf)(void *)(uintptr_t) (arg.buf), sizeof(dsbuf32)); | |||
1872 | break; | |||
1873 | } | |||
1874 | ||||
1875 | if (error == 0) | |||
1876 | td->td_retvaltd_uretoff.tdu_retval[0] = rval; | |||
1877 | return (error); | |||
1878 | } | |||
1879 | #endif | |||
1880 | ||||
1881 | int | |||
1882 | freebsd32_semctl(struct thread *td, struct freebsd32_semctl_args *uap) | |||
1883 | { | |||
1884 | struct semid_ds32 dsbuf32; | |||
1885 | struct semid_ds dsbuf; | |||
1886 | union semun semun; | |||
1887 | union semun32 arg; | |||
1888 | register_t rval; | |||
1889 | int error; | |||
1890 | ||||
1891 | switch (uap->cmd) { | |||
1892 | case SEM_STAT10: | |||
1893 | case IPC_SET1: | |||
1894 | case IPC_STAT2: | |||
1895 | case GETALL6: | |||
1896 | case SETVAL8: | |||
1897 | case SETALL9: | |||
1898 | error = copyin(uap->arg, &arg, sizeof(arg)); | |||
1899 | if (error) | |||
1900 | return (error); | |||
1901 | break; | |||
1902 | } | |||
1903 | ||||
1904 | switch (uap->cmd) { | |||
1905 | case SEM_STAT10: | |||
1906 | case IPC_STAT2: | |||
1907 | semun.buf = &dsbuf; | |||
1908 | break; | |||
1909 | case IPC_SET1: | |||
1910 | error = copyin(PTRIN(arg.buf)(void *)(uintptr_t) (arg.buf), &dsbuf32, sizeof(dsbuf32)); | |||
1911 | if (error) | |||
1912 | return (error); | |||
1913 | freebsd32_ipcperm_in(&dsbuf32.sem_perm, &dsbuf.sem_perm); | |||
1914 | PTRIN_CP(dsbuf32, dsbuf, sem_base)do { (dsbuf).sem_base = (void *)(uintptr_t) ((dsbuf32).sem_base ); } while (0); | |||
1915 | CP(dsbuf32, dsbuf, sem_nsems)do { (dsbuf).sem_nsems = (dsbuf32).sem_nsems; } while (0); | |||
1916 | CP(dsbuf32, dsbuf, sem_otime)do { (dsbuf).sem_otime = (dsbuf32).sem_otime; } while (0); | |||
1917 | CP(dsbuf32, dsbuf, sem_ctime)do { (dsbuf).sem_ctime = (dsbuf32).sem_ctime; } while (0); | |||
1918 | semun.buf = &dsbuf; | |||
1919 | break; | |||
1920 | case GETALL6: | |||
1921 | case SETALL9: | |||
1922 | semun.array = PTRIN(arg.array)(void *)(uintptr_t) (arg.array); | |||
1923 | break; | |||
1924 | case SETVAL8: | |||
1925 | semun.val = arg.val; | |||
1926 | break; | |||
1927 | } | |||
1928 | ||||
1929 | error = kern_semctl(td, uap->semid, uap->semnum, uap->cmd, &semun, | |||
1930 | &rval); | |||
1931 | if (error) | |||
1932 | return (error); | |||
1933 | ||||
1934 | switch (uap->cmd) { | |||
1935 | case SEM_STAT10: | |||
1936 | case IPC_STAT2: | |||
1937 | bzero(&dsbuf32, sizeof(dsbuf32)); | |||
1938 | freebsd32_ipcperm_out(&dsbuf.sem_perm, &dsbuf32.sem_perm); | |||
1939 | PTROUT_CP(dsbuf, dsbuf32, sem_base)do { (dsbuf32).sem_base = (u_int32_t)(uintptr_t) ((dsbuf).sem_base ); } while (0); | |||
1940 | CP(dsbuf, dsbuf32, sem_nsems)do { (dsbuf32).sem_nsems = (dsbuf).sem_nsems; } while (0); | |||
1941 | CP(dsbuf, dsbuf32, sem_otime)do { (dsbuf32).sem_otime = (dsbuf).sem_otime; } while (0); | |||
1942 | CP(dsbuf, dsbuf32, sem_ctime)do { (dsbuf32).sem_ctime = (dsbuf).sem_ctime; } while (0); | |||
1943 | error = copyout(&dsbuf32, PTRIN(arg.buf)(void *)(uintptr_t) (arg.buf), sizeof(dsbuf32)); | |||
1944 | break; | |||
1945 | } | |||
1946 | ||||
1947 | if (error == 0) | |||
1948 | td->td_retvaltd_uretoff.tdu_retval[0] = rval; | |||
1949 | return (error); | |||
1950 | } | |||
1951 | ||||
1952 | #endif /* COMPAT_FREEBSD32 */ |