Index: benchmark/io/sendfile/consumer.c
===================================================================
--- benchmark/io/sendfile/consumer.c	(revision da81b849ae2b320b5a4c2cef64756a4105b72ed9)
+++ benchmark/io/sendfile/consumer.c	(revision ef6d0594a14cc3fac10e95fc56ea1bbd9c1b9e38)
@@ -86,5 +86,5 @@
 	printf( "actial port: %d\n", ntohs(address.sin_port) );
 
-	ret = listen( listenfd, 0 );
+	ret = listen( listenfd, 1 );
 	if(ret < 0) {
 		fprintf( stderr, "listen error: (%d) %s\n", (int)errno, strerror(errno) );
@@ -92,48 +92,51 @@
 	}
 
-	struct sockaddr_in cli_addr;
-     	__socklen_t clilen = sizeof(cli_addr);
-	int fd = accept( listenfd, (struct sockaddr *) &cli_addr, &clilen );
-	if(fd < 0) {
-		fprintf( stderr, "accept error: (%d) %s\n", (int)errno, strerror(errno) );
-		exit( ACCEPT_ERROR );
+	for(int i = 0; i < 2; i++) {
+		struct sockaddr_in cli_addr;
+		__socklen_t clilen = sizeof(cli_addr);
+		int fd = accept( listenfd, (struct sockaddr *) &cli_addr, &clilen );
+		if(fd < 0) {
+			fprintf( stderr, "accept error: (%d) %s\n", (int)errno, strerror(errno) );
+			exit( ACCEPT_ERROR );
+		}
+
+		int error = 0;
+		size_t calls = 0;
+		size_t bytes = 0;
+
+		struct timespec after, before;
+
+		clock_gettime(CLOCK_MONOTONIC, &before);
+
+		for(;;) {
+			ret = recv(fd, buffer, buffer_len, 0);
+			if(ret == 0 ) goto EXIT;
+			if(ret < 0 ) {
+				if( errno == EAGAIN || errno == EWOULDBLOCK) continue;
+				if( errno == ECONNRESET ) { printf("Connection reset\n"); goto EXIT; }
+				if( errno == EPIPE ) { printf("Pipe closed\n"); goto EXIT; }
+				fprintf( stderr, "accept error: (%d) %s\n", (int)errno, strerror(errno) );
+				error = READ_ERROR;
+				goto EXIT;
+			}
+			calls++;
+			bytes += ret;
+		}
+		EXIT:;
+
+		clock_gettime(CLOCK_MONOTONIC, &after);
+
+		uint64_t tb = ((int64_t)before.tv_sec * TIMEGRAN) + before.tv_nsec;
+		uint64_t ta = ((int64_t)after.tv_sec * TIMEGRAN) + after.tv_nsec;
+		double secs = ((double)ta - tb) / TIMEGRAN;
+
+		printf("Received %'zu bytes in %'zu reads, %f seconds\n", bytes, calls, secs);
+		printf(" - %'3.3f bytes per second\n", (((double)bytes) / secs));
+		printf(" - %'3.3f bytes per calls\n", (((double)bytes) / calls));
+
+		close(fd);
+		if(error != 0) exit( error );
 	}
-
-	int error = 0;
-	size_t calls = 0;
-	size_t bytes = 0;
-
-	struct timespec after, before;
-
-	clock_gettime(CLOCK_MONOTONIC, &before);
-
-	for(;;) {
-		ret = recv(fd, buffer, buffer_len, 0);
-		if(ret == 0 ) goto EXIT;
-		if(ret < 0 ) {
-			if( errno == EAGAIN || errno == EWOULDBLOCK) continue;
-			if( errno == ECONNRESET ) { printf("Connection reset\n"); goto EXIT; }
-			if( errno == EPIPE ) { printf("Pipe closed\n"); goto EXIT; }
-			fprintf( stderr, "accept error: (%d) %s\n", (int)errno, strerror(errno) );
-			error = READ_ERROR;
-			goto EXIT;
-		}
-		calls++;
-		bytes += ret;
-	}
-	EXIT:;
-
-	clock_gettime(CLOCK_MONOTONIC, &after);
-
-	uint64_t tb = ((int64_t)before.tv_sec * TIMEGRAN) + before.tv_nsec;
-	uint64_t ta = ((int64_t)after.tv_sec * TIMEGRAN) + after.tv_nsec;
-	double secs = ((double)ta - tb) / TIMEGRAN;
-
-	printf("Received %'zu bytes in %'zu reads, %f seconds\n", bytes, calls, secs);
-	printf(" - %'3.3f bytes per second\n", (((double)bytes) / secs));
-	printf(" - %'3.3f bytes per calls\n", (((double)bytes) / calls));
-
 	close(listenfd);
-	close(fd);
-	return error;
+	return 0;
 }