1 #include "pthread_impl.h"
9 static void (*callback)(void *), *context;
11 static sem_t chainlock, chaindone;
12 static pthread_rwlock_t lock = PTHREAD_RWLOCK_INITIALIZER;
14 static void handler(int sig, siginfo_t *si, void *ctx)
17 pthread_t self = __pthread_self();
18 int old_errno = errno;
20 if (chainlen == libc.threads_minus_1) return;
22 sigqueue(self->pid, SIGSYNCCALL, (union sigval){0});
24 /* Threads which have already decremented themselves from the
25 * thread count must not act. Block further receipt of signals
28 memset(&((ucontext_t *)ctx)->uc_sigmask, -1, 8);
33 sem_init(&ch.sem, 0, 0);
34 sem_init(&ch.sem2, 0, 0);
36 while (sem_wait(&chainlock));
39 if (++chainlen == libc.threads_minus_1) sem_post(&chaindone);
42 while (sem_wait(&ch.sem));
45 while (sem_wait(&ch.sem));
50 void __synccall_wait()
52 struct chain *ch = cur;
54 while (sem_wait(&ch->sem));
58 void __synccall(void (*func)(void *), void *ctx)
65 if (!libc.threads_minus_1) {
70 pthread_rwlock_wrlock(&lock);
72 __syscall(SYS_rt_sigprocmask, SIG_BLOCK, (uint64_t[]){-1}, &oldmask, 8);
74 sem_init(&chaindone, 0, 0);
75 sem_init(&chainlock, 0, 1);
80 sa.sa_flags = SA_SIGINFO | SA_RESTART;
81 sa.sa_sigaction = handler;
82 sigfillset(&sa.sa_mask);
83 __libc_sigaction(SIGSYNCCALL, &sa, 0);
85 self = __pthread_self();
86 sigqueue(self->pid, SIGSYNCCALL, (union sigval){0});
87 while (sem_wait(&chaindone));
89 for (cur=head; cur; cur=cur->next) {
91 while (sem_wait(&cur->sem2));
95 for (cur=head; cur; cur=next) {
101 sa.sa_handler = SIG_IGN;
102 __libc_sigaction(SIGSYNCCALL, &sa, 0);
104 __syscall(SYS_rt_sigprocmask, SIG_SETMASK, &oldmask, 0, 8);
106 pthread_rwlock_unlock(&lock);
109 void __synccall_lock()
111 pthread_rwlock_rdlock(&lock);
114 void __synccall_unlock()
116 pthread_rwlock_unlock(&lock);