1 /* SPDX-License-Identifier: Apache-2.0
2 * Copyright(c) 2022 Cisco Systems, Inc.
6 #include <vlib/unix/unix.h>
7 #include <vlib/stats/stats.h>
23 [NODE_CLOCKS] = { .name = "clocks" },
24 [NODE_VECTORS] = { .name = "vectors" },
25 [NODE_CALLS] = { .name = "calls" },
26 [NODE_SUSPENDS] = { .name = "suspends" },
32 u32 symlinks[N_NODE_COUNTERS];
35 static vlib_stats_string_vector_t node_names = 0;
38 update_node_counters (vlib_stats_segment_t *sm)
40 clib_bitmap_t *bmp = 0;
41 vlib_main_t **stat_vms = 0;
42 vlib_node_t ***node_dups = 0;
46 vlib_node_get_nodes (0 /* vm, for barrier sync */,
47 (u32) ~0 /* all threads */, 1 /* include stats */,
48 0 /* barrier sync */, &node_dups, &stat_vms);
50 n_nodes = vec_len (node_dups[0]);
52 vec_validate (node_data, n_nodes - 1);
54 for (i = 0; i < n_nodes; i++)
55 if (vec_is_equal (node_data[i].name, node_dups[0][i]) == 0)
56 bmp = clib_bitmap_set (bmp, i, 1);
60 u32 last_thread = vlib_get_n_threads ();
61 vlib_stats_segment_lock ();
62 clib_bitmap_foreach (i, bmp)
64 if (node_data[i].name)
66 vec_free (node_data[i].name);
67 for (j = 0; j < ARRAY_LEN (node_data->symlinks); j++)
68 vlib_stats_remove_entry (node_data[i].symlinks[j]);
71 /* We can't merge the loops because a node index corresponding to a given
72 * node name can change between 2 updates. Otherwise, we could add
73 * already existing symlinks or delete valid ones.
75 clib_bitmap_foreach (i, bmp)
77 vlib_node_t *n = node_dups[0][i];
78 node_data[i].name = vec_dup (n->name);
79 vlib_stats_set_string_vector (&node_names, n->index, "%v", n->name);
81 for (int j = 0; j < ARRAY_LEN (node_counters); j++)
83 vlib_stats_validate (node_counters[j].entry_index, last_thread,
85 node_data[i].symlinks[j] = vlib_stats_add_symlink (
86 node_counters[j].entry_index, n->index, "/nodes/%U/%s",
87 format_vlib_stats_symlink, n->name, node_counters[j].name);
88 ASSERT (node_data[i].symlinks[j] != CLIB_U32_MAX);
91 vlib_stats_segment_unlock ();
95 for (j = 0; j < vec_len (node_dups); j++)
97 vlib_node_t **nodes = node_dups[j];
99 for (i = 0; i < vec_len (nodes); i++)
101 counter_t **counters;
103 vlib_node_t *n = nodes[i];
105 counters = vlib_stats_get_entry_data_pointer (
106 node_counters[NODE_CLOCKS].entry_index);
108 c[n->index] = n->stats_total.clocks - n->stats_last_clear.clocks;
110 counters = vlib_stats_get_entry_data_pointer (
111 node_counters[NODE_VECTORS].entry_index);
113 c[n->index] = n->stats_total.vectors - n->stats_last_clear.vectors;
115 counters = vlib_stats_get_entry_data_pointer (
116 node_counters[NODE_CALLS].entry_index);
118 c[n->index] = n->stats_total.calls - n->stats_last_clear.calls;
120 counters = vlib_stats_get_entry_data_pointer (
121 node_counters[NODE_SUSPENDS].entry_index);
123 c[n->index] = n->stats_total.suspends - n->stats_last_clear.suspends;
125 vec_free (node_dups[j]);
127 vec_free (node_dups);
132 do_stat_segment_updates (vlib_main_t *vm, vlib_stats_segment_t *sm)
134 if (sm->node_counters_enabled)
135 update_node_counters (sm);
137 vlib_stats_collector_t *c;
138 pool_foreach (c, sm->collectors)
140 vlib_stats_collector_data_t data = {
141 .entry_index = c->entry_index,
142 .vector_index = c->vector_index,
143 .private_data = c->private_data,
144 .entry = sm->directory_vector + c->entry_index,
149 /* Heartbeat, so clients detect we're still here */
150 sm->directory_vector[STAT_COUNTER_HEARTBEAT].value++;
154 stat_segment_collector_process (vlib_main_t *vm, vlib_node_runtime_t *rt,
157 vlib_stats_segment_t *sm = vlib_stats_get_segment ();
159 if (sm->node_counters_enabled)
161 node_names = vlib_stats_add_string_vector ("/sys/node/names");
164 for (int x = 0; x < ARRAY_LEN (node_counters); x++)
166 node_counters[x].entry_index = vlib_stats_add_counter_vector (
167 "/sys/node/%s", node_counters[x].name);
168 ASSERT (node_counters[x].entry_index != CLIB_U32_MAX);
172 sm->directory_vector[STAT_COUNTER_BOOTTIME].value = unix_time_now ();
176 do_stat_segment_updates (vm, sm);
177 vlib_process_suspend (vm, sm->update_interval);
179 return 0; /* or not */
182 VLIB_REGISTER_NODE (stat_segment_collector, static) = {
183 .function = stat_segment_collector_process,
184 .name = "statseg-collector-process",
185 .type = VLIB_NODE_TYPE_PROCESS,