| /spdk/module/bdev/ocf/ |
| H A D | stats.c | 10 vbdev_ocf_stats_get(ocf_cache_t cache, char *core_name, struct vbdev_ocf_stats *stats) in vbdev_ocf_stats_get() argument 20 return ocf_stats_collect_core(core, &stats->usage, &stats->reqs, &stats->blocks, &stats->errors); in vbdev_ocf_stats_get() 39 #define WJSON_STAT(w, stats, group, field, units) \ argument 41 spdk_json_write_named_uint64(w, "count", stats->group.field.value); \ 43 stats->group.field.fraction / 100, stats->group.field.fraction % 100); \ 48 vbdev_ocf_stats_write_json(struct spdk_json_write_ctx *w, struct vbdev_ocf_stats *stats) in vbdev_ocf_stats_write_json() argument 53 WJSON_STAT(w, stats, usage, occupancy, "4KiB blocks"); in vbdev_ocf_stats_write_json() 54 WJSON_STAT(w, stats, usage, free, "4KiB blocks"); in vbdev_ocf_stats_write_json() 55 WJSON_STAT(w, stats, usage, clean, "4KiB blocks"); in vbdev_ocf_stats_write_json() 56 WJSON_STAT(w, stats, usage, dirty, "4KiB blocks"); in vbdev_ocf_stats_write_json() [all …]
|
| H A D | stats.h | 19 int vbdev_ocf_stats_get(ocf_cache_t cache, char *core_name, struct vbdev_ocf_stats *stats); 22 void vbdev_ocf_stats_write_json(struct spdk_json_write_ctx *w, struct vbdev_ocf_stats *stats);
|
| /spdk/test/vhost/integrity/ |
| H A D | integrity_vm.sh | 72 stats=($(cat /sys/block/$dev/stat)) 76 ${stats[0]} ${stats[1]} ${stats[2]} ${stats[3]} 78 ${stats[4]} ${stats[5]} ${stats[6]} ${stats[7]} 80 ${stats[8]} ${stats[9]} ${stats[10]}
|
| /spdk/lib/rdma_provider/ |
| H A D | common.c | 28 if (init_attr->stats) { in spdk_rdma_provider_srq_create() 29 rdma_srq->stats = init_attr->stats; in spdk_rdma_provider_srq_create() 32 rdma_srq->stats = calloc(1, sizeof(*rdma_srq->stats)); in spdk_rdma_provider_srq_create() 33 if (!rdma_srq->stats) { in spdk_rdma_provider_srq_create() 42 if (!init_attr->stats) { in spdk_rdma_provider_srq_create() 43 free(rdma_srq->stats); in spdk_rdma_provider_srq_create() 74 free(rdma_srq->stats); in spdk_rdma_provider_srq_destroy() 113 return rdma_queue_recv_wrs(&rdma_srq->recv_wrs, first, rdma_srq->stats); in spdk_rdma_provider_srq_queue_recv_wrs() 129 rdma_srq->stats->doorbell_updates++; in spdk_rdma_provider_srq_flush_recv_wrs() 141 return rdma_queue_recv_wrs(&spdk_rdma_qp->recv_wrs, first, &spdk_rdma_qp->stats->recv); in spdk_rdma_provider_qp_queue_recv_wrs() [all …]
|
| H A D | rdma_provider_verbs.c | 43 if (qp_attr->stats) { in spdk_rdma_provider_qp_create() 44 spdk_rdma_qp->stats = qp_attr->stats; in spdk_rdma_provider_qp_create() 47 spdk_rdma_qp->stats = calloc(1, sizeof(*spdk_rdma_qp->stats)); in spdk_rdma_provider_qp_create() 48 if (!spdk_rdma_qp->stats) { in spdk_rdma_provider_qp_create() 105 free(spdk_rdma_qp->stats); in spdk_rdma_provider_qp_disconnect() 146 spdk_rdma_qp->stats->send.num_submitted_wrs++; in spdk_rdma_provider_qp_queue_send_wrs() 150 spdk_rdma_qp->stats->send.num_submitted_wrs++; 180 spdk_rdma_qp->stats [all...] |
| H A D | rdma_provider_mlx5_dv.c | 103 if (qp_attr->stats) { in spdk_rdma_provider_qp_create() 104 mlx5_qp->common.stats = qp_attr->stats; in spdk_rdma_provider_qp_create() 107 mlx5_qp->common.stats = calloc(1, sizeof(*mlx5_qp->common.stats)); in spdk_rdma_provider_qp_create() 108 if (!mlx5_qp->common.stats) { in spdk_rdma_provider_qp_create() 218 free(mlx5_qp->common.stats); in spdk_rdma_provider_qp_disconnect() 307 spdk_rdma_qp->stats->send.num_submitted_wrs++; in spdk_rdma_provider_qp_flush_send_wrs() 337 spdk_rdma_qp->stats->send.doorbell_updates++;
|
| /spdk/test/bdev/ |
| H A D | chaining.sh | 20 declare -A stats 51 stats["sequence_executed"]=$(get_stat sequence_executed) 52 stats["encrypt_executed"]=$(get_stat executed encrypt) 53 stats["decrypt_executed"]=$(get_stat executed decrypt) 54 stats["copy_executed"]=$(get_stat executed copy) 90 (($(get_stat sequence_executed) == stats["sequence_executed"] + 1)) 91 (($(get_stat executed encrypt) == stats["encrypt_executed"] + 2)) 92 (($(get_stat executed decrypt) == stats["decrypt_executed"])) 95 (($(get_stat executed copy) == stats["copy_executed"])) 100 (($(get_stat sequence_executed) == stats["sequence_executed"] + 1)) [all …]
|
| /spdk/test/nvmf/target/ |
| H A D | rpc.sh | 26 stats=$($rpc_py nvmf_get_stats) 28 (($(jcount '.poll_groups[].name' <<< "$stats") == 4)) 29 [[ $(jq '.poll_groups[0].transports[0]' <<< "$stats") == null ]] 33 stats=$($rpc_py nvmf_get_stats) 35 (($(jsum '.poll_groups[].admin_qpairs' <<< "$stats") == 0)) 36 (($(jsum '.poll_groups[].io_qpairs' <<< "$stats") == 0)) 40 (($(jcount '.poll_groups[0].transports[].trtype' <<< "$stats") == 1)) 41 transport_type=$(jq -r '.poll_groups[0].transports[0].trtype' <<< "$stats") 43 (($(jcount '.poll_groups[0].transports[0].devices[].name' <<< "$stats") > 0)) 110 stats=$($rpc_py nvmf_get_stats) [all …]
|
| /spdk/test/unit/lib/event/reactor.c/ |
| H A D | reactor_ut.c | 343 struct spdk_thread_stats stats; in test_reactor_stats() local 403 CU_ASSERT(spdk_thread_get_stats(&stats) == 0); in test_reactor_stats() 404 CU_ASSERT(stats.busy_tsc == 100); in test_reactor_stats() 405 CU_ASSERT(stats.idle_tsc == 0); in test_reactor_stats() 408 CU_ASSERT(spdk_thread_get_stats(&stats) == 0); in test_reactor_stats() 409 CU_ASSERT(stats.busy_tsc == 0); in test_reactor_stats() 410 CU_ASSERT(stats.idle_tsc == 300); in test_reactor_stats() 432 CU_ASSERT(spdk_thread_get_stats(&stats) == 0); in test_reactor_stats() 433 CU_ASSERT(stats.busy_tsc == 100); in test_reactor_stats() 434 CU_ASSERT(stats in test_reactor_stats() 541 struct spdk_thread_stats stats; test_scheduler() local 736 struct spdk_thread_stats stats; test_bind_thread() local [all...] |
| /spdk/scripts/bpf/ |
| H A D | sched.bt | 31 $stats = (struct spdk_thread_stats *)$info->current_stats; 32 if ($stats->busy_tsc > 0) { 33 $thread_pct = $stats->busy_tsc * 100 / ($stats->busy_tsc + $stats->idle_tsc); 34 …$core_pct = $stats->busy_tsc * 100 / (@cores_busy_tsc[$info->lcore] + @cores_idle_tsc[$info->lcore…
|
| /spdk/lib/trace_parser/ |
| H A D | trace.cpp | 165 object_stats *stats; in next_entry() 178 stats = &_stats[tpoint->object_type]; in next_entry() 181 stats->index[entry->object_id] = stats->counter++; in next_entry() 182 stats->start[entry->object_id] = entry->tsc; in next_entry() 186 if (spdk_likely(stats->start.find(entry->object_id) != stats->start.end())) { in next_entry() 187 pe->object_index = stats->index[entry->object_id]; in next_entry() 188 pe->object_start = stats->start[entry->object_id]; in next_entry() 209 stats in next_entry() 164 object_stats *stats; next_entry() local [all...] |
| /spdk/module/bdev/ftl/ |
| H A D | bdev_ftl_rpc.c | 213 struct ftl_stats *stats = &ftl_stats_ctx->ftl_stats; in _rpc_bdev_ftl_get_stats() 254 spdk_json_write_named_uint64(w, "ios", stats->entries[i].read.ios); in _rpc_bdev_ftl_get_stats() 255 spdk_json_write_named_uint64(w, "blocks", stats->entries[i].read.blocks); in _rpc_bdev_ftl_get_stats() 257 spdk_json_write_named_uint64(w, "media", stats->entries[i].read.errors.media); in _rpc_bdev_ftl_get_stats() 258 spdk_json_write_named_uint64(w, "crc", stats->entries[i].read.errors.crc); in _rpc_bdev_ftl_get_stats() 259 spdk_json_write_named_uint64(w, "other", stats->entries[i].read.errors.other); in _rpc_bdev_ftl_get_stats() 264 spdk_json_write_named_uint64(w, "ios", stats->entries[i].write.ios); in _rpc_bdev_ftl_get_stats() 265 spdk_json_write_named_uint64(w, "blocks", stats->entries[i].write.blocks); in _rpc_bdev_ftl_get_stats() 267 spdk_json_write_named_uint64(w, "media", stats->entries[i].write.errors.media); in _rpc_bdev_ftl_get_stats() 268 spdk_json_write_named_uint64(w, "other", stats in _rpc_bdev_ftl_get_stats() 205 struct ftl_stats *stats = &ftl_stats_ctx->ftl_stats; _rpc_bdev_ftl_get_stats() local [all...] |
| /spdk/test/dma/test_dma/ |
| H A D | test_dma.c | 49 struct dma_test_task_stats stats; 120 if (!task->stats.io_completed) { in print_total_stats() 123 task_iops = (double)task->stats.io_completed * SPDK_SEC_TO_USEC / test_time_usec; in print_total_stats() 125 task_avg_lat = (double)task->stats.total_tsc / task->stats.io_completed * SPDK_SEC_TO_USEC / in print_total_stats() 127 task_min_lat = (double)task->stats.min_tsc * SPDK_SEC_TO_USEC / tsc_rate; in print_total_stats() 128 task_max_lat = (double)task->stats.max_tsc * SPDK_SEC_TO_USEC / tsc_rate; in print_total_stats() 132 total_io_completed += task->stats.io_completed; in print_total_stats() 133 total_tsc += task->stats.total_tsc; in print_total_stats() 161 io_last_sec += task->stats in print_periodic_stats() 43 struct dma_test_task_stats stats; global() member [all...] |
| /spdk/test/scheduler/ |
| H A D | common.sh | 433 # Gather busy/idle stats since this function was last called 448 # Gather busy/idle stats since application start 458 local thread threads stats 460 stats=$(rpc_cmd thread_get_stats | jq -r '.threads[]') 461 threads=($(jq -r '.id' <<< "$stats")) 464 eval "${list_busy}[$thread]=\$(jq -r \"select(.id == $thread) | .busy\" <<< \$stats)" 465 eval "${list_idle}[$thread]=\$(jq -r \"select(.id == $thread) | .idle\" <<< \$stats)" 466 thread_map[thread]=$(jq -r "select(.id == $thread) | .name" <<< "$stats") 472 local stat=$2 stats astats 505 local stats sta [all...] |
| H A D | cgroups.sh | 195 local flags flags_map=() comm stats tflags 202 stats=(${comm/*) /}) tflags=${stats[6]}
|
| /spdk/scripts/ |
| H A D | dpdk_mem_info.py | 278 with open(stat_path, "r") as stats: 280 line = stats.readline() 287 line = stats.readline() 294 line = stats.readline() 306 line = stats.readline() 313 line = stats.readline() 335 line = stats.readline() 343 line = stats.readline() 347 line = stats.readline() 349 line = stats.readline() [all …]
|
| /spdk/test/unit/lib/nvme/nvme_poll_group.c/ |
| H A D | nvme_poll_group_ut.c | 66 struct spdk_nvme_transport_poll_group_stat **stats) in nvme_transport_poll_group_free_stats() 68 *stats = calloc(1, sizeof(**stats)); 69 SPDK_CU_ASSERT_FATAL(*stats != NULL); 70 (*stats)->trtype = nvme_transport_get_trtype(NULL); in unit_test_disconnected_qpair_cb() 77 struct spdk_nvme_transport_poll_group_stat *stats) in nvme_get_first_transport() 79 free(stats); in nvme_get_first_transport() 557 struct spdk_nvme_poll_group_stat *stats = NULL; 567 rc = spdk_nvme_poll_group_get_stats(&group, &stats); 569 CU_ASSERT(stats 53 nvme_transport_poll_group_get_stats(struct spdk_nvme_transport_poll_group * tgroup,struct spdk_nvme_transport_poll_group_stat ** stats) nvme_transport_poll_group_get_stats() argument 64 nvme_transport_poll_group_free_stats(struct spdk_nvme_transport_poll_group * tgroup,struct spdk_nvme_transport_poll_group_stat * stats) nvme_transport_poll_group_free_stats() argument 458 struct spdk_nvme_poll_group_stat *stats = NULL; test_spdk_nvme_poll_group_get_free_stats() local [all...] |
| /spdk/lib/ftl/ |
| H A D | ftl_core.c | 119 struct ftl_stats *stats = &dev->stats; in ftl_apply_limits() local 129 stats->limits[i]++; in ftl_apply_limits() 747 uint64_t io_activity_total_old = dev->stats.io_activity_total; in ftl_core_poller() 761 if (io_activity_total_old != dev->stats.io_activity_total) { in ftl_core_poller() 822 struct ftl_stats_entry *stats_entry = &dev->stats.entries[type]; in ftl_stats_bdev_io_completed() 862 struct ftl_stats_entry *stats_entry = &dev->stats.entries[type]; in ftl_stats_crc_error() 870 struct ftl_stats *stats; member 881 stats_ctx->cb_fn(stats_ctx->stats, stats_ctx->cb_arg); in _ftl_get_stats_cb() 890 *stats_ctx->stats in _ftl_get_stats() 898 spdk_ftl_get_stats(struct spdk_ftl_dev * dev,struct ftl_stats * stats,spdk_ftl_stats_fn cb_fn,void * cb_arg) spdk_ftl_get_stats() argument [all...] |
| H A D | ftl_debug.c | 203 write_user = dev->stats.entries[FTL_STATS_TYPE_CMP].write.blocks; in ftl_dev_dump_stats() 205 dev->stats.entries[FTL_STATS_TYPE_GC].write.blocks + in ftl_dev_dump_stats() 206 dev->stats.entries[FTL_STATS_TYPE_MD_BASE].write.blocks; in ftl_dev_dump_stats() 220 FTL_NOTICELOG(dev, " %5s: %"PRIu64"\n", limits[i], dev->stats.limits[i]); in ftl_dev_dump_stats()
|
| /spdk/lib/nvme/ |
| H A D | nvme_rdma.c | 138 struct nvme_rdma_poller_stats stats; member 739 attr.stats = rqpair->poller ? &rqpair->poller->stats.rdma_stats : NULL; in nvme_rdma_qpair_init() 2541 rqpair->poller->stats.queued_requests++; in nvme_rdma_process_send_completion() 3220 srq_init_attr.stats = &poller->stats.rdma_stats.recv; in nvme_rdma_poll_group_get_stats() 3511 poller->stats.polls++; 3518 poller->stats.idle_polls++; 3526 poller->stats.completions += rdma_completions; 3568 struct spdk_nvme_transport_poll_group_stat *stats; 3198 struct spdk_nvme_transport_poll_group_stat *stats; nvme_rdma_poll_group_get_stats() local 3250 nvme_rdma_poll_group_free_stats(struct spdk_nvme_transport_poll_group * tgroup,struct spdk_nvme_transport_poll_group_stat * stats) nvme_rdma_poll_group_free_stats() argument [all...] |
| H A D | nvme_poll_group.c | 459 struct spdk_nvme_poll_group_stat **stats) 469 assert(stats); 503 *stats = result; 229 spdk_nvme_poll_group_get_stats(struct spdk_nvme_poll_group * group,struct spdk_nvme_poll_group_stat ** stats) spdk_nvme_poll_group_get_stats() argument
|
| H A D | nvme_tcp.c | 71 struct spdk_nvme_tcp_stat stats; 88 struct spdk_nvme_tcp_stat *stats; 398 free(tqpair->stats); in nvme_tcp_ctrlr_delete_io_qpair() 515 tqpair->stats->submitted_requests++; in _tcp_write_pdu() 971 tqpair->stats->queued_requests++; in nvme_tcp_qpair_capsule_cmd_send() 2175 pgroup->stats.nvme_completions += num_completions; 2394 tqpair->stats = &tgroup->stats; in nvme_tcp_ctrlr_connect_qpair_poll() 2397 /* When resetting a controller, we disconnect adminq and then reconnect. The stats in nvme_tcp_ctrlr_connect_qpair_poll() 2401 if (tqpair->stats in nvme_tcp_ctrlr_connect_qpair_poll() 61 struct spdk_nvme_tcp_stat stats; global() member 78 struct spdk_nvme_tcp_stat *stats; global() member 2961 struct spdk_nvme_transport_poll_group_stat *stats; nvme_tcp_poll_group_get_stats() local 2985 nvme_tcp_poll_group_free_stats(struct spdk_nvme_transport_poll_group * tgroup,struct spdk_nvme_transport_poll_group_stat * stats) nvme_tcp_poll_group_free_stats() argument [all...] |
| /spdk/lib/thread/ |
| H A D | iobuf.c | 715 pool->stats.cache++; 728 pool->stats.retry++; 734 pool->stats.main++; 847 it->small_pool.cache += cache->stats.cache; 848 it->small_pool.main += cache->stats.main; 849 it->small_pool.retry += cache->stats.retry; 852 it->large_pool.cache += cache->stats.cache; 853 it->large_pool.main += cache->stats.main; 854 it->large_pool.retry += cache->stats.retry;
|
| /spdk/lib/event/ |
| H A D | app_rpc.c | 174 struct spdk_thread_stats stats; in _rpc_thread_get_stats() local 194 if (0 == spdk_thread_get_stats(&stats)) { in _rpc_thread_get_stats() 201 spdk_json_write_named_uint64(ctx->w, "busy", stats.busy_tsc); in _rpc_thread_get_stats() 202 spdk_json_write_named_uint64(ctx->w, "idle", stats.idle_tsc); in _rpc_thread_get_stats() 228 struct spdk_poller_stats stats; in rpc_get_poller() local 232 spdk_poller_get_stats(poller, &stats); in rpc_get_poller() 238 spdk_json_write_named_uint64(w, "run_count", stats.run_count); in rpc_get_poller() 239 spdk_json_write_named_uint64(w, "busy_count", stats.busy_count); in rpc_get_poller()
|
| /spdk/test/unit/lib/nvme/nvme_tcp.c/ |
| H A D | nvme_tcp_ut.c | 631 struct spdk_nvme_tcp_stat stats = {}; in test_nvme_tcp_qpair_capsule_cmd_send() 645 tqpair.stats = &stats; in test_nvme_tcp_qpair_capsule_cmd_send() 736 struct spdk_nvme_tcp_stat stats = {}; in test_nvme_tcp_qpair_write_pdu() 766 tqpair.stats = &stats; in test_nvme_tcp_qpair_write_pdu() 874 struct spdk_nvme_tcp_stat stats = {}; in test_nvme_tcp_qpair_send_h2c_term_req() 881 tqpair.stats = &stats; in test_nvme_tcp_qpair_send_h2c_term_req() 906 struct spdk_nvme_tcp_stat stats in test_nvme_tcp_pdu_ch_handle() 630 struct spdk_nvme_tcp_stat stats = {}; test_nvme_tcp_qpair_capsule_cmd_send() local 735 struct spdk_nvme_tcp_stat stats = {}; test_nvme_tcp_qpair_write_pdu() local 873 struct spdk_nvme_tcp_stat stats = {}; test_nvme_tcp_qpair_send_h2c_term_req() local 905 struct spdk_nvme_tcp_stat stats = {}; test_nvme_tcp_pdu_ch_handle() local 1091 struct spdk_nvme_tcp_stat stats = {}; test_nvme_tcp_qpair_icreq_send() local 1125 struct spdk_nvme_tcp_stat stats = {}; test_nvme_tcp_c2h_payload_handle() local 1218 struct spdk_nvme_tcp_stat stats = {}; test_nvme_tcp_icresp_handle() local 1284 struct spdk_nvme_tcp_stat stats = {}; test_nvme_tcp_pdu_payload_handle() local 1342 struct spdk_nvme_tcp_stat stats = {}; test_nvme_tcp_capsule_resp_hdr_handle() local [all...] |