refactor: break sigalrm propagate into util func

main
Sean McBride 4 years ago
parent 3cec497a9b
commit 564765c226

@ -44,21 +44,16 @@ extern pthread_t runtime_worker_threads[];
static inline void software_interrupt_handle_signals(int signal_type, siginfo_t *signal_info, void *user_context_raw); static inline void software_interrupt_handle_signals(int signal_type, siginfo_t *signal_info, void *user_context_raw);
/** /**
* SIGALRM is the preemption signal that occurs every quantum of execution * A POSIX signal is delivered to only one thread.
* @param signal_info data structure containing signal info * This function broadcasts the sigalarm signal to all other worker threads
* @param user_context userland context
* @param current_sandbox the sanbox active on the worker thread
*/ */
static inline void static inline void
sigalrm_handler(siginfo_t *signal_info, ucontext_t *user_context, struct sandbox *current_sandbox) sigalrm_propagate_workers(siginfo_t *signal_info)
{ {
/*
* A POSIX signal is delivered to only one thread.
* We need to ensure this thread broadcasts to all other threads
*/
if (signal_info->si_code == SI_KERNEL) {
/* Signal was sent directly by the kernel, so forward to other threads */ /* Signal was sent directly by the kernel, so forward to other threads */
if (signal_info->si_code == SI_KERNEL) {
for (int i = 0; i < runtime_total_worker_processors; i++) { for (int i = 0; i < runtime_total_worker_processors; i++) {
if (pthread_self() == runtime_worker_threads[i]) continue; if (pthread_self() == runtime_worker_threads[i]) continue;
@ -68,6 +63,18 @@ sigalrm_handler(siginfo_t *signal_info, ucontext_t *user_context, struct sandbox
/* Signal forwarded from another thread. Just confirm it resulted from pthread_kill */ /* Signal forwarded from another thread. Just confirm it resulted from pthread_kill */
assert(signal_info->si_code == SI_TKILL); assert(signal_info->si_code == SI_TKILL);
} }
}
/**
* SIGALRM is the preemption signal that occurs every quantum of execution
* @param signal_info data structure containing signal info
* @param user_context userland context
* @param current_sandbox the sanbox active on the worker thread
*/
static inline void
sigalrm_handler(siginfo_t *signal_info, ucontext_t *user_context, struct sandbox *current_sandbox)
{
sigalrm_propagate_workers(signal_info);
software_interrupt_SIGALRM_count++; software_interrupt_SIGALRM_count++;

Loading…
Cancel
Save