diff options
Diffstat (limited to 'regress/lib/libpthread/restart/connect')
-rw-r--r-- | regress/lib/libpthread/restart/connect/Makefile | 6 | ||||
-rw-r--r-- | regress/lib/libpthread/restart/connect/connect.c | 59 |
2 files changed, 65 insertions, 0 deletions
diff --git a/regress/lib/libpthread/restart/connect/Makefile b/regress/lib/libpthread/restart/connect/Makefile new file mode 100644 index 00000000000..4ce856466fc --- /dev/null +++ b/regress/lib/libpthread/restart/connect/Makefile @@ -0,0 +1,6 @@ +# $OpenBSD: Makefile,v 1.1 2011/09/18 16:36:58 fgsch Exp $ + +PROG = connect +CFLAGS += -I${.CURDIR}/../../include + +.include <bsd.regress.mk> diff --git a/regress/lib/libpthread/restart/connect/connect.c b/regress/lib/libpthread/restart/connect/connect.c new file mode 100644 index 00000000000..dfa62040a47 --- /dev/null +++ b/regress/lib/libpthread/restart/connect/connect.c @@ -0,0 +1,59 @@ +/* $OpenBSD: connect.c,v 1.1 2011/09/18 16:36:58 fgsch Exp $ */ +/* + * Federico G. Schwindt <fgsch@openbsd.org>, 2011. Public Domain. + */ +#include <sys/types.h> +#include <sys/socket.h> +#include <netinet/in.h> +#include <pthread.h> +#include <signal.h> +#include <unistd.h> +#include "test.h" + +volatile sig_atomic_t hits = 0; + +void +handler(int sig) +{ + hits++; +} + +void * +thr_connect(void *arg) +{ + struct sockaddr_in sa; + int s; + + CHECKe(s = socket(AF_INET, SOCK_STREAM, 0)); + bzero(&sa, sizeof(sa)); + sa.sin_family = AF_INET; + sa.sin_port = htons(23); + sa.sin_addr.s_addr = htonl(0xc7b98903); /* cvs.openbsd.org */ + ASSERT(connect(s, (struct sockaddr *)&sa, sizeof(sa)) == -1); + return ((caddr_t)NULL + errno); +} + +int +main(int argc, char **argv) +{ + struct sigaction sa; + pthread_t tid; + void *retval; + + bzero(&sa, sizeof(sa)); + sa.sa_handler = handler; + sa.sa_flags = SA_RESTART; + CHECKe(sigaction(SIGUSR1, &sa, NULL)); + + CHECKr(pthread_create(&tid, NULL, thr_connect, NULL)); + sleep(2); + + /* Should interrupt it. */ + CHECKr(pthread_kill(tid, SIGUSR1)); + sleep(1); + + CHECKr(pthread_join(tid, &retval)); + ASSERT(retval == (void *)EINTR); + ASSERT(hits == 1); + SUCCEED; +} |