X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=src%2Fplugins%2Funittest%2Fsvm_fifo_test.c;h=242709cc6082a117653306e5e5a3e0e888601c03;hb=64e96613d27816ed7d24b9ca2ed760d855d76c81;hp=16fcf8871f5dbf7002d3dd103c62851acc849e99;hpb=2de9c0f92bb486072d8371a24d9b23fd85e1aa80;p=vpp.git

diff --git a/src/plugins/unittest/svm_fifo_test.c b/src/plugins/unittest/svm_fifo_test.c
index 16fcf8871f5..242709cc608 100644
--- a/src/plugins/unittest/svm_fifo_test.c
+++ b/src/plugins/unittest/svm_fifo_test.c
@@ -2009,6 +2009,67 @@ sfifo_test_fifo_replay (vlib_main_t * vm, unformat_input_t * input)
   return 0;
 }
 
+static int
+sfifo_test_fifo_make_rcv_wnd_zero (vlib_main_t * vm, unformat_input_t * input)
+{
+  int __clib_unused verbose = 0, fifo_size = 4096, deq_chunk;
+  fifo_segment_main_t _fsm = { 0 }, *fsm = &_fsm;
+  u8 *test_data = 0, *data_buf = 0;
+  fifo_segment_t *fs;
+  svm_fifo_t *f;
+  int rv;
+
+  while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT)
+    {
+      if (unformat (input, "verbose"))
+	verbose = 1;
+      else
+	{
+	  vlib_cli_output (vm, "parse error: '%U'", format_unformat_error,
+			   input);
+	  return -1;
+	}
+    }
+
+  /*
+   * Init fifo and enqueue data such that multiple 4096 chunks are allocated
+   */
+  fs = fifo_segment_prepare (fsm, "fifo-rcv-wnd-zero", 0);
+  f = fifo_prepare (fs, fifo_size);
+
+  /* Enqueue 3000 into 4KB chunk, so there'll be 1096 free space */
+  svm_fifo_set_size (f, 4096);
+  validate_test_and_buf_vecs (&test_data, &data_buf, fifo_size);
+  rv = svm_fifo_enqueue (f, 3000, test_data);
+  SFIFO_TEST (rv == 3000, "enqueued %u", rv);
+  rv = svm_fifo_max_enqueue (f);
+  SFIFO_TEST (rv == 1096, "svm_fifo_max_enqueue %u", rv);
+  SFIFO_TEST (svm_fifo_is_sane (f), "fifo should be sane");
+
+  /* Shrink fifo size to the in-use size */
+  svm_fifo_set_size (f, 3000);
+  SFIFO_TEST (svm_fifo_is_sane (f), "fifo should be sane");
+
+  /* In TCP, this should result in rcv-wnd = 0 */
+  rv = svm_fifo_max_enqueue (f);
+  SFIFO_TEST (rv == 0, "svm_fifo_max_enqueue %u", rv);
+  rv = svm_fifo_max_enqueue_prod (f);
+  SFIFO_TEST (rv == 0, "svm_fifo_max_enqueue_prod %u", rv);
+
+  /* Dequeue and ... */
+  rv = svm_fifo_dequeue (f, 3000, data_buf);
+  SFIFO_TEST (rv == 3000, "dequeued %u", rv);
+
+  /* Clean up */
+  ft_fifo_free (fs, f);
+  ft_fifo_segment_free (fsm, fs);
+  vec_free (test_data);
+  vec_free (data_buf);
+
+  return 0;
+}
+
+
 static fifo_segment_main_t segment_main;
 
 static int
@@ -2260,10 +2321,11 @@ sfifo_test_fifo_segment_fifo_grow (int verbose)
   /*
    * Allocate fifo and try to grow beyond available space
    */
-  f = fifo_segment_alloc_fifo (fs, fifo_size, FIFO_SEGMENT_RX_FIFO);
+  f = fifo_segment_alloc_fifo (fs, fifo_segment_free_bytes (fs),
+			       FIFO_SEGMENT_RX_FIFO);
 
   /* Try to force fifo growth */
-  svm_fifo_set_size (f, svm_fifo_size (f) + n_free_chunk_bytes);
+  svm_fifo_set_size (f, svm_fifo_size (f) + n_free_chunk_bytes + 1);
   validate_test_and_buf_vecs (&test_data, &data_buf, svm_fifo_size (f));
   rv = svm_fifo_enqueue (f, svm_fifo_size (f), test_data);
 
@@ -2570,7 +2632,6 @@ sfifo_test_fifo_segment (vlib_main_t * vm, unformat_input_t * input)
 {
   int rv, verbose = 0;
 
-  fifo_segment_main_init (&segment_main, HIGH_SEGMENT_BASEVA, 5);
   while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT)
     {
       if (unformat (input, "verbose"))
@@ -2632,7 +2693,8 @@ svm_fifo_test (vlib_main_t * vm, unformat_input_t * input,
   int res = 0;
   char *str;
 
-
+  clib_warning ("high mem %lu", HIGH_SEGMENT_BASEVA << 4);
+  fifo_segment_main_init (&segment_main, HIGH_SEGMENT_BASEVA << 4, 5);
   while (unformat_check_input (input) != UNFORMAT_END_OF_INPUT)
     {
       if (unformat (input, "fifo1"))
@@ -2659,6 +2721,8 @@ svm_fifo_test (vlib_main_t * vm, unformat_input_t * input,
 	res = sfifo_test_fifo_shrink (vm, input);
       else if (unformat (input, "indirect"))
 	res = sfifo_test_fifo_indirect (vm, input);
+      else if (unformat (input, "zero"))
+	res = sfifo_test_fifo_make_rcv_wnd_zero (vm, input);
       else if (unformat (input, "segment"))
 	res = sfifo_test_fifo_segment (vm, input);
       else if (unformat (input, "all"))
@@ -2723,6 +2787,9 @@ svm_fifo_test (vlib_main_t * vm, unformat_input_t * input,
 	  if ((res = sfifo_test_fifo_indirect (vm, input)))
 	    goto done;
 
+	  if ((res = sfifo_test_fifo_make_rcv_wnd_zero (vm, input)))
+	    goto done;
+
 	  str = "all";
 	  unformat_init_cstring (input, str);
 	  if ((res = sfifo_test_fifo_segment (vm, input)))