ligang/vpp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

svm: fifo test

Browse Source 
Type: feature

Adding a very simple test case just to confirm that setting fifo size
same as the current in-use size would result no space to enqueue, which
is zero-window in the TCP.

Signed-off-by: Ryujiro Shibuya <ryujiro.shibuya@owmobility.com>
Change-Id: I6d60449386eaa270f801d2046cc7e546f843bf34
This commit is contained in:
Ryujiro Shibuya
2020-03-17 02:04:28 +00:00
committed by Florin Coras
parent 3ec09e9243
commit 64e96613d2
1 changed files with 66 additions and 0 deletions

66
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
@ -2660,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"))
@ -2724,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)))