diff options
Diffstat (limited to 'lib/libpthread/thread/thr_fork.c')
-rw-r--r-- | lib/libpthread/thread/thr_fork.c | 133 |
1 files changed, 6 insertions, 127 deletions
diff --git a/lib/libpthread/thread/thr_fork.c b/lib/libpthread/thread/thr_fork.c index 5bb64f7..a279621 100644 --- a/lib/libpthread/thread/thr_fork.c +++ b/lib/libpthread/thread/thr_fork.c @@ -31,7 +31,6 @@ * * $FreeBSD$ */ -#include <sys/param.h> #include <errno.h> #include <string.h> #include <stdlib.h> @@ -40,141 +39,21 @@ #include <pthread.h> #include "thr_private.h" -static void free_thread_resources(struct pthread *thread); - __weak_reference(_fork, fork); pid_t _fork(void) { - struct pthread *curthread = _get_curthread(); - int i, flags, use_deadlist = 0; - pid_t ret; - pthread_t pthread; - pthread_t pthread_save; + struct pthread *curthread; + pid_t ret; - /* - * Defer signals to protect the scheduling queues from access - * by the signal handler: - */ - _thread_kern_sig_defer(); + curthread = _get_curthread(); /* Fork a new process: */ - if ((ret = __sys_fork()) != 0) { - /* Parent process or error. Nothing to do here. */ - } else { - /* Reinitialize the GC mutex: */ - if (_mutex_reinit(&_gc_mutex) != 0) { - /* Abort this application: */ - PANIC("Cannot initialize GC mutex for forked process"); - } - /* Reinitialize the GC condition variable: */ - else if (_cond_reinit(&_gc_cond) != 0) { - /* Abort this application: */ - PANIC("Cannot initialize GC condvar for forked process"); - } - /* Initialize the ready queue: */ - else if (_pq_init(&_readyq) != 0) { - /* Abort this application: */ - PANIC("Cannot initialize priority ready queue."); - } else { - /* - * Enter a loop to remove all threads other than - * the running thread from the thread list: - */ - if ((pthread = TAILQ_FIRST(&_thread_list)) == NULL) { - pthread = TAILQ_FIRST(&_dead_list); - use_deadlist = 1; - } - while (pthread != NULL) { - /* Save the thread to be freed: */ - pthread_save = pthread; - - /* - * Advance to the next thread before - * destroying the current thread: - */ - if (use_deadlist != 0) - pthread = TAILQ_NEXT(pthread, dle); - else - pthread = TAILQ_NEXT(pthread, tle); - - /* Make sure this isn't the running thread: */ - if (pthread_save != curthread) { - /* - * Remove this thread from the - * appropriate list: - */ - if (use_deadlist != 0) - TAILQ_REMOVE(&_thread_list, - pthread_save, dle); - else - TAILQ_REMOVE(&_thread_list, - pthread_save, tle); - - free_thread_resources(pthread_save); - } - - /* - * Switch to the deadlist when the active - * thread list has been consumed. This can't - * be at the top of the loop because it is - * used to determine to which list the thread - * belongs (when it is removed from the list). - */ - if (pthread == NULL) { - pthread = TAILQ_FIRST(&_dead_list); - use_deadlist = 1; - } - } - - /* Treat the current thread as the initial thread: */ - _thread_initial = curthread; - - /* Re-init the dead thread list: */ - TAILQ_INIT(&_dead_list); - - /* Re-init the waiting and work queues. */ - TAILQ_INIT(&_waitingq); - TAILQ_INIT(&_workq); - - /* Re-init the threads mutex queue: */ - TAILQ_INIT(&curthread->mutexq); - - /* No spinlocks yet: */ - _spinblock_count = 0; - - /* Initialize the scheduling switch hook routine: */ - _sched_switch_hook = NULL; - } - } - - /* - * Undefer and handle pending signals, yielding if necessary: - */ - _thread_kern_sig_undefer(); + if ((ret = __sys_fork()) == 0) + /* Child process */ + _kse_single_thread(curthread); /* Return the process ID: */ return (ret); } - -static void -free_thread_resources(struct pthread *thread) -{ - - /* Check to see if the threads library allocated the stack. */ - if ((thread->attr.stackaddr_attr == NULL) && (thread->stack != NULL)) { - /* - * Since this is being called from fork, we are currently single - * threaded so there is no need to protect the call to - * _thread_stack_free() with _gc_mutex. - */ - _thread_stack_free(thread->stack, thread->attr.stacksize_attr, - thread->attr.guardsize_attr); - } - - if (thread->specific != NULL) - free(thread->specific); - - free(thread); -} |