/freebsd/lib/libc/gen/ |
H A D | sem.c | 79 struct sem { struct 89 LIST_ENTRY(sem) entry; argument 90 struct sem **backpointer; argument 93 typedef struct sem* sem_t; 107 static void sem_free(sem_t sem); 109 static LIST_HEAD(, sem) named_sems = LIST_HEAD_INITIALIZER(named_sems); 124 sem_check_validity(sem_t *sem) in sem_check_validity() argument 127 if ((sem != NULL) && ((*sem)->magic == SEM_MAGIC)) in sem_check_validity() 136 sem_free(sem_t sem) in sem_free() argument 139 sem->magic = 0; in sem_free() [all …]
|
H A D | sem_new.c | 75 sem_t *sem; member 113 sem_check_validity(sem_t *sem) in sem_check_validity() argument 116 if (sem->_magic == SEM_MAGIC) in sem_check_validity() 123 _sem_init(sem_t *sem, int pshared, unsigned int value) in _sem_init() argument 131 bzero(sem, sizeof(sem_t)); in _sem_init() 132 sem->_magic = SEM_MAGIC; in _sem_init() 133 sem->_kern._count = (u_int32_t)value; in _sem_init() 134 sem->_kern._flags = pshared ? USYNC_PROCESS_SHARED : 0; in _sem_init() 145 sem_t *sem, tmp; in _sem_open() local 149 sem = NULL; in _sem_open() [all …]
|
/freebsd/lib/libthr/thread/ |
H A D | thr_sem.c | 54 typedef struct sem *sem_t; 56 extern int _libc_sem_init_compat(sem_t *sem, int pshared, unsigned int value); 57 extern int _libc_sem_destroy_compat(sem_t *sem); 58 extern int _libc_sem_getvalue_compat(sem_t * __restrict sem, int * __restrict sval); 59 extern int _libc_sem_trywait_compat(sem_t *sem); 60 extern int _libc_sem_wait_compat(sem_t *sem); 61 extern int _libc_sem_timedwait_compat(sem_t * __restrict sem, 63 extern int _libc_sem_post_compat(sem_t *sem); 65 int _sem_init_compat(sem_t *sem, int pshared, unsigned int value); 66 int _sem_destroy_compat(sem_t *sem); [all …]
|
/freebsd/tools/test/stress2/testcases/lockf/ |
H A D | lockf.c | 50 int r, sem; in get() local 59 r = read(fd, &sem, sizeof(sem)); in get() 64 if (r != sizeof(sem)) in get() 70 return (sem); in get() 75 int r, sem; in incr() local 82 if (read(fd, &sem, sizeof(sem)) != sizeof(sem)) in incr() 86 sem++; in incr() 87 if (write(fd, &sem, sizeof(sem)) != sizeof(sem)) in incr() 136 int sem = 0; in test() local 145 if (write(fd, &sem, sizeof(sem)) != sizeof(sem)) in test()
|
/freebsd/contrib/netbsd-tests/lib/librt/ |
H A D | t_sem.c | 250 sem_t sem; in ATF_TC_BODY() local 252 SEM_REQUIRE(sem_init(&sem, 0, 0)); in ATF_TC_BODY() 253 SEM_REQUIRE(sem_post(&sem)); in ATF_TC_BODY() 257 SEM_REQUIRE(sem_timedwait(&sem, &ts)); in ATF_TC_BODY() 258 ATF_REQUIRE_ERRNO(ETIMEDOUT, sem_timedwait(&sem, &ts)); in ATF_TC_BODY() 260 ATF_REQUIRE_ERRNO(ETIMEDOUT, sem_timedwait(&sem, &ts)); in ATF_TC_BODY() 261 SEM_REQUIRE(sem_post(&sem)); in ATF_TC_BODY() 262 SEM_REQUIRE(sem_timedwait(&sem, &ts)); in ATF_TC_BODY() 266 ATF_REQUIRE_ERRNO(EINVAL, sem_timedwait(&sem, &ts)); in ATF_TC_BODY() 268 ATF_REQUIRE_ERRNO(EINVAL, sem_timedwait(&sem, &ts)); in ATF_TC_BODY() [all …]
|
/freebsd/contrib/netbsd-tests/lib/semaphore/ |
H A D | sem.c | 36 sem_t sem; in ATF_TC_BODY() local 41 ATF_REQUIRE_EQ(sem_init(&sem, 1, 0), 0); in ATF_TC_BODY() 43 sem_post(&sem); in ATF_TC_BODY() 44 sem_post(&sem); in ATF_TC_BODY() 46 sem_wait(&sem); in ATF_TC_BODY() 47 sem_wait(&sem); in ATF_TC_BODY() 48 rv = sem_trywait(&sem); in ATF_TC_BODY() 63 sem_t sem; in ATF_TC_BODY() local 66 sem_init(&sem, 1, 4); in ATF_TC_BODY() 68 ATF_REQUIRE_EQ(sem_trywait(&sem), 0); in ATF_TC_BODY() [all …]
|
/freebsd/tools/test/stress2/misc/ |
H A D | fts2.sh | 90 int sem; 93 if (read(fd, &sem, sizeof(sem)) != sizeof(sem)) 99 return (sem); 104 int sem; 107 if (read(fd, &sem, sizeof(sem)) != sizeof(sem)) 111 sem++; 112 if (write(fd, &sem, sizeof(sem)) != sizeof(sem)) 124 int sem = 0; 130 if (write(fd, &sem, sizeof(sem)) != sizeof(sem))
|
H A D | sem.sh | 37 sed '1,/^EOF/d' < $odir/$0 > sem.c 38 mycc -o sem -Wall sem.c 39 rm -f sem.c 43 /tmp/sem& 49 rm -f /tmp/sem 103 /* get sem */ 123 /* create sem */
|
H A D | sem_timedwait.sh | 98 sem_t sem; 105 sem_init(&sem, 0, 0); 116 sem_post(&sem); 119 } while (sem_timedwait(&sem, &tm) == -1);
|
/freebsd/tests/sys/fs/fusefs/ |
H A D | rmdir.cc | 78 sem_t sem; in TEST_F() local 82 ASSERT_EQ(0, sem_init(&sem, 0, 0)) << strerror(errno); in TEST_F() 94 expect_forget(ino, 1, &sem); in TEST_F() 111 sem_wait(&sem); in TEST_F() 112 sem_destroy(&sem); in TEST_F() 133 sem_t sem; in TEST_F() local 138 expect_forget(ino, 1, &sem); in TEST_F() 142 sem_wait(&sem); in TEST_F() 143 sem_destroy(&sem); in TEST_F() 150 sem_t sem; in TEST_F() local [all …]
|
H A D | last_local_modify.cc | 110 sem_t *sem = (sem_t*) arg; in allocate_th() local 112 if (sem) in allocate_th() 113 sem_wait(sem); in allocate_th() 130 sem_t *sem = (sem_t*) arg; in copy_file_range_th() local 135 if (sem) in copy_file_range_th() 136 sem_wait(sem); in copy_file_range_th() 152 sem_t *sem = (sem_t*) arg; in setattr_th() local 154 if (sem) in setattr_th() 155 sem_wait(sem); in setattr_th() 172 sem_t *sem = (sem_t*) arg; in write_th() local [all …]
|
H A D | destroy.cc | 77 sem_t sem; in TEST_F() local 80 sem_init(&sem, 0, 0); in TEST_F() 105 sem_post(&sem); in TEST_F() 119 sem_wait(&sem); in TEST_F() 128 sem_destroy(&sem); in TEST_F()
|
H A D | opendir.cc | 85 sem_t sem; in TEST_F() local 87 ASSERT_EQ(0, sem_init(&sem, 0, 0)) << strerror(errno); in TEST_F() 93 expect_forget(ino, 1, &sem); in TEST_F() 98 sem_wait(&sem); in TEST_F() 99 sem_destroy(&sem); in TEST_F()
|
H A D | forget.cc | 65 sem_t sem; in TEST_F() local 67 ASSERT_EQ(0, sem_init(&sem, 0, 0)) << strerror(errno); in TEST_F() 79 expect_forget(ino, 3, &sem); in TEST_F() 90 sem_wait(&sem); in TEST_F() 91 sem_destroy(&sem); in TEST_F()
|
H A D | getattr.cc | 175 sem_t sem; in TEST_F() local 177 ASSERT_EQ(0, sem_init(&sem, 0, 0)) << strerror(errno); in TEST_F() 189 expect_forget(ino, 1, &sem); in TEST_F() 194 sem_wait(&sem); in TEST_F() 195 sem_destroy(&sem); in TEST_F() 273 sem_t sem; in TEST_F() local 275 ASSERT_EQ(0, sem_init(&sem, 0, 0)) << strerror(errno); in TEST_F() 301 expect_forget(ino, 1, &sem); in TEST_F() 306 sem_wait(&sem); in TEST_F() 307 sem_destroy(&sem); in TEST_F()
|
H A D | utils.cc | 256 FuseTest::expect_forget(uint64_t ino, uint64_t nlookup, sem_t *sem) in expect_forget() argument 266 if (sem != NULL) in expect_forget() 267 sem_post(sem); in expect_forget() 585 sem_t *sem; in fork() local 598 sem = (sem_t*)mmap(NULL, sizeof(*sem), mprot, mflags, -1, 0); in fork() 599 ASSERT_NE(MAP_FAILED, sem) << strerror(errno); in fork() 600 ASSERT_EQ(0, sem_init(sem, 1, 0)) << strerror(errno); in fork() 606 if (sem_wait(sem)) { in fork() 625 sem_destroy(sem); in fork() 636 ASSERT_EQ(0, sem_post(sem)) << strerror(errno); in fork() [all …]
|
H A D | unlink.cc | 198 sem_t sem; in TEST_F() 200 ASSERT_EQ(0, sem_init(&sem, 0, 0)) << strerror(errno); in TEST_F() 204 expect_forget(ino, 1, &sem); in TEST_F() 207 sem_wait(&sem); in TEST_F() 208 sem_destroy(&sem); in TEST_F() 199 sem_t sem; TEST_F() local
|
/freebsd/sys/compat/linuxkpi/common/include/linux/ |
H A D | semaphore.h | 51 linux_sema_init(struct semaphore *sem, int val) in linux_sema_init() argument 54 memset(&sem->sema, 0, sizeof(sem->sema)); in linux_sema_init() 55 sema_init(&sem->sema, val, "lnxsema"); in linux_sema_init() 59 init_MUTEX(struct semaphore *sem) in init_MUTEX() argument 62 memset(&sem->sema, 0, sizeof(sem->sema)); in init_MUTEX() 63 sema_init(&sem->sema, 1, "lnxsema"); in init_MUTEX()
|
/freebsd/sys/contrib/openzfs/contrib/coverity/ |
H A D | model.c | 597 down_read(struct rw_semaphore *sem) in down_read() argument 602 __coverity_recursive_lock_acquire__(sem); in down_read() 606 down_write(struct rw_semaphore *sem) in down_write() argument 611 __coverity_recursive_lock_acquire__(sem); in down_write() 615 down_read_trylock(struct rw_semaphore *sem) in down_read_trylock() argument 618 __coverity_recursive_lock_acquire__(sem); in down_read_trylock() 626 down_write_trylock(struct rw_semaphore *sem) in down_write_trylock() argument 629 __coverity_recursive_lock_acquire__(sem); in down_write_trylock() 637 up_read(struct rw_semaphore *sem) in up_read() argument 639 __coverity_recursive_lock_release__(sem); in up_read() [all …]
|
/freebsd/contrib/ofed/librdmacm/ |
H A D | cma.h | 54 sem_t sem; member 59 sem_init(&lock->sem, 0, 0); in fastlock_init() 64 sem_destroy(&lock->sem); in fastlock_destroy() 69 sem_wait(&lock->sem); in fastlock_acquire() 74 sem_post(&lock->sem); in fastlock_release()
|
/freebsd/contrib/ofed/librdmacm/examples/ |
H A D | rping.c | 142 sem_t sem; member 177 sem_post(&cb->sem); in rping_cma_event_handler() 183 sem_post(&cb->sem); in rping_cma_event_handler() 190 sem_post(&cb->sem); in rping_cma_event_handler() 202 sem_post(&cb->sem); in rping_cma_event_handler() 212 sem_post(&cb->sem); in rping_cma_event_handler() 220 sem_post(&cb->sem); in rping_cma_event_handler() 226 sem_post(&cb->sem); in rping_cma_event_handler() 306 sem_post(&cb->sem); in rping_cq_event_handler() 312 sem_post(&cb->sem); in rping_cq_event_handler() [all …]
|
/freebsd/tools/regression/pthread/unwind/ |
H A D | sem_wait_cancel.cpp | 10 static sem_t sem; variable 17 sem_wait(&sem); in thr() 27 sem_init(&sem, 0, 0); in main()
|
/freebsd/contrib/netbsd-tests/lib/libpthread/ |
H A D | t_sem.c | 113 static sem_t sem; variable 216 SEM_REQUIRE(sem_post(&sem)); in sighandler() 239 ret = sem_wait(&sem); in threadfunc() 243 ret = sem_trywait(&sem); in threadfunc() 262 SEM_REQUIRE(sem_init(&sem, 0, 0)); in before_start_test()
|
/freebsd/sys/dev/ocs_fc/ |
H A D | ocs_os.h | 696 struct sema sem; /**< OS counting semaphore structure */ member 714 extern int ocs_sem_init(ocs_sem_t *sem, int val, const char *name, ...) __attribute__((format(print… 733 ocs_sem_p(ocs_sem_t *sem, int timeout_usec) in ocs_sem_p() argument 738 rc = sema_trywait(&sem->sem); in ocs_sem_p() 752 rc = sema_timedwait(&sem->sem, ticks); in ocs_sem_p() 757 sema_wait(&sem->sem); in ocs_sem_p() 777 ocs_sem_v(ocs_sem_t *sem) in ocs_sem_v() argument 779 sema_post(&sem->sem); in ocs_sem_v()
|
/freebsd/sys/dev/mlx4/mlx4_core/ |
H A D | mlx4_reset.c | 51 u32 sem; in mlx4_reset() local 104 sem = readl(reset + MLX4_SEM_OFFSET); in mlx4_reset() 105 if (!sem) in mlx4_reset() 111 if (sem) { in mlx4_reset()
|