Searched refs:thread_info (Results 1 – 3 of 3) sorted by relevance
| /spdk/module/scheduler/dynamic/ |
| H A D | scheduler_dynamic.c | 43 _get_thread_load(struct spdk_scheduler_thread_info *thread_info) in _get_thread_load()
47 busy = thread_info->current_stats.busy_tsc; in _get_thread_load()
48 idle = thread_info->current_stats.idle_tsc; in _get_thread_load()
54 typedef void (*_foreach_fn)(struct spdk_scheduler_thread_info *thread_info);
107 _move_thread(struct spdk_scheduler_thread_info *thread_info, uint32_t dst_core) in _move_thread()
110 struct core_stats *src = &g_cores[thread_info->lcore]; in _move_thread()
111 uint64_t busy_tsc = thread_info->current_stats.busy_tsc; in _move_thread()
115 SPDK_DTRACE_PROBE2(dynsched_move, thread_info, dst_core); in _move_thread()
150 thread_info->lcore = dst_core; in _is_core_at_limit()
181 _can_core_fit_thread(struct spdk_scheduler_thread_info *thread_info, uint32_ in _can_core_fit_thread()
42 _get_thread_load(struct spdk_scheduler_thread_info * thread_info) _get_thread_load() argument
102 _move_thread(struct spdk_scheduler_thread_info * thread_info,uint32_t dst_core) _move_thread() argument
176 _can_core_fit_thread(struct spdk_scheduler_thread_info * thread_info,uint32_t dst_core) _can_core_fit_thread() argument
211 _find_optimal_core(struct spdk_scheduler_thread_info * thread_info) _find_optimal_core() argument
291 _balance_idle(struct spdk_scheduler_thread_info * thread_info) _balance_idle() argument
301 _balance_active(struct spdk_scheduler_thread_info * thread_info) _balance_active() argument
[all...] |
| /spdk/app/spdk_top/ |
| H A D | spdk_top.c | 419 struct rpc_thread_info thread_info = {}; in rpc_decode_pollers_threads_array() local
434 SPDK_COUNTOF(rpc_thread_pollers_decoders), &thread_info); in rpc_decode_pollers_threads_array()
440 thread_name_length = strlen(thread_info.name); in rpc_decode_pollers_threads_array()
451 rc = rpc_decode_pollers_array(poller, out, &poller_count, thread_info.name, in rpc_decode_pollers_threads_array()
453 thread_info.id, poller_types[i]); in rpc_decode_pollers_threads_array()
467 free(thread_info.name); in rpc_decode_pollers_threads_array()
734 struct rpc_thread_info thread_info[RPC_MAX_THREADS], *thread; in get_thread_data() local
745 memset(thread_info, 0, sizeof(struct rpc_thread_info) * RPC_MAX_THREADS); in get_thread_data()
746 if (rpc_decode_threads_array(json_resp->result, thread_info, ¤t_threads_count)) { in get_thread_data()
749 free_rpc_threads_stats(&thread_info[i]); in get_thread_data()
[all …]
|
| /spdk/lib/event/ |
| H A D | reactor.c | 716 _threads_reschedule_thread(struct spdk_scheduler_thread_info *thread_info) in _reactors_scheduler_fini()
721 thread = spdk_thread_get_by_id(thread_info->thread_id); in _reactors_scheduler_fini()
729 lw_thread->lcore = thread_info->lcore; in _reactors_scheduler_update_core_mode()
737 struct spdk_scheduler_thread_info *thread_info; in _reactors_scheduler_update_core_mode()
743 thread_info = &core->thread_infos[j]; in _reactors_scheduler_update_core_mode()
744 if (thread_info->lcore != i) { in _reactors_scheduler_update_core_mode()
745 if (core->isolated || cores_info[thread_info->lcore].isolated) { in _reactors_scheduler_update_core_mode()
750 _threads_reschedule_thread(thread_info); in _reactors_scheduler_cancel()
677 _threads_reschedule_thread(struct spdk_scheduler_thread_info * thread_info) _threads_reschedule_thread() argument
698 struct spdk_scheduler_thread_info *thread_info; _threads_reschedule() local
|