| /spdk/test/common/lib/ |
| H A D | ut_multithread.c | 17 bool poll_thread(uintptr_t thread_id);
18 bool poll_thread_times(uintptr_t thread_id, uint32_t max_polls);
38 set_thread(uintptr_t thread_id) in set_thread() argument
40 g_ut_thread_id = thread_id; in set_thread()
41 if (thread_id == INVALID_THREAD) { in set_thread()
44 spdk_set_thread(g_ut_threads[thread_id].thread); in set_thread()
113 poll_thread_times(uintptr_t thread_id, uint32_t max_polls) in poll_thread_times() argument
116 struct ut_thread *thread = &g_ut_threads[thread_id]; in poll_thread_times()
124 return poll_thread(thread_id); in poll_thread_times()
126 assert(thread_id != (uintptr_t)INVALID_THREAD); in poll_thread_times()
[all …]
|
| /spdk/test/event/scheduler/ |
| H A D | scheduler.c | 56 rpc_scheduler_thread_create_cb(struct spdk_jsonrpc_request *request, uint64_t thread_id) in rpc_scheduler_thread_create_cb() argument
61 spdk_json_write_uint64(w, thread_id); in rpc_scheduler_thread_create_cb()
207 uint64_t thread_id; member
212 {"thread_id", offsetof(struct rpc_thread_set_active, thread_id), spdk_json_decode_uint64},
220 uint64_t thread_id; in rpc_scheduler_thread_set_active_cb() local
223 thread_id = spdk_thread_get_id(spdk_get_thread()); in rpc_scheduler_thread_set_active_cb()
227 if (spdk_thread_get_id(sched_thread->thread) == thread_id) { in rpc_scheduler_thread_set_active_cb()
265 thread = spdk_thread_get_by_id(req.thread_id); in rpc_scheduler_thread_set_active()
289 uint64_t thread_id; member
293 {"thread_id", offsetof(struct rpc_thread_delete, thread_id), spdk_json_decode_uint64},
[all …]
|
| H A D | scheduler.sh | 22 thread_id=$($rpc --plugin scheduler_plugin scheduler_thread_create -n half_active -a 0)
23 $rpc --plugin scheduler_plugin scheduler_thread_set_active $thread_id 50
25 thread_id=$($rpc --plugin scheduler_plugin scheduler_thread_create -n deleted -a 100)
26 $rpc --plugin scheduler_plugin scheduler_thread_delete $thread_id
|
| H A D | scheduler_plugin.py | 22 params = {'thread_id': args.thread_id, 'active': args.active}
27 params = {'thread_id': args.thread_id}
|
| /spdk/test/unit/lib/thread/iobuf.c/ |
| H A D | iobuf_ut.c | 20 uint32_t thread_id;
63 { .thread_id = 0, .module = "ut_module0", }, in iobuf()
64 { .thread_id = 0, .module = "ut_module0", }, in iobuf()
65 { .thread_id = 0, .module = "ut_module0", }, in iobuf()
66 { .thread_id = 0, .module = "ut_module0", }, in iobuf()
67 { .thread_id = 1, .module = "ut_module0", }, in iobuf()
68 { .thread_id = 1, .module = "ut_module0", }, in iobuf()
69 { .thread_id = 1, .module = "ut_module0", }, in iobuf()
70 { .thread_id = 1, .module = "ut_module0", }, in iobuf()
73 { .thread_id in iobuf()
19 uint32_t thread_id; global() member
[all...] |
| /spdk/test/rpc_plugins/ |
| H A D | scheduler_plugin.py | 22 params = {'thread_id': args.thread_id, 'active': args.active}
27 params = {'thread_id': args.thread_id}
|
| /spdk/app/spdk_top/ |
| H A D | spdk_top.c | 147 uint64_t thread_id; member
232 uint64_t thread_id; member
380 const char *thread_name, uint64_t thread_name_length, uint64_t thread_id, in rpc_decode_pollers_array() argument
386 out[*poller_count].thread_id = thread_id; in rpc_decode_pollers_array()
704 store_last_counters(uint64_t poller_id, uint64_t thread_id, uint64_t last_run_counter, in store_last_counters() argument
710 if ((history->poller_id == poller_id) && (history->thread_id == thread_id)) { in store_last_counters()
723 history->thread_id = thread_id; in store_last_counters()
806 get_last_run_counter(uint64_t poller_id, uint64_t thread_id) in get_last_run_counter() argument
811 if ((history->poller_id == poller_id) && (history->thread_id == thread_id)) { in get_last_run_counter()
820 get_last_busy_counter(uint64_t poller_id, uint64_t thread_id) in get_last_busy_counter() argument
[all …]
|
| /spdk/scripts/bpf/ |
| H A D | sched.bt | 9 uint64_t thread_id;
40 $info->thread_id, $info->lcore, arg2, $thread_pct, $core_pct);
|
| /spdk/module/scheduler/dynamic/ |
| H A D | scheduler_dynamic.c | 225 thread = spdk_thread_get_by_id(thread_info->thread_id); in _find_optimal_core()
|
| /spdk/lib/event/ |
| H A D | reactor.c | 721 thread = spdk_thread_get_by_id(thread_info->thread_id); in _reactors_scheduler_fini()
869 core_info->thread_infos[i].thread_id = spdk_thread_get_id(thread); in reactor_post_process_lw_thread()
|