1 // Copyright 2013 The Go Authors. All rights reserved. 2 // Use of this source code is governed by a BSD-style 3 // license that can be found in the LICENSE file. 4 5 // +build !windows 6 7 package cgotest 8 9 /* 10 #include <signal.h> 11 #include <pthread.h> 12 #include <unistd.h> 13 #include <stdlib.h> 14 15 static void *thread(void *p) { 16 const int M = 100; 17 int i; 18 (void)p; 19 for (i = 0; i < M; i++) { 20 pthread_kill(pthread_self(), SIGCHLD); 21 usleep(rand() % 20 + 5); 22 } 23 return NULL; 24 } 25 void testSendSIG() { 26 const int N = 20; 27 int i; 28 pthread_t tid[N]; 29 for (i = 0; i < N; i++) { 30 usleep(rand() % 200 + 100); 31 pthread_create(&tid[i], 0, thread, NULL); 32 } 33 for (i = 0; i < N; i++) 34 pthread_join(tid[i], 0); 35 } 36 */ 37 import "C" 38 39 import ( 40 "os" 41 "os/signal" 42 "syscall" 43 "testing" 44 "time" 45 ) 46 47 func test3250(t *testing.T) { 48 t.Skip("skipped, see golang.org/issue/5885") 49 const ( 50 thres = 1 51 sig = syscall.SIGCHLD 52 ) 53 type result struct { 54 n int 55 sig os.Signal 56 } 57 var ( 58 sigCh = make(chan os.Signal, 10) 59 waitStart = make(chan struct{}) 60 waitDone = make(chan result) 61 ) 62 63 signal.Notify(sigCh, sig) 64 65 go func() { 66 n := 0 67 alarm := time.After(time.Second * 3) 68 for { 69 select { 70 case <-waitStart: 71 waitStart = nil 72 case v := <-sigCh: 73 n++ 74 if v != sig || n > thres { 75 waitDone <- result{n, v} 76 return 77 } 78 case <-alarm: 79 waitDone <- result{n, sig} 80 return 81 } 82 } 83 }() 84 85 waitStart <- struct{}{} 86 C.testSendSIG() 87 r := <-waitDone 88 if r.sig != sig { 89 t.Fatalf("received signal %v, but want %v", r.sig, sig) 90 } 91 t.Logf("got %d signals\n", r.n) 92 if r.n <= thres { 93 t.Fatalf("expected more than %d", thres) 94 } 95 } 96
