From b44e9bc90b634b07d5f93a731a95028adc73bcbc Mon Sep 17 00:00:00 2001 From: Dave Barach Date: Fri, 19 Feb 2016 09:06:23 -0500 Subject: Serialize and upload the data plane node graph Include node names and graph arcs. Prep work for uploading node runtime data, so the latter can be reported in a comprehensible manner. Change-Id: I215b1f8cff244200c37c7e088f1f22229dc97eb6 Signed-off-by: Dave Barach --- vlib-api/Makefile.am | 3 +- vlib-api/vlibapi/api.h | 4 ++ vlib-api/vlibapi/node_serialize.c | 141 ++++++++++++++++++++++++++++++++++++++ 3 files changed, 147 insertions(+), 1 deletion(-) create mode 100644 vlib-api/vlibapi/node_serialize.c (limited to 'vlib-api') diff --git a/vlib-api/Makefile.am b/vlib-api/Makefile.am index f72d23aa72e..a1fab44c687 100644 --- a/vlib-api/Makefile.am +++ b/vlib-api/Makefile.am @@ -20,7 +20,8 @@ lib_LTLIBRARIES = libvlibapi.la libvlibmemory.la libvlibmemoryclient.la \ libvlibapi_la_SOURCES = \ vlibapi/api.h \ - vlibapi/api_shared.c + vlibapi/api_shared.c \ + vlibapi/node_serialize.c nobase_include_HEADERS = vlibapi/api.h diff --git a/vlib-api/vlibapi/api.h b/vlib-api/vlibapi/api.h index f620d950d8e..1f45a05738c 100644 --- a/vlib-api/vlibapi/api.h +++ b/vlib-api/vlibapi/api.h @@ -215,6 +215,10 @@ int vl_msg_api_pd_handler (void *mp, int rv); void vl_msg_api_set_first_available_msg_id (u16 first_avail); u16 vl_msg_api_get_msg_ids (char * name, int n); +/* node_serialize.c prototypes */ +u8 * vlib_node_serialize (vlib_node_main_t *nm, u8 * vector); +vlib_node_t ** vlib_node_unserialize (u8 * vector); + #define VLIB_API_INIT_FUNCTION(x) VLIB_DECLARE_INIT_FUNCTION(x,api_init) #endif /* included_api_h */ diff --git a/vlib-api/vlibapi/node_serialize.c b/vlib-api/vlibapi/node_serialize.c new file mode 100644 index 00000000000..d4fbd502398 --- /dev/null +++ b/vlib-api/vlibapi/node_serialize.c @@ -0,0 +1,141 @@ +/* + * Copyright (c) 2016 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +#include + +#include + +/* + * Serialize a vlib_node_main_t. Appends the result to vector. + * Pass 0 to create a new vector, use vec_reset_length(vector) + * to recycle a vector / avoid memory allocation, etc. + * Switch heaps before/after to serialize into API client shared memory. + */ + +u8 * vlib_node_serialize (vlib_node_main_t *nm, u8 * vector) +{ + serialize_main_t _sm, *sm=&_sm; + vlib_node_t * node; + int i, j; + u8 * cstemp = 0; + + serialize_open_vector (sm, vector); + + serialize_likely_small_unsigned_integer (sm, vec_len(nm->nodes)); + for (i = 0; i < vec_len (nm->nodes); i++) + { + node = nm->nodes[i]; + vec_reset_length (cstemp); + cstemp = vec_dup(node->name); + vec_add1(cstemp, 0); + serialize_cstring (sm, (char *)cstemp); + serialize_likely_small_unsigned_integer (sm, vec_len(node->next_nodes)); + for (j = 0; j < vec_len (node->next_nodes); j++) + serialize_likely_small_unsigned_integer (sm, node->next_nodes[j]); + } + vec_free(cstemp); + + return (serialize_close_vector (sm)); +} + +vlib_node_t ** vlib_node_unserialize (u8 * vector) +{ + serialize_main_t _sm, *sm=&_sm; + u32 nnodes, nnexts; + vlib_node_t * node; + vlib_node_t ** nodes = 0; + int i, j; + + serialize_open_vector (sm, vector); + + nnodes = unserialize_likely_small_unsigned_integer (sm); + + vec_validate (nodes, nnodes-1); + + for (i = 0; i < nnodes; i++) + { + node = 0; + vec_validate (node,0); + nodes[i] = node; + unserialize_cstring (sm, (char **)&node->name); + + nnexts = unserialize_likely_small_unsigned_integer (sm); + if (nnexts > 0) + vec_validate (node->next_nodes, nnexts-1); + for (j = 0; j < vec_len (node->next_nodes); j++) + node->next_nodes[j] = + unserialize_likely_small_unsigned_integer (sm); + } + return nodes; +} + + +#if CLIB_DEBUG > 0 + +static clib_error_t * +test_node_serialize_command_fn (vlib_main_t * vm, + unformat_input_t * input, + vlib_cli_command_t * cmd) +{ + vlib_node_main_t * nm = &vm->node_main; + u8 * vector = 0; + vlib_node_t ** nodes; + vlib_node_t * node; + vlib_node_t * next_node; + int i, j; + + /* + * Keep the number of memcpy ops to a minimum (e.g. 1). + * The current size of the serialized vector is + * slightly under 4K. + */ + vec_validate (vector, 4095); + vec_reset_length (vector); + + vector = vlib_node_serialize (nm, vector); + + nodes = vlib_node_unserialize (vector); + + vec_free (vector); + + for (i = 0; i < vec_len(nodes); i++) + { + node = nodes[i]; + + vlib_cli_output (vm, "[%d] %s", i, node->name); + for (j = 0; j < vec_len (node->next_nodes); j++) + { + if (node->next_nodes[j] != ~0) + next_node = nodes[node->next_nodes[j]]; + vlib_cli_output (vm, " [%d] %s", j, next_node->name); + } + } + + for (i = 0; i < vec_len(nodes); i++) + { + vec_free (nodes[i]->name); + vec_free (nodes[i]->next_nodes); + vec_free (nodes[i]); + } + vec_free(nodes); + + return 0; +} + +VLIB_CLI_COMMAND (test_node_serialize_node, static) = { + .path = "test node serialize", + .short_help = "test node serialize", + .function = test_node_serialize_command_fn, +}; +#endif -- cgit 1.2.3-korg