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(void (*func)(void *), void *ctx)
54 struct chain *cur, *next;
57 if (!libc.threads_minus_1) {
62 pthread_rwlock_wrlock(&lock);
64 __syscall(SYS_rt_sigprocmask, SIG_BLOCK, (uint64_t[]){-1}, &oldmask, 8);
66 sem_init(&chaindone, 0, 0);
67 sem_init(&chainlock, 0, 1);
72 sa.sa_flags = SA_SIGINFO | SA_RESTART;
73 sa.sa_sigaction = handler;
74 sigfillset(&sa.sa_mask);
75 __libc_sigaction(SIGSYNCCALL, &sa, 0);
77 self = __pthread_self();
78 sigqueue(self->pid, SIGSYNCCALL, (union sigval){0});
79 while (sem_wait(&chaindone));
81 for (cur=head; cur; cur=cur->next) {
83 while (sem_wait(&cur->sem2));
87 for (cur=head; cur; cur=next) {
93 sa.sa_handler = SIG_IGN;
94 __libc_sigaction(SIGSYNCCALL, &sa, 0);
96 __syscall(SYS_rt_sigprocmask, SIG_SETMASK, &oldmask, 0, 8);
98 pthread_rwlock_unlock(&lock);
101 void __synccall_lock()
103 pthread_rwlock_rdlock(&lock);
106 void __synccall_unlock()
108 pthread_rwlock_unlock(&lock);