diff options
author | Kurt Miller <kurt@cvs.openbsd.org> | 2006-10-13 18:02:53 +0000 |
---|---|---|
committer | Kurt Miller <kurt@cvs.openbsd.org> | 2006-10-13 18:02:53 +0000 |
commit | a0a0d520ff08727c9758c3bce0f527842b25c5d2 (patch) | |
tree | 9e06461eed61fb595bbdab15520d589d8b5cd4c3 | |
parent | 1a1944dfc1e22578a03cc8e61bd653b5bfb2b83c (diff) |
Test shutdown() racing with other threads using the same file
descriptor, with some of them blocking on data that will never
arrive.
-rw-r--r-- | regress/lib/libpthread/blocked_shutdown/Makefile | 5 | ||||
-rw-r--r-- | regress/lib/libpthread/blocked_shutdown/blocked_shutdown.c | 115 |
2 files changed, 120 insertions, 0 deletions
diff --git a/regress/lib/libpthread/blocked_shutdown/Makefile b/regress/lib/libpthread/blocked_shutdown/Makefile new file mode 100644 index 00000000000..f0d5cbc9570 --- /dev/null +++ b/regress/lib/libpthread/blocked_shutdown/Makefile @@ -0,0 +1,5 @@ +# $OpenBSD: Makefile,v 1.1 2006/10/13 18:02:52 kurt Exp $ + +PROG= blocked_shutdown + +.include <bsd.regress.mk> diff --git a/regress/lib/libpthread/blocked_shutdown/blocked_shutdown.c b/regress/lib/libpthread/blocked_shutdown/blocked_shutdown.c new file mode 100644 index 00000000000..1d95d398e8b --- /dev/null +++ b/regress/lib/libpthread/blocked_shutdown/blocked_shutdown.c @@ -0,0 +1,115 @@ +/* $OpenBSD: blocked_shutdown.c,v 1.1 2006/10/13 18:02:52 kurt Exp $ */ +/* + * Copyright (c) 2006 Kurt Miller <kurt@intricatesoftware.com> + * + * Permission to use, copy, modify, and distribute this software for any + * purpose with or without fee is hereby granted, provided that the above + * copyright notice and this permission notice appear in all copies. + * + * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES + * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF + * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR + * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES + * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN + * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF + * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. + */ + +/* + * Test shutdown() racing with other threads using the same file + * descriptor, with some of them blocking on data that will never + * arrive. + */ + +#include <pthread.h> +#include <unistd.h> +#include <fcntl.h> +#include <time.h> +#include <sys/types.h> +#include <sys/socket.h> +#include <netinet/in.h> +#include "test.h" + +#define ITERATIONS 100 +#define BUSY_THREADS 5 +#define WAITING_THREADS 5 + +static void * +deadlock_detector(void *arg) +{ + sleep(60); + PANIC("deadlock detected"); +} + +static void * +waiting_read(void *arg) +{ + int fd = *(int *)arg; + struct sockaddr remote_addr; + char readBuf; + int n, remote_addr_len = sizeof(struct sockaddr); + + n = recvfrom(fd, &readBuf, 1, 0, &remote_addr, &remote_addr_len); + + if (n == -1) + return ((caddr_t)NULL + errno); + else + return (NULL); +} + +static void * +busy_thread(void *arg) +{ + int fd = *(int *)arg; + + /* loop until error */ + while(fcntl(fd, F_GETFD, NULL) != -1); + + return ((caddr_t)NULL + errno); +} + +int +main(int argc, char *argv[]) +{ + pthread_t busy_threads[BUSY_THREADS]; + pthread_t waiting_threads[WAITING_THREADS]; + pthread_t deadlock_thread; + struct sockaddr_in addr; + int fd, i, j; + void *value_ptr; + struct timespec rqtp; + + rqtp.tv_sec = 0; + rqtp.tv_nsec = 1000000; + + bzero((char *) &addr, sizeof addr); + addr.sin_family = AF_INET; + addr.sin_addr.s_addr = htonl(INADDR_LOOPBACK); + + CHECKr(pthread_create(&deadlock_thread, NULL, + deadlock_detector, NULL)); + + for (i = 0; i < ITERATIONS; i++) { + CHECKe(fd = socket(AF_INET, SOCK_DGRAM, 0)); + addr.sin_port = htons(0); + CHECKr(bind(fd, (struct sockaddr *)&addr, sizeof(addr))); + for (j = 0; j < BUSY_THREADS; j++) + CHECKr(pthread_create(&busy_threads[j], NULL, + busy_thread, (void *)&fd)); + for (j = 0; j < WAITING_THREADS; j++) + CHECKr(pthread_create(&waiting_threads[j], NULL, + waiting_read, (void *)&fd)); + nanosleep(&rqtp, NULL); + CHECKr(shutdown(fd, SHUT_RDWR)); + for (j = 0; j < WAITING_THREADS; j++) { + CHECKr(pthread_join(waiting_threads[j], &value_ptr)); + ASSERT(value_ptr == NULL); + } + CHECKr(close(fd)); + for (j = 0; j < BUSY_THREADS; j++) { + CHECKr(pthread_join(busy_threads[j], &value_ptr)); + ASSERT(value_ptr == (void *)EBADF); + } + } + SUCCEED; +} |