37 #include <sys/types.h>
45 #include <qb/qblist.h>
46 #include <qb/qbipcs.h>
47 #include <qb/qbipc_common.h>
68 #define MAX_SCHEDMISS_EVENTS 10
70 static unsigned int highest_schedmiss_event;
72 #define SCHEDMISS_PREFIX "stats.schedmiss"
209 #define NUM_PG_STATS (sizeof(cs_pg_stats) / sizeof(struct cs_stats_conv))
210 #define NUM_SRP_STATS (sizeof(cs_srp_stats) / sizeof(struct cs_stats_conv))
211 #define NUM_KNET_STATS (sizeof(cs_knet_stats) / sizeof(struct cs_stats_conv))
212 #define NUM_KNET_HANDLE_STATS (sizeof(cs_knet_handle_stats) / sizeof(struct cs_stats_conv))
213 #define NUM_IPCSC_STATS (sizeof(cs_ipcs_conn_stats) / sizeof(struct cs_stats_conv))
214 #define NUM_IPCSG_STATS (sizeof(cs_ipcs_global_stats) / sizeof(struct cs_stats_conv))
230 struct qb_list_head
list;
247 *value_len = strlen((
char *)(stat_array) + conv->
offset)+1;
251 assert(value_len != NULL);
253 memcpy(
value, (
char *)(stat_array) + conv->
offset, *value_len);
257 static void stats_add_entry(
const char *key,
struct cs_stats_conv *cs_conv)
267 static void stats_rm_entry(
const char *key)
316 struct knet_link_status link_status;
319 struct knet_handle_stats knet_handle_stats;
325 unsigned int sm_event;
335 switch (statinfo->
type) {
338 stats_map_set_value(statinfo, pg_stats,
value, value_len,
type);
342 stats_map_set_value(statinfo, pg_stats->
srp,
value, value_len,
type);
344 case STAT_KNET_HANDLE:
349 stats_map_set_value(statinfo, &knet_handle_stats,
value, value_len,
type);
352 if (sscanf(key_name,
"stats.knet.node%d.link%d", &
nodeid, &link_no) != 2) {
357 if (nodeid <= 0 || nodeid > KNET_MAX_HOST ||
358 link_no < 0 || link_no > KNET_MAX_LINK) {
367 stats_map_set_value(statinfo, &link_status,
value, value_len,
type);
370 if (sscanf(key_name,
"stats.ipcs.service%d.%d.%p", &service_id, &pid, &conn_ptr) != 3) {
388 sm_type = strrchr(key_name,
'.');
389 if (sm_type == NULL) {
394 if (strcmp(sm_type,
"timestamp") == 0) {
395 memcpy(
value, &schedmiss_event[sm_event].timestamp,
sizeof(uint64_t));
396 *value_len =
sizeof(uint64_t);
399 if (strcmp(sm_type,
"delay") == 0) {
400 memcpy(
value, &schedmiss_event[sm_event].delay,
sizeof(
float));
401 *value_len =
sizeof(float);
411 static void schedmiss_clear_stats(
void)
417 if (i < highest_schedmiss_event) {
419 stats_rm_entry(
param);
421 stats_rm_entry(
param);
423 schedmiss_event[i].
timestamp = (uint64_t)0LL;
424 schedmiss_event[i].
delay = 0.0f;
426 highest_schedmiss_event = 0;
438 schedmiss_event[i+1].
delay = schedmiss_event[i].
delay;
442 schedmiss_event[0].
timestamp = timestamp;
443 schedmiss_event[0].
delay = delay;
451 highest_schedmiss_event++;
456 #define STATS_CLEAR "stats.clear."
457 #define STATS_CLEAR_KNET "stats.clear.knet"
458 #define STATS_CLEAR_IPC "stats.clear.ipc"
459 #define STATS_CLEAR_TOTEM "stats.clear.totem"
460 #define STATS_CLEAR_ALL "stats.clear.all"
461 #define STATS_CLEAR_SCHEDMISS "stats.clear.schedmiss"
483 schedmiss_clear_stats();
489 schedmiss_clear_stats();
520 return (qb_map_pref_iter_create(
stats_map, prefix));
529 res = qb_map_iter_next(iter, (
void **)&item);
533 stats_map_set_value(item->cs_conv, NULL, NULL, value_len,
type);
540 qb_map_iter_free(iter);
547 struct qb_list_head *iter;
555 qb_list_for_each(iter, &stats_tracker_list_head) {
569 old_val.
len = new_val.
len = value_len;
582 static void stats_map_notify_fn(uint32_t event,
char *key,
void *old_value,
void *
value,
void *
user_data)
589 if (
value == NULL && old_value == NULL) {
598 new_val.
data = new_value;
602 &new_val.type) !=
CS_OK) {
610 memcpy(&old_val, &new_val,
sizeof(new_val));
645 tracker->
events = track_type;
677 qb_list_add (&tracker->
list, &stats_tracker_list_head);
691 tracker->
key_name, stats_map_notify_fn,
698 qb_list_del(&tracker->
list);
730 stats_rm_entry(
param);
765 stats_rm_entry(
param);