/* * Copyright (c) 2015 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. */ /* * node_cli.c: node CLI * * Copyright (c) 2008 Eliot Dresselhaus * * Permission is hereby granted, free of charge, to any person obtaining * a copy of this software and associated documentation files (the * "Software"), to deal in the Software without restriction, including * without limitation the rights to use, copy, modify, merge, publish, * distribute, sublicense, and/or sell copies of the Software, and to * permit persons to whom the Software is furnished to do so, subject to * the following conditions: * * The above copyright notice and this permission notice shall be * included in all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE * LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */ #include #include #include #include #include #include #include static int node_cmp (void *a1, void *a2) { vlib_node_t **n1 = a1; vlib_node_t **n2 = a2; return vec_cmp (n1[0]->name, n2[0]->name); } static clib_error_t * show_node_graph (vlib_main_t * vm, unformat_input_t * input, vlib_cli_command_t * cmd) { vlib_node_main_t *nm = &vm->node_main; vlib_node_t *n; u32 node_index; vlib_cli_output (vm, "%U\n", format_vlib_node_graph, nm, 0); if (unformat (input, "%U", unformat_vlib_node, vm, &node_index)) { n = vlib_get_node (vm, node_index); vlib_cli_output (vm, "%U\n", format_vlib_node_graph, nm, n); } else { vlib_node_t **nodes = vec_dup (nm->nodes); uword i; vec_sort_with_function (nodes, node_cmp); for (i = 0; i < vec_len (nodes); i++) vlib_cli_output (vm, "%U\n\n", format_vlib_node_graph, nm, nodes[i]); vec_free (nodes); } return 0; } /* *INDENT-OFF* */ VLIB_CLI_COMMAND (show_node_graph_command, static) = { .path = "show vlib graph", .short_help = "Show packet processing node graph", .function = show_node_graph, }; /* *INDENT-ON* */ static clib_error_t * show_node_graphviz (vlib_main_t * vm, unformat_input_t * input, vlib_cli_command_t * cmd) { clib_error_t *error = 0; vlib_node_main_t *nm = &vm->node_main; vlib_node_t **nodes = nm->nodes; u8 *chroot_filename = 0; int fd; uword *active = 0; u32 i, j; unformat_input_t _line_input, *line_input = &_line_input; u8 filter = 0, calls_filter = 0, vectors_filter = 0, both = 0; fd = -1; /* Get a line of input. */ if (unformat_user (input, unformat_line_input, line_input)) { while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT) { if (unformat (line_input, "filter")) filter = 1; else if (unformat (line_input, "calls") && filter) calls_filter = 1; else if (unformat (line_input, "vectors") && filter) vectors_filter = 1; else if (unformat (line_input, "file %U", unformat_vlib_tmpfile, &chroot_filename)) { fd = open ((char *) chroot_filename, O_CREAT | O_TRUNC | O_WRONLY, 0664); } else return clib_error_return (0, "unknown input `%U'", format_unformat_error, input); } unformat_free (line_input); } /*both is set to true if calls_filter and vectors_filter are, or neither */ both = filter & (!(calls_filter ^ vectors_filter)); #define format__(vm__, fd__, ...) \ if ((fd) < 0) \ { \ vlib_cli_output((vm__), ## __VA_ARGS__); \ } \ else \ { \ fdformat((fd__), ## __VA_ARGS__); \ } format__ (vm, fd, "%s", "digraph {\n"); clib_bitmap_alloc (active, vec_len (nodes)); clib_bitmap_set_region (active, 0, 1, vec_len (nodes)); if (filter) { /*Adding the legend to the dot file*/ format__ (vm, fd, "%s", " rankdir=\"LR\"\n nodesep=2\n subgraph cluster_legend {\n " " label=\"Legend\"\n style=\"solid\"\n labelloc = b\n " " subgraph cluster_colors {\n label=\"Packets/Call\"\n " " style=\"solid\"\n labelloc = b\n"); format__ (vm, fd, "%s", " 0 [label=\"No packet\", fixedsize=true shape=circle " "width=2 fontsize=17]\n" " 1 [label=\"1-32\", fillcolor=1 style=filled " "colorscheme=ylorrd8 fixedsize=true shape=circle width=2 " "fontsize=17]\n" " 2 [label=\"33-64\", fillcolor=2 style=filled " "colorscheme=ylorrd8 fixedsize=true shape=circle width=2 " "fontsize=17]\n" " 3 [label=\"65-96\", fillcolor=3 style=filled " "colorscheme=ylorrd8 fixedsize=true shape=circle width=2 " "fontsize=17]\n" " 4 [label=\"97-128\", fillcolor=4 style=filled " "colorscheme=ylorrd8 fixedsize=true shape=circle width=2 " "fontsize=17]\n" " 5 [label=\"129-160\", fillcolor=5 style=filled " "colorscheme=ylorrd8 fixedsize=true shape=circle width=2 " "fontsize=17]\n" " 6 [label=\"161-192\", fillcolor=6 style=filled " "colorscheme=ylorrd8 fixedsize=true shape=circle width=2 " "fontsize=17]\n" " 7 [label=\"193-224\", fillcolor=7 style=filled " "colorscheme=ylorrd8 fixedsize=true shape=circle width=2 " "fontsize=17]\n" " 8 [label=\"224+\", fillcolor=8 style=filled " "colorscheme=ylorrd8 fixedsize=true shape=circle width=2 " "fontsize=17]\n"); format__ (vm, fd, "%s", " 0 -> 1 -> 2 -> 3 -> 4 [style=\"invis\",weight =100]\n " " 5 -> 6 -> 7 -> 8 [style=\"invis\",weight =100]\n }\n " " subgraph cluster_size {\n label=\"Cycles/Packet\"\n " " style=\"solid\"\n labelloc = b\n"); format__ ( vm, fd, "%s", " a[label=\"0\",fixedsize=true shape=circle width=1] \n" " b[label=\"10\",fixedsize=true shape=circle width=2 " "fontsize=17]\n" " c[label=\"100\",fixedsize=true shape=circle width=3 " "fontsize=20]\n" " d[label=\"1000\",fixedsize=true shape=circle width=4 " "fontsize=23]\n" " a -> b -> c -> d [style=\"invis\",weight =100]\n }\n }\n"); vlib_worker_thread_barrier_sync (vm); for (j = 0; j < vec_len (nm->nodes); j++) { vlib_node_t *n; n = nm->nodes[j]; vlib_node_sync_stats (vm, n); } /* Updating the stats for multithreaded use cases. * We need to dup the nodes to sum the stats from all threads.*/ nodes = vec_dup (nm->nodes); for (i = 1; i < vlib_get_n_threads (); i++) { vlib_node_main_t *nm_clone; vlib_main_t *vm_clone; vlib_node_runtime_t *rt; vlib_node_t *n; vm_clone = vlib_get_main_by_index (i); nm_clone = &vm_clone->node_main; for (j = 0; j < vec_len (nm_clone->nodes); j++) { n = nm_clone->nodes[j]; rt = vlib_node_get_runtime (vm_clone, n->index); /* Sync the stats directly in the duplicated node.*/ vlib_node_runtime_sync_stats_node (nodes[j], rt, 0, 0, 0); } } vlib_worker_thread_barrier_release (vm); for (i = 0; i < vec_len (nodes); i++) { u64 p, c, l; c = nodes[i]->stats_total.calls - nodes[i]->stats_last_clear.calls; p = nodes[i]->stats_total.vectors - nodes[i]->stats_last_clear.vectors; l = nodes[i]->stats_total.clocks - nodes[i]->stats_last_clear.clocks; if ((both && c > 0 && p > 0) || (calls_filter && c > 0) || (vectors_filter && p > 0)) { format__ (vm, fd, " \"%v\" [shape=circle", nodes[i]->name); /*Changing the size and the font of nodes that receive packets*/ if (p > 0) { f64 x = (f64) l / (f64) p; f64 size_ratio = (1 + log10 (x + 1)); format__ (vm, fd, " width=%.2f fontsize=%.2f fixedsize=true", size_ratio, 11 + 3 * size_ratio); /*Coloring nodes that are indeed called*/ if (c > 0) { u64 color = ((p - 1) / (32 * c)) + 1; color = clib_min (color, 8); format__ ( vm, fd, " fillcolor=%u style=filled colorscheme=ylorrd8", color); } } format__ (vm, fd, "]\n"); } else { clib_bitmap_set (active, i, 0); } } } clib_bitmap_foreach (i, active) { for (j = 0; j < vec_len (nodes[i]->next_nodes); j++) { if (nodes[i]->next_nodes[j] == VLIB_INVALID_NODE_INDEX) continue; if (!filter || clib_bitmap_get (active, nodes[i]->next_nodes[j])) { format__ (vm, fd, " \"%v\" -> \"%v\"\n", nodes[i]->name, nodes[nodes[i]->next_nodes[j]]->name); } } } format__ (vm, fd, "}\n"); if (fd >= 0) { /*Dumping all the nodes saturates dot capacities to render a directed * graph. In this case, prefer using he fdp command to generate an * undirected graph. */ const char *soft = filter ? "dot" : "fdp"; vlib_cli_output ( vm, "vlib graph dumped into `%s'. Run eg. `%s -Tsvg -O %s'.", chroot_filename, soft, chroot_filename); } clib_bitmap_free (active); vec_free (chroot_filename); if (filter) vec_free (nodes); if (fd >= 0) close (fd); return error; } /*? * Dump dot files data to draw a graph of all the nodes. * If the argument 'filter' is provided, only the active nodes (since the last * "clear run" command) are selected and they are scaled and colored according * to their utilization. You can choose to filter nodes that are called, * nodes that receive vectors or both (default). * The 'file' option allows to save data 
/*
 * Copyright (c) 2019 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.
 */
