Function lwp_thread_signal_catch

components/lwp/lwp_signal.c:736–802

}

void lwp_thread_signal_catch(void *exp_frame)
{
    struct rt_thread *thread;
    struct rt_lwp *lwp;
    lwp_sigqueue_t pending;
    lwp_sigset_t *sig_mask;
    int retry_signal_catch;
    int signo;

    thread = rt_thread_self();
    lwp = (struct rt_lwp *)thread->lwp;

    RT_ASSERT(!!lwp);
    LWP_LOCK(lwp);

    do {
        /* if stopped process resume, we will retry to catch the signal */
        retry_signal_catch = 0;
        signo = 0;

        /* try to peek a signal which is pending and not blocked by this thread */
        if (!sigqueue_isempty(_SIGQ(thread)))
        {
            pending = _SIGQ(thread);
            sig_mask = &thread->signal.sigset_mask;
            signo = sigqueue_peek(pending, sig_mask);
        }
        if (!signo && !sigqueue_isempty(_SIGQ(lwp)))
        {
            pending = _SIGQ(lwp);
            sig_mask = &thread->signal.sigset_mask;
            signo = sigqueue_peek(pending, sig_mask);
        }

        if (signo)
        {
            lwp_siginfo_t siginfo;
            lwp_sighandler_t handler;

            LOG_D("%s(signo=%d)", __func__, signo);

            siginfo = sigqueue_dequeue(pending, signo);
            RT_ASSERT(siginfo != RT_NULL);
            handler = _get_sighandler_locked(lwp, signo);

            if (_is_stop_signal(lwp, signo) && handler == LWP_SIG_ACT_DFL)
            {
                /* notify the status update for parent process */
                _notify_parent_and_leader(lwp, thread, signo, RT_TRUE);

                LOG_D("%s: pid=%d stopped", __func__, lwp->pid);
                _stop_thread_locked(lwp, thread, signo, siginfo, pending);
                LOG_D("%s: pid=%d continued", __func__, lwp->pid);

                /* wakeup and retry to catch signals send to us */
                retry_signal_catch = 1;
            }
            else