X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=src%2Fvpp%2Fstats%2Fstat_segment.h;h=f5862a684e42a0d7d68d5cae43f69594bd88337f;hb=ed999e3b8159eb5b584354af95686a84fb012e05;hp=eae6902dc75ad0a09513d7f1025fbd14a60216c9;hpb=0f09a828ad2dc53d4f1e69de536f3104eaccc4b0;p=vpp.git diff --git a/src/vpp/stats/stat_segment.h b/src/vpp/stats/stat_segment.h index eae6902dc75..f5862a684e4 100644 --- a/src/vpp/stats/stat_segment.h +++ b/src/vpp/stats/stat_segment.h @@ -22,53 +22,45 @@ typedef enum { - STAT_COUNTER_VECTOR_RATE = 0, - STAT_COUNTER_NUM_WORKER_THREADS, - STAT_COUNTER_VECTOR_RATE_PER_WORKER, - STAT_COUNTER_INPUT_RATE, - STAT_COUNTER_LAST_UPDATE, - STAT_COUNTER_LAST_STATS_CLEAR, - STAT_COUNTER_HEARTBEAT, - STAT_COUNTER_NODE_CLOCKS, - STAT_COUNTER_NODE_VECTORS, - STAT_COUNTER_NODE_CALLS, - STAT_COUNTER_NODE_SUSPENDS, - STAT_COUNTER_INTERFACE_NAMES, - STAT_COUNTER_NODE_NAMES, - STAT_COUNTER_MEM_STATSEG_TOTAL, - STAT_COUNTER_MEM_STATSEG_USED, - STAT_COUNTERS + STAT_COUNTER_NUM_WORKER_THREADS = 0, + STAT_COUNTER_INPUT_RATE, + STAT_COUNTER_LAST_UPDATE, + STAT_COUNTER_LAST_STATS_CLEAR, + STAT_COUNTER_HEARTBEAT, + STAT_COUNTER_NODE_CLOCKS, + STAT_COUNTER_NODE_VECTORS, + STAT_COUNTER_NODE_CALLS, + STAT_COUNTER_NODE_SUSPENDS, + STAT_COUNTER_INTERFACE_NAMES, + STAT_COUNTER_NODE_NAMES, + STAT_COUNTERS } stat_segment_counter_t; -#define foreach_stat_segment_counter_name \ - _(VECTOR_RATE, SCALAR_INDEX, vector_rate, /sys) \ - _(VECTOR_RATE_PER_WORKER, COUNTER_VECTOR_SIMPLE, \ - vector_rate_per_worker, /sys) \ - _(NUM_WORKER_THREADS, SCALAR_INDEX, num_worker_threads, /sys) \ - _(INPUT_RATE, SCALAR_INDEX, input_rate, /sys) \ - _(LAST_UPDATE, SCALAR_INDEX, last_update, /sys) \ - _(LAST_STATS_CLEAR, SCALAR_INDEX, last_stats_clear, /sys) \ - _(HEARTBEAT, SCALAR_INDEX, heartbeat, /sys) \ - _(NODE_CLOCKS, COUNTER_VECTOR_SIMPLE, clocks, /sys/node) \ - _(NODE_VECTORS, COUNTER_VECTOR_SIMPLE, vectors, /sys/node) \ - _(NODE_CALLS, COUNTER_VECTOR_SIMPLE, calls, /sys/node) \ - _(NODE_SUSPENDS, COUNTER_VECTOR_SIMPLE, suspends, /sys/node) \ - _(INTERFACE_NAMES, NAME_VECTOR, names, /if) \ - _(NODE_NAMES, NAME_VECTOR, names, /sys/node) \ - _(MEM_STATSEG_TOTAL, SCALAR_INDEX, total, /mem/statseg) \ - _(MEM_STATSEG_USED, SCALAR_INDEX, used, /mem/statseg) +/* clang-format off */ +#define foreach_stat_segment_node_counter_name \ + _ (NODE_CLOCKS, COUNTER_VECTOR_SIMPLE, clocks, /sys/node) \ + _ (NODE_VECTORS, COUNTER_VECTOR_SIMPLE, vectors, /sys/node) \ + _ (NODE_CALLS, COUNTER_VECTOR_SIMPLE, calls, /sys/node) \ + _ (NODE_SUSPENDS, COUNTER_VECTOR_SIMPLE, suspends, /sys/node) + +#define foreach_stat_segment_counter_name \ + _ (NUM_WORKER_THREADS, SCALAR_INDEX, num_worker_threads, /sys) \ + _ (INPUT_RATE, SCALAR_INDEX, input_rate, /sys) \ + _ (LAST_UPDATE, SCALAR_INDEX, last_update, /sys) \ + _ (LAST_STATS_CLEAR, SCALAR_INDEX, last_stats_clear, /sys) \ + _ (HEARTBEAT, SCALAR_INDEX, heartbeat, /sys) \ + _ (INTERFACE_NAMES, NAME_VECTOR, names, /if) \ + _ (NODE_NAMES, NAME_VECTOR, names, /sys/node) \ + foreach_stat_segment_node_counter_name +/* clang-format on */ /* Default stat segment 32m */ #define STAT_SEGMENT_DEFAULT_SIZE (32<<20) /* Shared segment memory layout version */ -#define STAT_SEGMENT_VERSION 1 +#define STAT_SEGMENT_VERSION 2 -static inline uint64_t -stat_segment_offset (void *start, void *data) -{ - return (char *) data - (char *) start; -} +#define STAT_SEGMENT_INDEX_INVALID UINT32_MAX typedef void (*stat_segment_update_fn)(stat_segment_directory_entry_t * e, u32 i); @@ -86,14 +78,18 @@ typedef struct /* statistics segment */ uword *directory_vector_by_name; stat_segment_directory_entry_t *directory_vector; - u64 *error_vector; + volatile u64 **error_vector; u8 **interfaces; u8 **nodes; + /* Update interval */ + f64 update_interval; + clib_spinlock_t *stat_segment_lockp; clib_socket_t *socket; u8 *socket_name; ssize_t memory_size; + clib_mem_page_sz_t log2_page_sz; u8 node_counters_enabled; void *last; void *heap; @@ -112,5 +108,16 @@ stat_segment_register_state_counter(u8 *name, u32 *index); clib_error_t * stat_segment_deregister_state_counter(u32 index); void stat_segment_set_state_counter (u32 index, u64 value); +void stat_segment_poll_add (u32 vector_index, stat_segment_update_fn update_fn, + u32 caller_index, u32 interval); + +u32 stat_segment_new_entry (u8 *name, stat_directory_type_t t); +void vlib_stats_register_mem_heap (clib_mem_heap_t *heap); +void vlib_stat_segment_lock (void); +void vlib_stat_segment_unlock (void); +void vlib_stats_register_symlink (void *oldheap, u8 *name, u32 index1, + u32 index2, u8 lock); + +void stat_provider_register_vector_rate (u32 num_workers); #endif