|  | // Copyright 2015 The Go Authors. All rights reserved. | 
|  | // Use of this source code is governed by a BSD-style | 
|  | // license that can be found in the LICENSE file. | 
|  |  | 
|  | // Test that a signal handler that uses up stack space does not crash | 
|  | // if the signal is delivered to a thread running a goroutine. | 
|  | // This is a lot like misc/cgo/testcarchive/main2.c. | 
|  |  | 
|  | #include <setjmp.h> | 
|  | #include <signal.h> | 
|  | #include <stddef.h> | 
|  | #include <stdio.h> | 
|  | #include <stdlib.h> | 
|  | #include <string.h> | 
|  | #include <sys/types.h> | 
|  | #include <unistd.h> | 
|  | #include <sched.h> | 
|  | #include <time.h> | 
|  | #include <dlfcn.h> | 
|  |  | 
|  | static void die(const char* msg) { | 
|  | perror(msg); | 
|  | exit(EXIT_FAILURE); | 
|  | } | 
|  |  | 
|  | static volatile sig_atomic_t sigioSeen; | 
|  |  | 
|  | // Use up some stack space. | 
|  | static void recur(int i, char *p) { | 
|  | char a[1024]; | 
|  |  | 
|  | *p = '\0'; | 
|  | if (i > 0) { | 
|  | recur(i - 1, a); | 
|  | } | 
|  | } | 
|  |  | 
|  | // Signal handler that uses up more stack space than a goroutine will have. | 
|  | static void ioHandler(int signo, siginfo_t* info, void* ctxt) { | 
|  | char a[1024]; | 
|  |  | 
|  | recur(4, a); | 
|  | sigioSeen = 1; | 
|  | } | 
|  |  | 
|  | static jmp_buf jmp; | 
|  | static char* nullPointer; | 
|  |  | 
|  | // Signal handler for SIGSEGV on a C thread. | 
|  | static void segvHandler(int signo, siginfo_t* info, void* ctxt) { | 
|  | sigset_t mask; | 
|  | int i; | 
|  |  | 
|  | if (sigemptyset(&mask) < 0) { | 
|  | die("sigemptyset"); | 
|  | } | 
|  | if (sigaddset(&mask, SIGSEGV) < 0) { | 
|  | die("sigaddset"); | 
|  | } | 
|  | i = sigprocmask(SIG_UNBLOCK, &mask, NULL); | 
|  | if (i != 0) { | 
|  | fprintf(stderr, "sigprocmask: %s\n", strerror(i)); | 
|  | exit(EXIT_FAILURE); | 
|  | } | 
|  |  | 
|  | // Don't try this at home. | 
|  | longjmp(jmp, signo); | 
|  |  | 
|  | // We should never get here. | 
|  | abort(); | 
|  | } | 
|  |  | 
|  | int main(int argc, char** argv) { | 
|  | int verbose; | 
|  | struct sigaction sa; | 
|  | void* handle; | 
|  | void (*fn)(void); | 
|  | sigset_t mask; | 
|  | int i; | 
|  | struct timespec ts; | 
|  |  | 
|  | verbose = argc > 2; | 
|  | setvbuf(stdout, NULL, _IONBF, 0); | 
|  |  | 
|  | // Call setsid so that we can use kill(0, SIGIO) below. | 
|  | // Don't check the return value so that this works both from | 
|  | // a job control shell and from a shell script. | 
|  | setsid(); | 
|  |  | 
|  | if (verbose) { | 
|  | printf("calling sigaction\n"); | 
|  | } | 
|  |  | 
|  | memset(&sa, 0, sizeof sa); | 
|  | sa.sa_sigaction = ioHandler; | 
|  | if (sigemptyset(&sa.sa_mask) < 0) { | 
|  | die("sigemptyset"); | 
|  | } | 
|  | sa.sa_flags = SA_SIGINFO; | 
|  | if (sigaction(SIGIO, &sa, NULL) < 0) { | 
|  | die("sigaction"); | 
|  | } | 
|  |  | 
|  | sa.sa_sigaction = segvHandler; | 
|  | if (sigaction(SIGSEGV, &sa, NULL) < 0 || sigaction(SIGBUS, &sa, NULL) < 0) { | 
|  | die("sigaction"); | 
|  | } | 
|  |  | 
|  | if (verbose) { | 
|  | printf("calling dlopen\n"); | 
|  | } | 
|  |  | 
|  | handle = dlopen(argv[1], RTLD_NOW | RTLD_GLOBAL); | 
|  | if (handle == NULL) { | 
|  | fprintf(stderr, "%s\n", dlerror()); | 
|  | exit(EXIT_FAILURE); | 
|  | } | 
|  |  | 
|  | if (verbose) { | 
|  | printf("calling dlsym\n"); | 
|  | } | 
|  |  | 
|  | // Start some goroutines. | 
|  | fn = (void(*)(void))dlsym(handle, "RunGoroutines"); | 
|  | if (fn == NULL) { | 
|  | fprintf(stderr, "%s\n", dlerror()); | 
|  | exit(EXIT_FAILURE); | 
|  | } | 
|  |  | 
|  | if (verbose) { | 
|  | printf("calling RunGoroutines\n"); | 
|  | } | 
|  |  | 
|  | fn(); | 
|  |  | 
|  | // Block SIGIO in this thread to make it more likely that it | 
|  | // will be delivered to a goroutine. | 
|  |  | 
|  | if (verbose) { | 
|  | printf("calling pthread_sigmask\n"); | 
|  | } | 
|  |  | 
|  | if (sigemptyset(&mask) < 0) { | 
|  | die("sigemptyset"); | 
|  | } | 
|  | if (sigaddset(&mask, SIGIO) < 0) { | 
|  | die("sigaddset"); | 
|  | } | 
|  | i = pthread_sigmask(SIG_BLOCK, &mask, NULL); | 
|  | if (i != 0) { | 
|  | fprintf(stderr, "pthread_sigmask: %s\n", strerror(i)); | 
|  | exit(EXIT_FAILURE); | 
|  | } | 
|  |  | 
|  | if (verbose) { | 
|  | printf("calling kill\n"); | 
|  | } | 
|  |  | 
|  | if (kill(0, SIGIO) < 0) { | 
|  | die("kill"); | 
|  | } | 
|  |  | 
|  | if (verbose) { | 
|  | printf("waiting for sigioSeen\n"); | 
|  | } | 
|  |  | 
|  | // Wait until the signal has been delivered. | 
|  | i = 0; | 
|  | while (!sigioSeen) { | 
|  | ts.tv_sec = 0; | 
|  | ts.tv_nsec = 1000000; | 
|  | nanosleep(&ts, NULL); | 
|  | i++; | 
|  | if (i > 5000) { | 
|  | fprintf(stderr, "looping too long waiting for signal\n"); | 
|  | exit(EXIT_FAILURE); | 
|  | } | 
|  | } | 
|  |  | 
|  | if (verbose) { | 
|  | printf("calling setjmp\n"); | 
|  | } | 
|  |  | 
|  | // Test that a SIGSEGV on this thread is delivered to us. | 
|  | if (setjmp(jmp) == 0) { | 
|  | if (verbose) { | 
|  | printf("triggering SIGSEGV\n"); | 
|  | } | 
|  |  | 
|  | *nullPointer = '\0'; | 
|  |  | 
|  | fprintf(stderr, "continued after address error\n"); | 
|  | exit(EXIT_FAILURE); | 
|  | } | 
|  |  | 
|  | if (verbose) { | 
|  | printf("calling dlsym\n"); | 
|  | } | 
|  |  | 
|  | // Make sure that a SIGSEGV in Go causes a run-time panic. | 
|  | fn = (void (*)(void))dlsym(handle, "TestSEGV"); | 
|  | if (fn == NULL) { | 
|  | fprintf(stderr, "%s\n", dlerror()); | 
|  | exit(EXIT_FAILURE); | 
|  | } | 
|  |  | 
|  | if (verbose) { | 
|  | printf("calling TestSEGV\n"); | 
|  | } | 
|  |  | 
|  | fn(); | 
|  |  | 
|  | printf("PASS\n"); | 
|  | return 0; | 
|  | } |