#define SEGMENT_MANAGER_GET_INDEX_FROM_HANDLE(x) (x >> 32)
-/* dummy callback functions */
+/* placeholder callback functions */
static void
-dummy_session_reset_callback (session_t * s)
+placeholder_session_reset_callback (session_t * s)
{
clib_warning ("called...");
}
static int
-dummy_session_connected_callback (u32 app_index, u32 api_context,
- session_t * s, u8 is_fail)
+placeholder_session_connected_callback (u32 app_index, u32 api_context,
+ session_t * s, session_error_t err)
{
clib_warning ("called...");
return 0;
}
static int
-dummy_add_segment_callback (u32 client_index, u64 segment_handle)
+placeholder_add_segment_callback (u32 client_index, u64 segment_handle)
{
clib_warning ("called...");
return 0;
}
static int
-dummy_del_segment_callback (u32 client_index, u64 segment_handle)
+placeholder_del_segment_callback (u32 client_index, u64 segment_handle)
{
clib_warning ("called...");
return 0;
}
static void
-dummy_session_disconnect_callback (session_t * s)
+placeholder_session_disconnect_callback (session_t * s)
{
clib_warning ("called...");
}
static int
-dummy_session_accept_callback (session_t * s)
+placeholder_session_accept_callback (session_t * s)
{
clib_warning ("called...");
return 0;
}
static int
-dummy_server_rx_callback (session_t * s)
+placeholder_server_rx_callback (session_t * s)
{
clib_warning ("called...");
return -1;
}
-/* *INDENT-OFF* */
-static session_cb_vft_t dummy_session_cbs = {
- .session_reset_callback = dummy_session_reset_callback,
- .session_connected_callback = dummy_session_connected_callback,
- .session_accept_callback = dummy_session_accept_callback,
- .session_disconnect_callback = dummy_session_disconnect_callback,
- .builtin_app_rx_callback = dummy_server_rx_callback,
- .add_segment_callback = dummy_add_segment_callback,
- .del_segment_callback = dummy_del_segment_callback,
+static session_cb_vft_t placeholder_session_cbs = {
+ .session_reset_callback = placeholder_session_reset_callback,
+ .session_connected_callback = placeholder_session_connected_callback,
+ .session_accept_callback = placeholder_session_accept_callback,
+ .session_disconnect_callback = placeholder_session_disconnect_callback,
+ .builtin_app_rx_callback = placeholder_server_rx_callback,
+ .add_segment_callback = placeholder_add_segment_callback,
+ .del_segment_callback = placeholder_del_segment_callback,
};
-/* *INDENT-ON* */
static char *states_str[] = {
#define _(sym,str) str,
.api_client_index = ~0,
.options = options,
.namespace_id = 0,
- .session_cb_vft = &dummy_session_cbs,
+ .session_cb_vft = &placeholder_session_cbs,
.name = format (0, "segment_manager_test_pressure_1"),
};
svm_fifo_enqueue (tx_fifo, fifo_size - 1, data);
/* 256KB+ / 2048KB+ => ~12% */
- fifo_segment_update_free_bytes (fs);
rv = fifo_segment_get_mem_status (fs);
SEG_MGR_TEST ((rv == MEMORY_PRESSURE_NO_PRESSURE),
"fifo_segment_get_mem_status %s", states_str[rv]);
svm_fifo_enqueue (rx_fifo, fifo_size, data);
svm_fifo_enqueue (tx_fifo, fifo_size, data);
svm_fifo_enqueue (tx_fifo, fifo_size, data);
- svm_fifo_enqueue (tx_fifo, fifo_size, data);
- /* 8 chunks : 49% */
- fifo_segment_update_free_bytes (fs);
+ /* 7 chunks : ~44% */
rv = fifo_segment_get_mem_status (fs);
SEG_MGR_TEST ((rv == MEMORY_PRESSURE_NO_PRESSURE),
"fifo_segment_get_mem_status %s", states_str[rv]);
/* grow fifos */
+ svm_fifo_enqueue (tx_fifo, fifo_size, data);
svm_fifo_enqueue (rx_fifo, fifo_size, data);
svm_fifo_enqueue (tx_fifo, fifo_size, data);
/* 10 chunks : 61% */
- fifo_segment_update_free_bytes (fs);
rv = fifo_segment_get_mem_status (fs);
SEG_MGR_TEST ((rv == MEMORY_PRESSURE_LOW_PRESSURE),
"fifo_segment_get_mem_status %s", states_str[rv]);
svm_fifo_enqueue (tx_fifo, fifo_size, data);
/* 14 chunks : 85% */
- fifo_segment_update_free_bytes (fs);
rv = fifo_segment_get_mem_status (fs);
SEG_MGR_TEST ((rv == MEMORY_PRESSURE_HIGH_PRESSURE),
"fifo_segment_get_mem_status %s", states_str[rv]);
svm_fifo_dequeue_drop (tx_fifo, fifo_size);
svm_fifo_dequeue_drop (tx_fifo, fifo_size);
- /* 10 chunks : 61% */
- fifo_segment_update_free_bytes (fs);
+ /* 10 chunks : 63% */
rv = fifo_segment_get_mem_status (fs);
SEG_MGR_TEST ((rv == MEMORY_PRESSURE_LOW_PRESSURE),
"fifo_segment_get_mem_status %s", states_str[rv]);
svm_fifo_enqueue (tx_fifo, fifo_size, data);
svm_fifo_enqueue (tx_fifo, fifo_size, data);
- /* 14 chunks : 85% */
- fifo_segment_update_free_bytes (fs);
+ /* 14 chunks : 88% */
rv = fifo_segment_get_mem_status (fs);
SEG_MGR_TEST ((rv == MEMORY_PRESSURE_HIGH_PRESSURE),
"fifo_segment_get_mem_status %s", states_str[rv]);
svm_fifo_dequeue_drop (tx_fifo, fifo_size);
svm_fifo_dequeue_drop (tx_fifo, fifo_size);
-
- /* 10 chunks : 61% */
- fifo_segment_update_free_bytes (fs);
+ /* 10 chunks : 63% */
rv = fifo_segment_get_mem_status (fs);
SEG_MGR_TEST ((rv == MEMORY_PRESSURE_LOW_PRESSURE),
"fifo_segment_get_mem_status %s", states_str[rv]);
svm_fifo_dequeue_drop (tx_fifo, fifo_size);
/* 2 chunks : 12% */
- fifo_segment_update_free_bytes (fs);
rv = fifo_segment_get_mem_status (fs);
SEG_MGR_TEST ((rv == MEMORY_PRESSURE_NO_PRESSURE),
"fifo_segment_get_mem_status %s", states_str[rv]);
.api_client_index = ~0,
.options = options,
.namespace_id = 0,
- .session_cb_vft = &dummy_session_cbs,
- .name = format (0, "segment_manager_test_pressure_1"),
+ .session_cb_vft = &placeholder_session_cbs,
+ .name = format (0, "segment_manager_test_pressure_2"),
};
attach_args.options[APP_OPTIONS_SEGMENT_SIZE] = app_seg_size;
/* initial status : (0 / 2MB) */
fs0 = segment_manager_get_segment (sm, 0);
- fifo_segment_update_free_bytes (fs0);
rv = fifo_segment_get_mem_status (fs0);
SEG_MGR_TEST ((rv == MEMORY_PRESSURE_NO_PRESSURE),
"fifo_segment_get_mem_status %s", states_str[rv]);
&rx_fifo, &tx_fifo);
SEG_MGR_TEST ((rv == 0), "segment_manager_alloc_session_fifos %d", rv);
- svm_fifo_set_size (rx_fifo, size_2MB);
- svm_fifo_set_size (tx_fifo, size_2MB);
+ svm_fifo_set_size (rx_fifo, size_1MB);
+ svm_fifo_set_size (tx_fifo, size_1MB);
/* fill fifos (but not add chunks) */
svm_fifo_enqueue (rx_fifo, fifo_size - 1, data);
for (i = 0; i < 509; ++i)
{
svm_fifo_enqueue (rx_fifo, fifo_size, data);
+ svm_fifo_enqueue (tx_fifo, fifo_size, data);
}
- /* 510 chunks : 100% of 2MB */
- fifo_segment_update_free_bytes (fs);
+ /* 100% of 2MB */
rv = fifo_segment_get_mem_status (fs);
SEG_MGR_TEST ((rv == MEMORY_PRESSURE_HIGH_PRESSURE),
"fifo_segment_get_mem_status %s", states_str[rv]);
rv = svm_fifo_enqueue (rx_fifo, fifo_size, data);
SEG_MGR_TEST ((rv == SVM_FIFO_EGROW), "svm_fifo_enqueue %d", rv);
- /* then, no-memory is detected */
- fifo_segment_update_free_bytes (fs);
- rv = fifo_segment_get_mem_status (fs);
- SEG_MGR_TEST ((rv == MEMORY_PRESSURE_NO_MEMORY),
- "fifo_segment_get_mem_status %s", states_str[rv]);
-
/* shrink fifos */
for (i = 0; i < 20; ++i)
{
svm_fifo_dequeue_drop (rx_fifo, fifo_size);
+ svm_fifo_dequeue_drop (tx_fifo, fifo_size);
}
/* 489 chunks : 96%, it is high-pressure level
* but the reached-mem-limit record is not reset
* so the no-memory state lasts.
*/
- fifo_segment_update_free_bytes (fs);
- rv = fifo_segment_get_mem_status (fs);
- SEG_MGR_TEST ((rv == MEMORY_PRESSURE_NO_MEMORY),
- "fifo_segment_get_mem_status %s", states_str[rv]);
+ /*
+ rv = fifo_segment_get_mem_status (fs);
+ SEG_MGR_TEST ((rv == MEMORY_PRESSURE_NO_MEMORY),
+ "fifo_segment_get_mem_status %s", states_str[rv]);
+ */
/* shrink fifos */
for (i = 0; i < 133; ++i)
}
/* 356 chunks : 70% of 2MB */
- fifo_segment_update_free_bytes (fs);
rv = fifo_segment_get_mem_status (fs);
SEG_MGR_TEST ((rv == MEMORY_PRESSURE_LOW_PRESSURE),
"fifo_segment_get_mem_status %s", states_str[rv]);
/* shrink fifos */
- for (i = 0; i < 354; ++i)
+ for (i = 0; i < 360; ++i)
{
svm_fifo_dequeue_drop (rx_fifo, fifo_size);
+ svm_fifo_dequeue_drop (tx_fifo, fifo_size);
}
/* 2 chunks : 3% of 2MB */
- fifo_segment_update_free_bytes (fs);
rv = fifo_segment_get_mem_status (fs);
SEG_MGR_TEST ((rv == MEMORY_PRESSURE_NO_PRESSURE),
"fifo_segment_get_mem_status %s", states_str[rv]);
.api_client_index = ~0,
.options = options,
.namespace_id = 0,
- .session_cb_vft = &dummy_session_cbs,
- .name = format (0, "segment_manager_test_pressure_1"),
+ .session_cb_vft = &placeholder_session_cbs,
+ .name = format (0, "segment_manager_test_fifo_balanced_alloc"),
};
attach_args.options[APP_OPTIONS_SEGMENT_SIZE] = app_seg_size;
}
/* add another 2MB segment */
- fs_index = segment_manager_add_segment (sm, size_2MB);
+ fs_index = segment_manager_add_segment (sm, size_2MB, 0);
SEG_MGR_TEST ((fs_index == 1), "fs_index %d", fs_index);
/* allocate fifos : 4KB x2
return 0;
}
-static int
-segment_manager_test_fifo_ops (vlib_main_t * vm, unformat_input_t * input)
+/* disabled until fifo tuning and memory pressure are properly working */
+__clib_unused static int
+segment_manager_test_fifo_ops (vlib_main_t *vm, unformat_input_t *input)
{
int rv, i;
segment_manager_t *sm;
.api_client_index = ~0,
.options = options,
.namespace_id = 0,
- .session_cb_vft = &dummy_session_cbs,
+ .session_cb_vft = &placeholder_session_cbs,
.name = format (0, "segment_manager_test_pressure_1"),
};
"fifo_segment_get_mem_status %s", states_str[rv]);
/* (virtual) fifo size is still large as it is not updated */
- SEG_MGR_TEST ((rx_fifo->size == most_grown), "rx_fifo->size %u",
- rx_fifo->size);
+ SEG_MGR_TEST ((rx_fifo->shr->size == most_grown), "rx_fifo->size %u",
+ rx_fifo->shr->size);
vnet_app_detach_args_t detach_args = {
.app_index = attach_args.app_index,
return 0;
}
+static int
+segment_manager_test_prealloc_hdrs (vlib_main_t * vm,
+ unformat_input_t * input)
+{
+ u32 fifo_size = size_4KB, prealloc_hdrs, sm_index, fs_index;
+ u64 options[APP_OPTIONS_N_OPTIONS];
+ uword app_seg_size = size_2MB * 2;
+ segment_manager_t *sm;
+ fifo_segment_t *fs;
+ int rv;
+
+ memset (&options, 0, sizeof (options));
+
+ vnet_app_attach_args_t attach_args = {
+ .api_client_index = ~0,
+ .options = options,
+ .namespace_id = 0,
+ .session_cb_vft = &placeholder_session_cbs,
+ .name = format (0, "segment_manager_test_prealloc_hdrs"),
+ };
+
+ prealloc_hdrs = 64;
+
+ attach_args.options[APP_OPTIONS_SEGMENT_SIZE] = app_seg_size;
+ attach_args.options[APP_OPTIONS_FLAGS] = APP_OPTIONS_FLAGS_IS_BUILTIN;
+ attach_args.options[APP_OPTIONS_RX_FIFO_SIZE] = fifo_size;
+ attach_args.options[APP_OPTIONS_TX_FIFO_SIZE] = fifo_size;
+ attach_args.options[APP_OPTIONS_PREALLOC_FIFO_HDRS] = prealloc_hdrs;
+
+ rv = vnet_application_attach (&attach_args);
+ vec_free (attach_args.name);
+
+ SEG_MGR_TEST ((rv == 0), "vnet_application_attach %d", rv);
+
+ segment_manager_parse_segment_handle (attach_args.segment_handle, &sm_index,
+ &fs_index);
+ sm = segment_manager_get (sm_index);
+
+ SEG_MGR_TEST ((sm != 0), "seg manager is valid", sm);
+
+ fs = segment_manager_get_segment (sm, fs_index);
+ SEG_MGR_TEST (fifo_segment_num_free_fifos (fs) == prealloc_hdrs,
+ "prealloc should be %u", prealloc_hdrs);
+
+ vnet_app_detach_args_t detach_args = {
+ .app_index = attach_args.app_index,
+ .api_client_index = ~0,
+ };
+ rv = vnet_application_detach (&detach_args);
+ SEG_MGR_TEST ((rv == 0), "vnet_application_detach %d", rv);
+ return 0;
+}
static clib_error_t *
segment_manager_test (vlib_main_t * vm,
res = segment_manager_test_pressure_2 (vm, input);
else if (unformat (input, "alloc"))
res = segment_manager_test_fifo_balanced_alloc (vm, input);
- else if (unformat (input, "fifo_ops"))
- res = segment_manager_test_fifo_ops (vm, input);
+ else if (unformat (input, "prealloc_hdrs"))
+ res = segment_manager_test_prealloc_hdrs (vm, input);
else if (unformat (input, "all"))
{
goto done;
if ((res = segment_manager_test_fifo_balanced_alloc (vm, input)))
goto done;
- if ((res = segment_manager_test_fifo_ops (vm, input)))
+ if ((res = segment_manager_test_prealloc_hdrs (vm, input)))
goto done;
}
else
return 0;
}
-/* *INDENT-OFF* */
VLIB_CLI_COMMAND (tcp_test_command, static) =
{
.path = "test segment-manager",
.short_help = "test segment manager [pressure_levels_1]"
- "[pressure_level_2][alloc][fifo_ops][all]",
+ "[pressure_level_2][alloc][fifo_ops][prealloc_hdrs][all]",
.function = segment_manager_test,
};
* eval: (c-set-style "gnu")
* End:
*/
-
Code Review / vpp.git / blobdiff