Lines Matching refs:thread
14 #include "spdk/thread.h"
19 #include "spdk_internal/thread.h"
171 struct spdk_thread *thread = spdk_get_thread();
179 for (poller = spdk_thread_get_first_active_poller(thread); poller != NULL;
184 for (poller = spdk_thread_get_first_timed_poller(thread); poller != NULL;
189 for (poller = spdk_thread_get_first_paused_poller(thread); poller != NULL;
196 spdk_json_write_named_string(ctx->w, "name", spdk_thread_get_name(thread));
197 spdk_json_write_named_uint64(ctx->w, "id", spdk_thread_get_id(thread));
199 spdk_cpuset_and(&tmp_mask, spdk_thread_get_cpumask(thread));
250 struct spdk_thread *thread = spdk_get_thread();
254 spdk_json_write_named_string(ctx->w, "name", spdk_thread_get_name(thread));
255 spdk_json_write_named_uint64(ctx->w, "id", spdk_thread_get_id(thread));
258 for (poller = spdk_thread_get_first_active_poller(thread); poller != NULL;
265 for (poller = spdk_thread_get_first_timed_poller(thread); poller != NULL;
272 for (poller = spdk_thread_get_first_paused_poller(thread); poller != NULL;
309 struct spdk_thread *thread = spdk_get_thread();
313 spdk_json_write_named_string(ctx->w, "name", spdk_thread_get_name(thread));
316 for (ch = spdk_thread_get_first_io_channel(thread); ch != NULL;
363 struct spdk_thread *thread;
395 thread = spdk_thread_get_from_ctx(lw_thread);
398 spdk_json_write_named_string(ctx->w, "name", spdk_thread_get_name(thread));
399 spdk_json_write_named_uint64(ctx->w, "id", spdk_thread_get_id(thread));
401 spdk_cpuset_and(&tmp_mask, spdk_thread_get_cpumask(thread));
724 struct spdk_thread *thread;
744 thread = spdk_thread_get_by_id(req.id);
745 if (thread == NULL) {
794 spdk_thread_send_msg(thread, _rpc_thread_set_cpumask, ctx);