Home
last modified time | relevance | path

Searched refs:thread (Results 1 – 25 of 174) sorted by relevance

1234567

/spdk/lib/thread/
H A Dthread.c13 #include "spdk/thread.h"
19 #include "spdk_internal/thread.h"
45 struct spdk_thread *thread;
52 /* The poller is registered with a thread but not currently executing its fn. */
76 /* Current state of the poller; should only be accessed from the poller's thread. */
86 struct spdk_thread *thread;
95 /* The thread is processing poller and message by spdk_thread_poll(). */
98 /* The thread is in the process of termination. It reaps unregistering
103 /* The thread is exited. It is ready to call spdk_thread_destroy(). */
118 * Contains pollers actively running on this thread
44 struct spdk_thread *thread; global() member
85 struct spdk_thread *thread; global() member
364 _free_thread(struct spdk_thread * thread) _free_thread() argument
492 struct spdk_thread *thread, *null_thread; spdk_thread_create() local
605 spdk_thread_is_app_thread(struct spdk_thread * thread) spdk_thread_is_app_thread() argument
615 spdk_thread_bind(struct spdk_thread * thread,bool bind) spdk_thread_bind() argument
621 spdk_thread_is_bound(struct spdk_thread * thread) spdk_thread_is_bound() argument
627 spdk_set_thread(struct spdk_thread * thread) spdk_set_thread() argument
633 thread_exit(struct spdk_thread * thread,uint64_t now) thread_exit() argument
704 spdk_thread_exit(struct spdk_thread * thread) spdk_thread_exit() argument
729 spdk_thread_is_running(struct spdk_thread * thread) spdk_thread_is_running() argument
735 spdk_thread_is_exited(struct spdk_thread * thread) spdk_thread_is_exited() argument
741 spdk_thread_destroy(struct spdk_thread * thread) spdk_thread_destroy() argument
759 spdk_thread_get_ctx(struct spdk_thread * thread) spdk_thread_get_ctx() argument
769 spdk_thread_get_cpumask(struct spdk_thread * thread) spdk_thread_get_cpumask() argument
777 struct spdk_thread *thread; spdk_thread_set_cpumask() local
817 msg_queue_run_batch(struct spdk_thread * thread,uint32_t max_msgs) msg_queue_run_batch() argument
876 poller_insert_timer(struct spdk_thread * thread,struct spdk_poller * poller,uint64_t now) poller_insert_timer() argument
900 poller_remove_timer(struct spdk_thread * thread,struct spdk_poller * poller) poller_remove_timer() argument
916 thread_insert_poller(struct spdk_thread * thread,struct spdk_poller * poller) thread_insert_poller() argument
926 thread_update_stats(struct spdk_thread * thread,uint64_t end,uint64_t start,int rc) thread_update_stats() argument
941 thread_execute_poller(struct spdk_thread * thread,struct spdk_poller * poller) thread_execute_poller() argument
1003 thread_execute_timed_poller(struct spdk_thread * thread,struct spdk_poller * poller,uint64_t now) thread_execute_timed_poller() argument
1064 thread_poll(struct spdk_thread * thread,uint32_t max_msgs,uint64_t now) thread_poll() argument
1128 struct spdk_thread *thread = ctx; _thread_remove_pollers() local
1152 struct spdk_thread *thread = ctx; _thread_exit() local
1164 spdk_thread_poll(struct spdk_thread * thread,uint32_t max_msgs,uint64_t now) spdk_thread_poll() argument
1202 spdk_thread_next_poller_expiration(struct spdk_thread * thread) spdk_thread_next_poller_expiration() argument
1215 spdk_thread_has_active_pollers(struct spdk_thread * thread) spdk_thread_has_active_pollers() argument
1221 thread_has_unpaused_pollers(struct spdk_thread * thread) thread_has_unpaused_pollers() argument
1232 spdk_thread_has_pollers(struct spdk_thread * thread) spdk_thread_has_pollers() argument
1243 spdk_thread_is_idle(struct spdk_thread * thread) spdk_thread_is_idle() argument
1272 spdk_thread_get_name(const struct spdk_thread * thread) spdk_thread_get_name() argument
1278 spdk_thread_get_id(const struct spdk_thread * thread) spdk_thread_get_id() argument
1286 struct spdk_thread *thread; spdk_thread_get_by_id() local
1305 struct spdk_thread *thread; spdk_thread_get_stats() local
1323 spdk_thread_get_last_tsc(struct spdk_thread * thread) spdk_thread_get_last_tsc() argument
1359 spdk_thread_send_msg(const struct spdk_thread * thread,spdk_msg_fn fn,void * ctx) spdk_thread_send_msg() argument
1406 spdk_thread_send_critical_msg(struct spdk_thread * thread,spdk_msg_fn fn) spdk_thread_send_critical_msg() argument
1653 struct spdk_thread *thread; poller_register() local
1750 wrong_thread(const char * func,const char * name,struct spdk_thread * thread,struct spdk_thread * curthread) wrong_thread() argument
1766 struct spdk_thread *thread; spdk_poller_unregister() local
1819 struct spdk_thread *thread; spdk_poller_pause() local
1855 struct spdk_thread *thread; spdk_poller_resume() local
1936 spdk_thread_get_first_active_poller(struct spdk_thread * thread) spdk_thread_get_first_active_poller() argument
1948 spdk_thread_get_first_timed_poller(struct spdk_thread * thread) spdk_thread_get_first_timed_poller() argument
1960 spdk_thread_get_first_paused_poller(struct spdk_thread * thread) spdk_thread_get_first_paused_poller() argument
1972 spdk_thread_get_first_io_channel(struct spdk_thread * thread) spdk_thread_get_first_io_channel() argument
2038 struct spdk_thread *thread; spdk_for_each_thread() local
2093 struct spdk_thread *thread = _get_thread(); spdk_thread_set_interrupt_mode() local
2138 struct spdk_thread *thread; spdk_io_device_register() local
2189 struct spdk_thread *thread; _finish_unregister() local
2225 struct spdk_thread *thread; spdk_io_device_unregister() local
2292 thread_get_io_channel(struct spdk_thread * thread,struct io_device * dev) thread_get_io_channel() argument
2304 struct spdk_thread *thread; spdk_get_io_channel() local
2388 struct spdk_thread *thread; put_io_channel() local
2443 struct spdk_thread *thread; spdk_put_io_channel() local
2576 struct spdk_thread *thread; spdk_for_each_channel() local
2647 struct spdk_thread *thread; spdk_for_each_channel_continue() local
2693 thread_interrupt_destroy(struct spdk_thread * thread) thread_interrupt_destroy() argument
2715 struct spdk_thread *thread = arg; thread_interrupt_msg_process() local
2764 thread_interrupt_create(struct spdk_thread * thread) thread_interrupt_create() argument
2789 thread_interrupt_create(struct spdk_thread * thread) thread_interrupt_create() argument
2799 struct spdk_thread *orig_thread, *thread; _interrupt_wrapper() local
2830 struct spdk_thread *thread; spdk_interrupt_register_for_events() local
2877 struct spdk_thread *thread; spdk_interrupt_unregister() local
2906 struct spdk_thread *thread; spdk_interrupt_set_event_types() local
2923 spdk_thread_get_interrupt_fd(struct spdk_thread * thread) spdk_thread_get_interrupt_fd() argument
2929 spdk_thread_get_interrupt_fd_group(struct spdk_thread * thread) spdk_thread_get_interrupt_fd_group() argument
3077 struct spdk_thread *thread = spdk_get_thread(); spdk_spin_lock() local
3097 struct spdk_thread *thread = spdk_get_thread(); spdk_spin_unlock() local
3118 struct spdk_thread *thread = spdk_get_thread(); spdk_spin_held() local
[all...]
H A DMakefile12 C_SRCS = thread.c iobuf.c
13 LIBNAME = thread
/spdk/test/common/lib/
H A Dut_multithread.c27 struct spdk_thread *thread; member
44 spdk_set_thread(g_ut_threads[thread_id].thread); in set_thread()
52 struct spdk_thread *thread; in allocate_threads() local
64 thread = spdk_thread_create(NULL, NULL); in allocate_threads()
65 assert(thread != NULL); in allocate_threads()
66 g_ut_threads[i].thread = thread; in allocate_threads()
77 struct spdk_thread *thread; in free_threads() local
81 thread = g_ut_threads[i].thread; in free_threads()
82 spdk_thread_exit(thread); in free_threads()
90 thread = g_ut_threads[i].thread; in free_threads()
[all …]
/spdk/test/unit/lib/thread/thread.c/
H A Dthread_ut.c11 #include "thread/thread_internal.h"
13 #include "thread/thread.c"
19 _thread_schedule(struct spdk_thread *thread) in _thread_schedule() argument
36 _thread_op(struct spdk_thread *thread, enum spdk_thread_op op) in _thread_op() argument
40 return _thread_schedule(thread); in _thread_op()
49 struct spdk_thread *thread; in thread_alloc() local
53 thread = spdk_thread_create(NULL, NULL); in thread_alloc()
54 SPDK_CU_ASSERT_FATAL(thread != NULL); in thread_alloc()
55 spdk_set_thread(thread); in thread_alloc()
667 struct spdk_thread *thread; thread_name() local
866 struct spdk_thread *thread; thread_exit_test() local
1043 struct spdk_thread *thread; thread_update_stats_test() local
1192 struct spdk_thread *thread; nested_channel() local
1387 struct spdk_thread *thread; cache_closest_timed_poller() local
1481 struct spdk_thread *thread; multi_timed_pollers_have_same_expiration() local
[all...]
/spdk/test/scheduler/
H A Didle.sh16 local thread load
22 for thread in "${!thread_map[@]}"; do
24 $((busy[thread] * 100 / (busy[thread] + idle[thread]))) \
26 if ((idle[thread] < busy[thread])); then
37 local reactors thread
58 for thread in "${threads[@]}"; do
59 … "select(.lcore == $spdk_main_core) | .lw_threads[] | select(.name == \"$thread\") | .cpumask" <<<…
60 printf 'SPDK cpumask: %s Thread %s cpumask: %s\n' "$spdk_cpumask" "$thread" "$thread_cpumask"
H A Dload_balancing.sh21 local threads thread
55 for thread in "${threads[@]}"; do
56 if ((thread != thread0 && thread != thread1)); then
58 "$thread" "${thread_map[thread]}" "$cpu"
61 load=$((busy[thread] * 100 / (busy[thread] + idle[thread])))
64 "$thread" "${thread_map[thread]}" "$load"
68 "$thread" "${thread_map[thread]}" "$cpu" "$load"
93 local thread cpu
138 for thread in "${extra_threads[@]}"; do
139 destroy_thread "$thread"
[all …]
H A Dcommon.sh441 for thread in "${!thread_map[@]}"; do
442 : $((busy[thread] = total_busy[thread] - past_busy[thread], past_busy[thread] = total_busy[thread]))
443 : $((idle[thread] = total_idle[thread] - past_idle[thread], past_idle[thread]
[all...]
H A Dgovernor.sh47 local thread
48 for thread in "${!cpu_siblings[spdk_main_core]}"; do
49 ((thread == spdk_main_core)) && continue # handled by DPDK/scheduler
55 set_cpufreq "$thread" "$main_core_set_min_freq" "$main_core_set_max_freq"
/spdk/mk/
H A Dspdk.lib_deps.mk33 DEPDIRS-vfu_tgt := log util thread $(JSON_LIBS)
44 DEPDIRS-thread := log util trace
55 DEPDIRS-blob := log util thread dma trace
56 DEPDIRS-accel := log util thread json rpc jsonrpc dma
58 DEPDIRS-virtio := log util json thread vfio_user
60 DEPDIRS-lvol := log util blob thread
67 DEPDIRS-bdev := accel log util thread $(JSON_LIBS) notify trace dma
68 DEPDIRS-blobfs := log thread blob trace util
69 DEPDIRS-event := log util thread $(JSON_LIBS) trace init
70 DEPDIRS-init := jsonrpc json log rpc thread uti
[all...]
/spdk/test/unit/lib/event/reactor.c/
H A Dreactor_ut.c11 #include "spdk/thread.h"
12 #include "spdk_internal/thread.h"
114 struct spdk_thread *thread; in test_schedule_thread() local
130 * at its end because it is passed to SPDK thread library by in test_schedule_thread()
133 thread = spdk_thread_create(NULL, &cpuset); in test_schedule_thread()
134 CU_ASSERT(thread != NULL); in test_schedule_thread()
145 CU_ASSERT(spdk_thread_get_from_ctx(lw_thread) == thread); in test_schedule_thread()
149 spdk_set_thread(thread); in test_schedule_thread()
150 spdk_thread_exit(thread); in test_schedule_thread()
151 while (!spdk_thread_is_exited(thread)) { in test_schedule_thread()
166 struct spdk_thread *thread; test_reschedule_thread() local
535 struct spdk_thread *thread[3]; test_scheduler() local
730 struct spdk_thread *thread[3]; test_bind_thread() local
930 struct spdk_thread *thread[2]; test_governor() local
[all...]
/spdk/lib/event/
H A Dreactor.c15 #include "spdk/thread.h"
268 static int reactor_thread_op(struct spdk_thread *thread, enum spdk_thread_op op); in spdk_reactors_init()
319 SPDK_ERRLOG("Initialize spdk thread lib failed\n"); in spdk_reactors_fini()
423 struct spdk_thread *thread; in _reactor_set_interrupt_mode()
438 thread = spdk_thread_get_from_ctx(lw_thread); in spdk_reactor_set_interrupt_mode()
440 grp = spdk_thread_get_interrupt_fd_group(thread); in spdk_reactor_set_interrupt_mode()
443 grp = spdk_thread_get_interrupt_fd_group(thread); in spdk_reactor_set_interrupt_mode()
447 spdk_thread_send_msg(thread, _reactor_set_thread_interrupt_mode, target); in spdk_reactor_set_interrupt_mode()
674 * strictly thread safe. However, we're toggling between true and in _init_thread_stats()
675 * false here, and if a thread see in _init_thread_stats()
374 struct spdk_thread *thread; _reactor_set_interrupt_mode() local
662 struct spdk_thread *thread = spdk_thread_get_from_ctx(lw_thread); _init_thread_stats() local
680 struct spdk_thread *thread; _threads_reschedule_thread() local
786 struct spdk_thread *thread; _reactors_scheduler_gather_metrics() local
850 struct spdk_thread *thread = spdk_thread_get_from_ctx(lw_thread); _reactor_remove_lw_thread() local
869 struct spdk_thread *thread = spdk_thread_get_from_ctx(lw_thread); reactor_post_process_lw_thread() local
899 struct spdk_thread *thread; _reactor_run() local
936 struct spdk_thread *thread; reactor_run() local
1126 struct spdk_thread *thread; _schedule_thread() local
1165 _reactor_schedule_thread(struct spdk_thread * thread) _reactor_schedule_thread() argument
1257 _reactor_request_thread_reschedule(struct spdk_thread * thread) _reactor_request_thread_reschedule() argument
1286 reactor_thread_op(struct spdk_thread * thread,enum spdk_thread_op op) reactor_thread_op() argument
[all...]
H A Dapp_rpc.c14 #include "spdk/thread.h"
19 #include "spdk_internal/thread.h"
171 struct spdk_thread *thread = spdk_get_thread(); in _rpc_thread_get_stats() local
179 for (poller = spdk_thread_get_first_active_poller(thread); poller != NULL; in _rpc_thread_get_stats()
184 for (poller = spdk_thread_get_first_timed_poller(thread); poller != NULL; in _rpc_thread_get_stats()
189 for (poller = spdk_thread_get_first_paused_poller(thread); poller != NULL; in _rpc_thread_get_stats()
196 spdk_json_write_named_string(ctx->w, "name", spdk_thread_get_name(thread)); in _rpc_thread_get_stats()
197 spdk_json_write_named_uint64(ctx->w, "id", spdk_thread_get_id(thread)); in _rpc_thread_get_stats()
199 spdk_cpuset_and(&tmp_mask, spdk_thread_get_cpumask(thread)); in _rpc_thread_get_stats()
250 struct spdk_thread *thread in _rpc_thread_get_pollers() local
309 struct spdk_thread *thread = spdk_get_thread(); _rpc_thread_get_io_channels() local
363 struct spdk_thread *thread; _rpc_framework_get_reactors() local
663 struct spdk_thread *thread; rpc_thread_set_cpumask() local
[all...]
/spdk/test/event/scheduler/
H A Dscheduler.c26 struct spdk_thread *thread; member
70 spdk_thread_exit(sched_thread->thread); in thread_delete()
118 spdk_thread_get_name(sched_thread->thread)); in update_pollers()
136 rpc_scheduler_thread_create_cb(sched_thread->request, spdk_thread_get_id(sched_thread->thread)); in rpc_register_poller()
181 sched_thread->thread = spdk_thread_create(req.name, cpu_set); in rpc_scheduler_thread_create()
182 assert(sched_thread->thread != NULL); in rpc_scheduler_thread_create()
188 spdk_thread_send_msg(sched_thread->thread, rpc_register_poller, sched_thread); in rpc_scheduler_thread_create()
227 if (spdk_thread_get_id(sched_thread->thread) == thread_id) { in rpc_scheduler_thread_set_active_cb()
247 struct spdk_thread *thread; in rpc_scheduler_thread_set_active() local
265 thread = spdk_thread_get_by_id(req.thread_id); in rpc_scheduler_thread_set_active()
[all …]
/spdk/doc/
H A Dusdt.md74 2111.260278: nqn.2014-08.org.nvmexpress.discovery on thread 2 state to ACTIVE start
75 2111.264281: nqn.2014-08.org.nvmexpress.discovery on thread 2 state to ACTIVE done
78 2111.271573: nqn.2014-08.org.nvmexpress.discovery on thread 3 state to ACTIVE start
79 2111.279787: nqn.2014-08.org.nvmexpress.discovery on thread 3 state to ACTIVE done
81 2189.952508: nqn.2016-06.io.spdk:cnode1 on thread 2 state to ACTIVE start
82 2189.959125: nqn.2016-06.io.spdk:cnode1 on thread 2 state to ACTIVE done
84 2189.969058: nqn.2016-06.io.spdk:cnode1 on thread 3 state to ACTIVE start
85 2189.999889: nqn.2016-06.io.spdk:cnode1 on thread 3 state to ACTIVE done
87 2197.879199: nqn.2016-06.io.spdk:cnode1 on thread 2 state to PAUSED start
88 2197.883416: nqn.2016-06.io.spdk:cnode1 on thread 2 state to PAUSED done
[all …]
H A Dspdk_top.md9 Why doesn't the classic top utility work for SPDK? SPDK uses a polled-mode design; a reactor thread…
14 …d metrics from the pollers, analyzes and report the metrics on a per poller, thread and core basis.
45 The threads tab displays a line item for each spdk thread. The information displayed shows:
47 * Thread name - name of SPDK thread.
48 * Core - core on which the thread is currently running.
49 * Active/Timed/Paused pollers - number of pollers grouped by type on this thread.
50 * Idle/Busy - how many microseconds the thread was idle/busy.
54 thread (with poller name, type, run count and period).
65 * On thread - thread on which the poller is running.
86 window allows to select a thread and display thread details pop-up on top of it. To close both pop-…
H A Devent.md8 described in the following sections. The event framework spawns one thread per
25 assigning connections to them without introducing cross-thread
27 not entirely independent and cross-thread shared state is necessary. SPDK
34 To accomplish cross-thread communication while minimizing synchronization
36 event framework runs one event loop thread per CPU core. These threads are
41 thread-per-connection server design, which achieves concurrency by depending
63 are executed on the thread they are registered on. The reactor event loop
72 spdk_app_start() is called, it will block the current thread until the application
H A Dconcurrency.md35 assign that data to a single thread. When other threads want to access the data,
36 they pass a message to the owning thread to perform the operation on their
51 In more extreme cases where even message passing may be too costly, each thread
52 may make a local copy of the data. The thread will then only reference its local
53 copy. To mutate the data, threads will send a message to each other thread
65 [thread](http://www.spdk.io/doc/thread_8h.html)
66 abstraction, located in `libspdk_thread.a`. The thread abstraction provides a
69 First, `spdk_thread` is an abstraction for a lightweight, stackless thread of
73 only a single system thread executing `spdk_thread_poll()` on that
76 `spdk_thread_destroy()`. The lightweight thread is the foundational abstraction for
[all …]
/spdk/test/unit/lib/nvmf/nvmf.c/
H A Dnvmf_ut.c123 struct spdk_thread *thread; member
149 struct spdk_thread *thread = NULL; in test_nvmf_tgt_create_poll_group() local
159 thread = spdk_thread_create(NULL, NULL); in test_nvmf_tgt_create_poll_group()
160 SPDK_CU_ASSERT_FATAL(thread != NULL); in test_nvmf_tgt_create_poll_group()
161 spdk_set_thread(thread); in test_nvmf_tgt_create_poll_group()
164 ch.thread = thread; in test_nvmf_tgt_create_poll_group()
210 CU_ASSERT(group.thread == thread); in test_nvmf_tgt_create_poll_group()
218 spdk_thread_exit(thread); in test_nvmf_tgt_create_poll_group()
[all...]
/spdk/scripts/bpf/
H A Dnvmf.bt20 printf("%d.%06d: %s on thread %d state to %s start\n",
26 printf("%d.%06d: %s on thread %d state to %s done\n",
32 printf("%d.%06d: create poll group on thread: %d\n",
38 printf("%d.%06d: destroy poll group on thread: %d\n",
44 printf("%d.%06d: add qpair: %p to poll group on thread %d\n",
50 printf("%d.%06d: destroy qpairs on poll group on thread %d\n",
56 printf("%d.%06d: remove qpair: %p from poll group on thread %d\n",
62 printf("%d.%06d: disconnect qpair: %p from poll group on thread %d\n",
74 printf("%d.%06d: drain qpair: %p from poll group on thread %d\n",
146 printf("%d.%06d: add qpair: %p with id: %d to poll group on thread: %lu\n",
[all …]
/spdk/test/unit/lib/bdev/compress.c/
H A Dcompress_ut.c12 #include "thread/thread_internal.h"
216 struct spdk_thread *thread; in test_setup()
220 thread = spdk_thread_create(NULL, NULL); in test_setup()
221 spdk_set_thread(thread); in test_setup()
223 g_comp_bdev.reduce_thread = thread; in test_setup()
238 g_io_ch->thread = thread; in test_cleanup()
255 struct spdk_thread *thread; in test_cleanup()
261 thread = spdk_get_thread();
262 spdk_thread_exit(thread);
201 struct spdk_thread *thread; test_setup() local
239 struct spdk_thread *thread; test_cleanup() local
[all...]
/spdk/include/spdk_internal/
H A Dthread.h33 struct spdk_poller *spdk_thread_get_first_active_poller(struct spdk_thread *thread);
35 struct spdk_poller *spdk_thread_get_first_timed_poller(struct spdk_thread *thread);
37 struct spdk_poller *spdk_thread_get_first_paused_poller(struct spdk_thread *thread);
40 struct spdk_io_channel *spdk_thread_get_first_io_channel(struct spdk_thread *thread);
/spdk/test/unit/lib/blobfs/blobfs_sync_ut/
H A Dblobfs_sync_ut.c82 struct spdk_thread *thread; in fs_thread_poll() local
84 thread = spdk_get_thread(); in fs_thread_poll()
85 while (spdk_thread_poll(thread, 0, 0) > 0) {} in fs_thread_poll()
405 struct spdk_thread *thread; in cache_write_null_buffer() local
431 thread = spdk_get_thread(); in cache_write_null_buffer()
432 while (spdk_thread_poll(thread, 0, 0) > 0) {} in cache_write_null_buffer()
584 struct spdk_thread *thread = arg; in spdk_thread() local
586 spdk_set_thread(thread); in spdk_thread()
589 spdk_thread_poll(thread, 0, 0); in spdk_thread()
598 struct spdk_thread *thread; in main() local
[all …]
/spdk/test/unit/lib/ftl/common/
H A Dutils.c137 struct spdk_thread *thread; in test_free_ftl_dev() local
142 thread = dev->core_thread; in test_free_ftl_dev()
144 spdk_set_thread(thread); in test_free_ftl_dev()
145 spdk_thread_exit(thread); in test_free_ftl_dev()
146 while (!spdk_thread_is_exited(thread)) { in test_free_ftl_dev()
147 spdk_thread_poll(thread, 0, 0); in test_free_ftl_dev()
149 spdk_thread_destroy(thread); in test_free_ftl_dev()
/spdk/test/unit/lib/nvmf/tcp.c/
H A Dtcp_ut.c421 struct spdk_thread *thread; in test_nvmf_tcp_create()
427 thread = spdk_thread_create(NULL, NULL); in test_nvmf_tcp_create()
428 SPDK_CU_ASSERT_FATAL(thread != NULL); in test_nvmf_tcp_create()
429 spdk_set_thread(thread); in test_nvmf_tcp_create()
491 spdk_thread_exit(thread);
492 while (!spdk_thread_is_exited(thread)) {
493 spdk_thread_poll(thread, 0, 0); in init_accel()
495 spdk_thread_destroy(thread); in init_accel()
501 struct spdk_thread *thread; in fini_accel()
506 thread
379 struct spdk_thread *thread; test_nvmf_tcp_create() local
459 struct spdk_thread *thread; test_nvmf_tcp_destroy() local
511 struct spdk_thread *thread; test_nvmf_tcp_poll_group_create() local
557 struct spdk_thread *thread; test_nvmf_tcp_send_c2h_data() local
779 struct spdk_thread *thread; test_nvmf_tcp_qpair_init_mem_resource() local
1294 struct spdk_thread *thread; test_nvmf_tcp_tls_add_remove_credentials() local
[all...]
/spdk/test/blobfs/rocksdb/
H A Dpostprocess.py37 for thread in sorted(threads):
40 print("Thread: {:s}".format(thread))
44 if key.thread == thread:

1234567