X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=src%2Fvcl%2Fsock_test_server.c;h=896aeb024d85d27ce550663e312186c4873cdb13;hb=0e88e851e058f4fb7cc690dbbdb19216ab360d1c;hp=1280429f0f6bce5932b2ebca7cf4537dcd80f032;hpb=008dbe109ce2714be69ffb6549a0c0198a07f7d0;p=vpp.git

diff --git a/src/vcl/sock_test_server.c b/src/vcl/sock_test_server.c
index 1280429f0f6..896aeb024d8 100644
--- a/src/vcl/sock_test_server.c
+++ b/src/vcl/sock_test_server.c
@@ -24,6 +24,7 @@
 #include <vcl/sock_test.h>
 #include <sys/stat.h>
 #include <fcntl.h>
+#include <sys/ioctl.h>
 
 #define SOCK_SERVER_USE_EPOLL 1
 #define VPPCOM_SESSION_ATTR_UNIT_TEST 0
@@ -828,6 +829,7 @@ main (int argc, char **argv)
 	  if (EPOLLIN & ssm->wait_events[i].events)
 #endif
 	    {
+	    read_again:
 	      rx_bytes = sock_test_read (client_fd, conn->buf,
 					 conn->buf_size, &conn->stats);
 	      if (rx_bytes > 0)
@@ -910,6 +912,8 @@ main (int argc, char **argv)
 			   (conn->cfg.test == SOCK_TEST_TYPE_BI))
 		    {
 		      stream_test_server (conn, rx_bytes);
+		      if (ioctl (conn->fd, FIONREAD))
+			goto read_again;
 		      continue;
 		    }