From edf1637312c81eff0f8c6b22e8fa46f963169ff8 Mon Sep 17 00:00:00 2001 From: Sean Hefty Date: Fri, 16 Aug 2013 23:45:53 -0700 Subject: [PATCH] Refresh of shutdown --- examples/rstream.c | 30 +----------------------------- 1 file changed, 1 insertion(+), 29 deletions(-) diff --git a/examples/rstream.c b/examples/rstream.c index 0135927b..278437f6 100644 --- a/examples/rstream.c +++ b/examples/rstream.c @@ -445,20 +445,8 @@ free: return ret; } -static void *do_shutdown(void *arg) -{ - int rs = (int) arg; - - sleep(1); - printf("calling shutdown from separate thread\n"); - rs_shutdown(rs, SHUT_RDWR); - printf("shutdown completed\n"); - return NULL; -} - static int run(void) { - struct pollfd fds; int i, ret = 0; buf = malloc(!custom ? test_size[TEST_CNT - 1].size : transfer_size); @@ -518,23 +506,7 @@ static int run(void) if (fork_pid) wait(NULL); else - { - if (dst_addr) { - pthread_t thread_id; - ret = pthread_create(&thread_id, NULL, do_shutdown, (void*) rs); - - fds.fd = rs; - fds.events = POLLIN; - printf("calling poll\n"); - ret = rs_poll(&fds, 1, 10000); - printf("poll ret %d (%s) revents 0x%x (POLLHUP 0x%x)\n", - ret, strerror(errno), fds.revents, POLLHUP); - } else { - printf("sleeping for 10 seconds\n"); - sleep(10); - rs_shutdown(rs, SHUT_RDWR); - } - } + rs_shutdown(rs, SHUT_RDWR); rs_close(rs); free: free(buf); -- 2.46.0