Lines Matching defs:spdk_thread
40 static struct spdk_thread *g_app_thread;
45 struct spdk_thread *thread;
86 struct spdk_thread *thread;
114 struct spdk_thread {
149 TAILQ_ENTRY(spdk_thread) tailq;
157 /* spdk_thread is bound to current CPU core. */
160 /* Indicates whether this spdk_thread currently runs in interrupt. */
174 * Assert that spdk_thread struct is 8 byte aligned to ensure
177 SPDK_STATIC_ASSERT((sizeof(struct spdk_thread)) % 8 == 0, "Incorrect size");
206 * An spdk_thread may migrate to another pthread. A spinlock held across migration leads to
266 struct spdk_thread *unregister_thread;
304 static TAILQ_HEAD(, spdk_thread) g_threads = TAILQ_HEAD_INITIALIZER(g_threads);
307 static __thread struct spdk_thread *tls_thread = NULL;
353 static inline struct spdk_thread *
383 static void thread_interrupt_destroy(struct spdk_thread *thread);
384 static int thread_interrupt_create(struct spdk_thread *thread);
387 _free_thread(struct spdk_thread *thread)
512 struct spdk_thread *
515 struct spdk_thread *thread, *null_thread;
520 /* Since this spdk_thread object will be used by another core, ensure that it won't share a
623 struct spdk_thread *
630 spdk_thread_is_app_thread(struct spdk_thread *thread)
640 spdk_thread_bind(struct spdk_thread *thread, bool bind)
646 spdk_thread_is_bound(struct spdk_thread *thread)
652 spdk_set_thread(struct spdk_thread *thread)
658 thread_exit(struct spdk_thread *thread, uint64_t now)
729 spdk_thread_exit(struct spdk_thread *thread)
754 spdk_thread_is_running(struct spdk_thread *thread)
760 spdk_thread_is_exited(struct spdk_thread *thread)
766 spdk_thread_destroy(struct spdk_thread *thread)
784 spdk_thread_get_ctx(struct spdk_thread *thread)
794 spdk_thread_get_cpumask(struct spdk_thread *thread)
802 struct spdk_thread *thread;
828 struct spdk_thread *
838 return SPDK_CONTAINEROF(ctx, struct spdk_thread, ctx);
842 msg_queue_run_batch(struct spdk_thread *thread, uint32_t max_msgs)
901 poller_insert_timer(struct spdk_thread *thread, struct spdk_poller *poller, uint64_t now)
925 poller_remove_timer(struct spdk_thread *thread, struct spdk_poller *poller)
941 thread_insert_poller(struct spdk_thread *thread, struct spdk_poller *poller)
951 thread_update_stats(struct spdk_thread *thread, uint64_t end,
966 thread_execute_poller(struct spdk_thread *thread, struct spdk_poller *poller)
1028 thread_execute_timed_poller(struct spdk_thread *thread, struct spdk_poller *poller,
1089 thread_run_pp_handlers(struct spdk_thread *thread)
1105 thread_poll(struct spdk_thread *thread, uint32_t max_msgs, uint64_t now)
1172 struct spdk_thread *thread = ctx;
1196 struct spdk_thread *thread = ctx;
1208 spdk_thread_poll(struct spdk_thread *thread, uint32_t max_msgs, uint64_t now)
1210 struct spdk_thread *orig_thread;
1246 spdk_thread_next_poller_expiration(struct spdk_thread *thread)
1259 spdk_thread_has_active_pollers(struct spdk_thread *thread)
1265 thread_has_unpaused_pollers(struct spdk_thread *thread)
1276 spdk_thread_has_pollers(struct spdk_thread *thread)
1287 spdk_thread_is_idle(struct spdk_thread *thread)
1309 struct spdk_thread *
1316 spdk_thread_get_name(const struct spdk_thread *thread)
1322 spdk_thread_get_id(const struct spdk_thread *thread)
1327 struct spdk_thread *
1330 struct spdk_thread *thread;
1349 struct spdk_thread *thread;
1367 spdk_thread_get_last_tsc(struct spdk_thread *thread)
1377 thread_send_msg_notification(const struct spdk_thread *target_thread)
1387 /* When each spdk_thread can switch between poll and interrupt mode dynamically,
1403 spdk_thread_send_msg(const struct spdk_thread *thread, spdk_msg_fn fn, void *ctx)
1405 struct spdk_thread *local_thread;
1450 spdk_thread_send_critical_msg(struct spdk_thread *thread, spdk_msg_fn fn)
1696 struct spdk_thread *thread;
1793 wrong_thread(const char *func, const char *name, struct spdk_thread *thread,
1794 struct spdk_thread *curthread)
1809 struct spdk_thread *thread;
1862 struct spdk_thread *thread;
1898 struct spdk_thread *thread;
1979 spdk_thread_get_first_active_poller(struct spdk_thread *thread)
1991 spdk_thread_get_first_timed_poller(struct spdk_thread *thread)
2003 spdk_thread_get_first_paused_poller(struct spdk_thread *thread)
2015 spdk_thread_get_first_io_channel(struct spdk_thread *thread)
2027 spdk_thread_get_trace_id(struct spdk_thread *thread)
2033 struct spdk_thread *cur_thread;
2037 struct spdk_thread *orig_thread;
2087 struct spdk_thread *thread;
2138 struct spdk_thread *thread = _get_thread();
2144 SPDK_NOTICELOG("Set spdk_thread (%s) to %s mode from %s mode.\n",
2183 struct spdk_thread *thread;
2234 struct spdk_thread *thread;
2270 struct spdk_thread *thread;
2337 thread_get_io_channel(struct spdk_thread *thread, struct io_device *dev)
2349 struct spdk_thread *thread;
2433 struct spdk_thread *thread;
2488 struct spdk_thread *thread;
2525 struct spdk_thread *
2557 struct spdk_thread *cur_thread;
2559 struct spdk_thread *orig_thread;
2621 struct spdk_thread *thread;
2692 struct spdk_thread *thread;
2738 thread_interrupt_destroy(struct spdk_thread *thread)
2760 struct spdk_thread *thread = arg;
2761 struct spdk_thread *orig_thread;
2800 thread_interrupt_create(struct spdk_thread *thread)
2830 thread_interrupt_create(struct spdk_thread *thread)
2840 struct spdk_thread *orig_thread, *thread;
2884 struct spdk_thread *thread;
2948 struct spdk_thread *orig_thread, *thread;
2996 struct spdk_thread *thread;
3032 struct spdk_thread *thread;
3054 spdk_thread_get_interrupt_fd(struct spdk_thread *thread)
3060 spdk_thread_get_interrupt_fd_group(struct spdk_thread *thread)
3208 struct spdk_thread *thread = spdk_get_thread();
3228 struct spdk_thread *thread = spdk_get_thread();
3249 struct spdk_thread *thread = spdk_get_thread();
3259 struct spdk_thread *thr;