From: Sean Hefty <sean.hefty@intel.com>
Date: Sat, 17 Aug 2013 06:45:53 +0000 (-0700)
Subject: Refresh of shutdown
X-Git-Url: https://openfabrics.org/gitweb/?a=commitdiff_plain;h=edf1637312c81eff0f8c6b22e8fa46f963169ff8;p=~shefty%2Flibrdmacm.git

Refresh of shutdown
---

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);