/**
 * @file
 * @brief NAT active-passive HA
 */

#ifndef __included_nat_ha_h__
#define __included_nat_ha_h__

#include <vnet/vnet.h>
#include <vnet/ip/ip.h>

/* Call back functions for received HA events on passive/failover */
typedef void (*nat_ha_sadd_cb_t) (ip4_address_t * in_addr, u16 in_port,
				  ip4_address_t * out_addr, u16 out_port,
				  ip4_address_t * eh_addr, u16 eh_port,
				  ip4_address_t * ehn_addr, u16 ehn_port,
				  u8 proto, u32 fib_index, u16 flags,
				  u32 thread_index);
typedef void (*nat_ha_sdel_cb_t) (ip4_address_t * out_addr, u16 out_port,
				  ip4_address_t * eh_addr, u16 eh_port,
				  u8 proto, u32 fib_index, u32 thread_index);
typedef void (*nat_ha_sref_cb_t) (ip4_address_t * out_addr, u16 out_port,
				  ip4_address_t * eh_addr, u16 eh_port,
				  u8 proto, u32 fib_index, u32 total_pkts,
				  u64 total_bytes, u32 thread_index);

/**
 * @brief Initialize NAT HA
 */
void nat_ha_init (vlib_main_t * vm, nat_ha_sadd_cb_t sadd_cb,
		  nat_ha_sdel_cb_t sdel_cb, nat_ha_sref_cb_t sref_cb);

/**
 * @brief Set HA listener (local settings)
 *
 * @param addr local IP4 address
 * @param port local UDP port number
 * @param path_mtu path MTU between local and failover
 *
 * @returns 0 on success, non-zero value otherwise.
 */
int nat_ha_set_listener (ip4_address_t * addr, u16 port, u32 path_mtu);

/**
 * @brief Get HA listener/local configuration
 */
void nat_ha_get_listener (ip4_address_t * addr, u16 * port, u32 * path_mtu);

/**
 * @brief Set HA failover (remote settings)
 *
 * @param addr failover IP4 address
 * @param port failvoer UDP port number