perfmon: new perfmon plugin

Type: feature
Change-Id: I2c14f82393d11fc05c6d229f5c58603ab5c0f14d
Signed-off-by: Damjan Marion <damarion@cisco.com>

1 files changed, 437 insertions, 0 deletions

diff --git a/src/plugins/perfmon/cli.c b/src/plugins/perfmon/cli.c
new file mode 100644
index 00000000000..cb7debe1615
--- /dev/null
+++ b/src/plugins/perfmon/cli.c
@@ -0,0 +1,437 @@
+/*
+ * Copyright (c) 2020 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 <vnet/vnet.h>
+#include <perfmon/perfmon.h>
+#include <perfmon/table.h>
+
+uword
+unformat_perfmon_bundle_name (unformat_input_t *input, va_list *args)
+{
+  perfmon_main_t *pm = &perfmon_main;
+  perfmon_bundle_t **b = va_arg (*args, perfmon_bundle_t **);
+  uword *p;
+  u8 *str = 0;
+
+  if (unformat (input, "%s", &str) == 0)
+    return 0;
+
+  p = hash_get_mem (pm->bundle_by_name, str);
+
+  if (p)
+    b[0] = (perfmon_bundle_t *) p[0];
+
+  vec_free (str);
+  return p ? 1 : 0;
+}
+
+uword
+unformat_perfmon_source_name (unformat_input_t *input, va_list *args)
+{
+  perfmon_main_t *pm = &perfmon_main;
+  perfmon_source_t **b = va_arg (*args, perfmon_source_t **);
+  uword *p;
+  u8 *str = 0;
+
+  if (unformat (input, "%s", &str) == 0)
+    return 0;
+
+  p = hash_get_mem (pm->source_by_name, str);
+
+  if (p)
+    b[0] = (perfmon_source_t *) p[0];
+
+  vec_free (str);
+  return p ? 1 : 0;
+}
+
+u8 *
+format_perfmon_bundle (u8 *s, va_list *args)
+{
+  perfmon_bundle_t *b = va_arg (*args, perfmon_bundle_t *);
+  int verbose = va_arg (*args, int);
+
+  const char *bundle_type[] = {
+    [PERFMON_BUNDLE_TYPE_NODE] = "node",
+    [PERFMON_BUNDLE_TYPE_THREAD] = "thread",
+    [PERFMON_BUNDLE_TYPE_SYSTEM] = "system",
+  };
+
+  if (b == 0)
+    return format (s, "%-20s%-10s%-20s%s", "Name", "Type", "Source",
+		   "Description");
+
+  if (verbose)
+    {
+      s = format (s, "name: %s\n", b->name);
+      s = format (s, "description: %s\n", b->description);
+      s = format (s, "source: %s\n", b->src->name);
+      for (int i = 0; i < b->n_events; i++)
+	{
+	  perfmon_event_t *e = b->src->events + b->events[i];
+	  s = format (s, "event %u: %s\n", i, e->name);
+	}
+    }
+  else
+    s = format (s, "%-20s%-10s%-20s%s", b->name, bundle_type[b->type],
+		b->src->name, b->description);
+
+  return s;
+}
+
+static clib_error_t *
+show_perfmon_bundle_command_fn (vlib_main_t *vm, unformat_input_t *input,
+				vlib_cli_command_t *cmd)
+{
+  perfmon_main_t *pm = &perfmon_main;
+  unformat_input_t _line_input, *line_input = &_line_input;
+  perfmon_bundle_t *b = 0, **vb = 0;
+  int verbose = 0;
+
+  if (unformat_user (input, unformat_line_input, line_input))
+    {
+      while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT)
+	{
+	  if (unformat (line_input, "verbose"))
+	    verbose = 1;
+	  else if (unformat (line_input, "%U", unformat_perfmon_bundle_name,
+			     &b))
+	    vec_add (vb, &b, 1);
+	  else
+	    return clib_error_return (0, "unknown input `%U'",
+				      format_unformat_error, line_input);
+	}
+      unformat_free (line_input);
+    }
+
+  if (vb == 0)
+    {
+      char *key;
+      hash_foreach_mem (key, b, pm->bundle_by_name, vec_add (vb, &b, 1););
+    }
+  else
+    verbose = 1;
+
+  if (verbose == 0)
+    vlib_cli_output (vm, "%U\n", format_perfmon_bundle, 0, 0);
+
+  for (int i = 0; i < vec_len (vb); i++)
+    vlib_cli_output (vm, "%U\n", format_perfmon_bundle, vb[i], verbose);
+
+  vec_free (vb);
+  return 0;
+}
+
+VLIB_CLI_COMMAND (show_perfmon_bundle_command, static) = {
+  .path = "show perfmon bundle",
+  .short_help = "show perfmon bundle [<bundle-name>] [verbose]",
+  .function = show_perfmon_bundle_command_fn,
+  .is_mp_safe = 1,
+};
+
+u8 *
+format_perfmon_source (u8 *s, va_list *args)
+{
+  perfmon_source_t *src = va_arg (*args, perfmon_source_t *);
+  int verbose = va_arg (*args, int);
+
+  if (src == 0)
+    return format (s, "%-20s%-9s %s", "Name", "NumEvents", "Description");
+
+  if (verbose)
+    {
+      s = format (s, "name:        %s\n", src->name);
+      s = format (s, "description: %s\n", src->description);
+      s = format (s, "Events:\n");
+      for (int i = 0; i < src->n_events; i++)
+	{
+	  perfmon_event_t *e = src->events + i;
+	  s = format (s, "  %s", e->name);
+	  if (src->format_config)
+	    s = format (s, " (%U)\n", src->format_config, e->config);
+	  else
+	    s = format (s, " (0x%x)\n", e->config);
+	  if (e->description)
+	    s = format (s, "    %s\n", e->description);
+	}
+
+      if (src->instances_by_type)
+	{
+	  s = format (s, "Instances:\n");
+	  for (int i = 0; i < vec_len (src->instances_by_type); i++)
+	    {
+	      perfmon_instance_type_t *it;
+	      it = vec_elt_at_index (src->instances_by_type, i);
+	      if (vec_len (it->instances) == 0)
+		continue;
+	      s = format (s, "  %s:\n   ", it->name);
+	      for (int j = 0; j < vec_len (it->instances); j++)
+		{
+		  perfmon_instance_t *in = vec_elt_at_index (it->instances, j);
+		  s = format (s, " %s", in->name);
+		}
+	      s = format (s, "\n");
+	    }
+	}
+    }
+  else
+    s = format (s, "%-20s%9u %s", src->name, src->n_events, src->description);
+
+  return s;
+}
+
+static clib_error_t *
+show_perfmon_source_command_fn (vlib_main_t *vm, unformat_input_t *input,
+				vlib_cli_command_t *cmd)
+{
+  perfmon_main_t *pm = &perfmon_main;
+  unformat_input_t _line_input, *line_input = &_line_input;
+  perfmon_source_t *s = 0, **vs = 0;
+  int verbose = 0;
+
+  if (unformat_user (input, unformat_line_input, line_input))
+    {
+      while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT)
+	{
+	  if (unformat (line_input, "verbose"))
+	    verbose = 1;
+	  else if (unformat (line_input, "%U", unformat_perfmon_source_name,
+			     &s))
+	    vec_add (vs, &s, 1);
+	  else
+	    return clib_error_return (0, "unknown input `%U'",
+				      format_unformat_error, line_input);
+	}
+      unformat_free (line_input);
+    }
+
+  if (vs == 0)
+    {
+      char *key;
+      hash_foreach_mem (key, s, pm->source_by_name, vec_add (vs, &s, 1););
+    }
+  else
+    verbose = 1;
+
+  if (verbose == 0)
+    vlib_cli_output (vm, "%U\n", format_perfmon_source, 0, 0);
+
+  for (int i = 0; i < vec_len (vs); i++)
+    vlib_cli_output (vm, "%U\n", format_perfmon_source, vs[i], verbose);
+
+  vec_free (vs);
+  return 0;
+}
+
+VLIB_CLI_COMMAND (show_perfmon_source_command, static) = {
+  .path = "show perfmon source",
+  .short_help = "show perfmon source [<source-name>] [verbose]",
+  .function = show_perfmon_source_command_fn,
+  .is_mp_safe = 1,
+};
+
+static clib_error_t *
+show_perfmon_active_bundle_command_fn (vlib_main_t *vm,
+				       unformat_input_t *input,
+				       vlib_cli_command_t *cmd)
+{
+  perfmon_main_t *pm = &perfmon_main;
+
+  vlib_cli_output (vm, "%U\n", format_perfmon_bundle, pm->active_bundle, 1);
+
+  return 0;
+}
+
+VLIB_CLI_COMMAND (show_perfmon_active_bundle_command, static) = {
+  .path = "show perfmon active-bundle",
+  .short_help = "show perfmon active-bundle",
+  .function = show_perfmon_active_bundle_command_fn,
+  .is_mp_safe = 1,
+};
+
+static clib_error_t *
+show_perfmon_stats_command_fn (vlib_main_t *vm, unformat_input_t *input,
+			       vlib_cli_command_t *cmd)
+{
+  perfmon_main_t *pm = &perfmon_main;
+  perfmon_bundle_t *b = pm->active_bundle;
+  clib_error_t *err = 0;
+  table_t table = {}, *t = &table;
+  u32 n_instances;
+  perfmon_reading_t *r, *readings = 0;
+  perfmon_instance_type_t *it = pm->active_instance_type;
+  perfmon_instance_t *in;
+  u8 *s = 0;
+  int n_row = 0;
+
+  if (b == 0)
+    return clib_error_return (0, "no budle selected");
+
+  n_instances = vec_len (it->instances);
+  vec_validate (readings, n_instances - 1);
+
+  for (int i = 0; i < n_instances; i++)
+    {
+      in = vec_elt_at_index (it->instances, i);
+      r = vec_elt_at_index (readings, i);
+
+      if (read (pm->group_fds[i], r, (b->n_events + 3) * sizeof (u64)) == -1)
+	{
+	  err = clib_error_return_unix (0, "read");
+	  goto done;
+	}
+    }
+
+  table_format_title (t, "%s", b->description);
+
+  table_add_header_col (t, 0);
+  table_add_header_row (t, 0);
+
+  if (b->column_headers)
+    {
+      char **hdr = b->column_headers;
+      while (hdr[0])
+	table_format_cell (t, -1, n_row++, "%s", hdr++[0]);
+    }
+
+  int col = 0;
+  for (int i = 0; i < n_instances; i++)
+    {
+      in = vec_elt_at_index (it->instances, i);
+      r = vec_elt_at_index (readings, i);
+      table_format_cell (t, col, -1, "%s", in->name);
+      if (b->type == PERFMON_BUNDLE_TYPE_NODE)
+	{
+	  perfmon_thread_runtime_t *tr;
+	  tr = vec_elt_at_index (pm->thread_runtimes, i);
+	  for (int j = 0; j < tr->n_nodes; j++)
+	    if (tr->node_stats[j].n_calls)
+	      {
+		perfmon_node_stats_t ns;
+		table_format_cell (t, ++col, -1, "%U", format_vlib_node_name,
+				   vm, j);
+		table_set_cell_align (t, col, -1, TTAA_RIGHT);
+		table_set_cell_fg_color (t, col, -1, TTAC_CYAN);
+		clib_memcpy_fast (&ns, tr->node_stats + j, sizeof (ns));
+		for (int j = 0; j < n_row; j++)
+		  table_format_cell (t, col, j, "%U", b->format_fn, &ns, j);
+	      }
+	}
+      else
+	{
+	  for (int j = 0; j < n_row; j++)
+	    table_format_cell (t, i, j, "%U", b->format_fn, r, j);
+	}
+      col++;
+    }
+
+  vlib_cli_output (vm, "%U\n", format_table, t);
+  table_free (t);
+
+  if (b->footer)
+    vlib_cli_output (vm, "\n%s\n", b->footer);
+
+done:
+  vec_free (readings);
+  vec_free (s);
+  return err;
+}
+
+VLIB_CLI_COMMAND (show_perfmon_stats_command, static) = {
+  .path = "show perfmon statistics",
+  .short_help = "show perfmon statistics",
+  .function = show_perfmon_stats_command_fn,
+  .is_mp_safe = 1,
+};
+
+static clib_error_t *
+set_perfmon_bundle_command_fn (vlib_main_t *vm, unformat_input_t *input,
+			       vlib_cli_command_t *cmd)
+{
+  perfmon_main_t *pm = &perfmon_main;
+  unformat_input_t _line_input, *line_input = &_line_input;
+  perfmon_bundle_t *b = 0;
+
+  if (unformat_user (input, unformat_line_input, line_input) == 0)
+    return clib_error_return (0, "please specify bundle name");
+
+  while (unformat_check_input (line_input) != UNFORMAT_END_OF_INPUT)
+    {
+      if (unformat (line_input, "%U", unformat_perfmon_bundle_name, &b))
+	;
+      else
+	return clib_error_return (0, "unknown input '%U'",
+				  format_unformat_error, line_input);
+    }
+  unformat_free (line_input);
+
+  if (b == 0)
+    return clib_error_return (0, "please specify bundle name");
+
+  if (pm->is_running)
+    return clib_error_return (0, "please stop first");
+
+  return perfmon_set (vm, b);
+}
+
+VLIB_CLI_COMMAND (set_perfmon_bundle_command, static) = {
+  .path = "set perfmon bundle",
+  .short_help = "set perfmon bundle [<bundle-name>]",
+  .function = set_perfmon_bundle_command_fn,
+  .is_mp_safe = 1,
+};
+
+static clib_error_t *
+perfmon_reset_command_fn (vlib_main_t *vm, unformat_input_t *input,
+			  vlib_cli_command_t *cmd)
+{
+  perfmon_reset (vm);
+  return 0;
+}
+
+VLIB_CLI_COMMAND (perfmon_reset_command, static) = {
+  .path = "perfmon reset",
+  .short_help = "perfmon reset",
+  .function = perfmon_reset_command_fn,
+  .is_mp_safe = 1,
+};
+
+static clib_error_t *
+perfmon_start_command_fn (vlib_main_t *vm, unformat_input_t *input,
+			  vlib_cli_command_t *cmd)
+{
+  return perfmon_start (vm);
+}
+
+VLIB_CLI_COMMAND (perfmon_start_command, static) = {
+  .path = "perfmon start",
+  .short_help = "perfmon start",
+  .function = perfmon_start_command_fn,
+  .is_mp_safe = 1,
+};
+
+static clib_error_t *
+perfmon_stop_command_fn (vlib_main_t *vm, unformat_input_t *input,
+			 vlib_cli_command_t *cmd)
+{
+  return perfmon_stop (vm);
+}
+
+VLIB_CLI_COMMAND (perfmon_stop_command, static) = {
+  .path = "perfmon stop",
+  .short_help = "perfmon stop",
+  .function = perfmon_stop_command_fn,
+  .is_mp_safe = 1,
+};