1 /* $OpenBSD: connect.c,v 1.1 2011/09/18 16:36:58 fgsch Exp $ */ 2 /* 3 * Federico G. Schwindt <fgsch@openbsd.org>, 2011. Public Domain. 4 */ 5 #include <sys/types.h> 6 #include <sys/socket.h> 7 #include <netinet/in.h> 8 #include <pthread.h> 9 #include <signal.h> 10 #include <unistd.h> 11 #include "test.h" 12 13 volatile sig_atomic_t hits = 0; 14 15 void 16 handler(int sig) 17 { 18 hits++; 19 } 20 21 void * 22 thr_connect(void *arg) 23 { 24 struct sockaddr_in sa; 25 int s; 26 27 CHECKe(s = socket(AF_INET, SOCK_STREAM, 0)); 28 bzero(&sa, sizeof(sa)); 29 sa.sin_family = AF_INET; 30 sa.sin_port = htons(23); 31 sa.sin_addr.s_addr = htonl(0xc7b98903); /* cvs.openbsd.org */ 32 ASSERT(connect(s, (struct sockaddr *)&sa, sizeof(sa)) == -1); 33 return ((caddr_t)NULL + errno); 34 } 35 36 int 37 main(int argc, char **argv) 38 { 39 struct sigaction sa; 40 pthread_t tid; 41 void *retval; 42 43 bzero(&sa, sizeof(sa)); 44 sa.sa_handler = handler; 45 sa.sa_flags = SA_RESTART; 46 CHECKe(sigaction(SIGUSR1, &sa, NULL)); 47 48 CHECKr(pthread_create(&tid, NULL, thr_connect, NULL)); 49 sleep(2); 50 51 /* Should interrupt it. */ 52 CHECKr(pthread_kill(tid, SIGUSR1)); 53 sleep(1); 54 55 CHECKr(pthread_join(tid, &retval)); 56 ASSERT(retval == (void *)EINTR); 57 ASSERT(hits == 1); 58 SUCCEED; 59 } 60