Function _stop_thread_locked

components/lwp/lwp_signal.c:593–647

static int _do_signal_wakeup(rt_thread_t thread, int sig);
static rt_err_t _stop_thread_locked(rt_lwp_t self_lwp, rt_thread_t cur_thr, int signo,
                                    lwp_siginfo_t si, lwp_sigqueue_t sq)
{
    rt_err_t error;
    int jobctl_stopped = self_lwp->jobctl_stopped;
    rt_thread_t iter;

    /* race to setup jobctl stopped flags */
    if (!jobctl_stopped)
    {
        self_lwp->jobctl_stopped = RT_TRUE;
        self_lwp->wait_reap_stp = RT_FALSE;
        rt_list_for_each_entry(iter, &self_lwp->t_grp, sibling)
        {
            if (iter != cur_thr)
                _do_signal_wakeup(iter, signo);
        }
    }

    /**
     * raise the event again so siblings is able to catch it again.
     * `si` will be discarded while SIGCONT is generatd
     */
    sigqueue_enqueue(sq, si);

    /* release the lwp lock so we can happily suspend */
    LWP_UNLOCK(self_lwp);

    rt_set_errno(RT_EOK);

    /* After suspension, only the SIGKILL and SIGCONT will wake this thread up */
    error = rt_thread_suspend_with_flag(cur_thr, RT_KILLABLE);
    if (error == RT_EOK)
    {
        rt_schedule();
        error = rt_get_errno();
        error = error > 0 ? -error : error;
    }

    if (!jobctl_stopped &&
        (sigqueue_ismember(_SIGQ(self_lwp), SIGCONT) ||
        sigqueue_ismember(_SIGQ(cur_thr), SIGCONT)))
    {
        /**
         * if we are resumed by a SIGCONT and we are the winner of racing
         * notify parent of the incoming event
         */
        _notify_parent_and_leader(self_lwp, cur_thr, SIGCONT, RT_FALSE);
    }

    /* reacquire the lock since we release it before */
    LWP_LOCK(self_lwp);

    return error;
}

static void _catch_signal_locked(rt_lwp_t lwp, rt_thread_t thread, int signo,
                                 lwp_siginfo_t siginfo, lwp_sighandler_t handler,