/spdk/lib/thread/ |
H A D | thread.c | 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 D | thread_internal.h | 21 struct spdk_thread *thread; member
|
/spdk/test/common/lib/ |
H A D | ut_multithread.c | 27 struct spdk_thread *thread; member 52 struct spdk_thread *thread; in allocate_threads() local 77 struct spdk_thread *thread; in free_threads() local 116 struct ut_thread *thread = &g_ut_threads[thread_id]; in poll_thread_times() local 150 struct ut_thread *thread = &g_ut_threads[thread_id]; in poll_thread() local
|
/spdk/lib/event/ |
H A D | reactor.c | 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 D | app_rpc.c | 171 struct spdk_thread *thread = spdk_get_thread(); in _rpc_thread_get_stats() local 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/unit/lib/event/reactor.c/ |
H A D | reactor_ut.c | 114 struct spdk_thread *thread; in test_schedule_thread() local 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/test/unit/lib/nvmf/nvmf.c/ |
H A D | nvmf_ut.c | 123 struct spdk_thread *thread; member 149 struct spdk_thread *thread = NULL; in test_nvmf_tgt_create_poll_group() local [all...] |
/spdk/test/unit/lib/thread/thread.c/ |
H A D | thread_ut.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 49 struct spdk_thread *thread; in thread_alloc() local 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/unit/lib/blobfs/blobfs_sync_ut/ |
H A D | blobfs_sync_ut.c | 82 struct spdk_thread *thread; in fs_thread_poll() local 405 struct spdk_thread *thread; in cache_write_null_buffer() local 584 struct spdk_thread *thread = arg; in spdk_thread() local 598 struct spdk_thread *thread; in main() local
|
/spdk/test/unit/lib/nvmf/tcp.c/ |
H A D | tcp_ut.c | 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/event/scheduler/ |
H A D | scheduler.c | 26 struct spdk_thread *thread; member 247 struct spdk_thread *thread; in rpc_scheduler_thread_set_active() local 326 struct spdk_thread *thread; in rpc_scheduler_thread_delete() local
|
/spdk/lib/vfu_tgt/ |
H A D | tgt_internal.h | 27 struct spdk_thread *thread; member
|
/spdk/test/unit/lib/init/subsystem.c/ |
H A D | subsystem_ut.c | 211 struct spdk_thread *thread; in main() local
|
/spdk/test/unit/lib/ftl/common/ |
H A D | utils.c | 137 struct spdk_thread *thread; in test_free_ftl_dev() local
|
/spdk/module/event/subsystems/nvmf/ |
H A D | nvmf_tgt.c | 33 struct spdk_thread *thread; member 194 pg->thread = spdk_get_thread(); in nvmf_tgt_create_poll_groups() local [all...] |
/spdk/test/unit/lib/init/rpc.c/ |
H A D | rpc_ut.c | 222 struct spdk_thread *thread; in main() local
|
/spdk/test/thread/lock/ |
H A D | spdk_lock.c | 75 struct spdk_thread *thread = spdk_get_thread(); in do_not_abort() local 393 struct spdk_thread *thread = arg; in stop_thread() local
|
/spdk/test/unit/lib/bdev/compress.c/ |
H A D | compress_ut.c | 201 struct spdk_thread *thread; test_setup() local 239 struct spdk_thread *thread; test_cleanup() local [all...] |
/spdk/lib/ftl/ |
H A D | ftl_init.c | 65 struct spdk_thread *thread = ctx; in exit_thread() local
|
/spdk/lib/ftl/mngt/ |
H A D | ftl_mngt_startup.c | 287 struct spdk_thread *thread; global() member
|
/spdk/test/unit/lib/blobfs/blobfs_bdev.c/ |
H A D | blobfs_bdev_ut.c | 126 spdk_thread_send_msg(const struct spdk_thread *thread, spdk_msg_fn fn, void *ctx) in spdk_thread_send_msg()
|
/spdk/lib/nvmf/ |
H A D | nvmf_internal.h | 224 struct spdk_thread *thread; global() member 272 struct spdk_thread *thread; global() member 280 struct spdk_thread *thread; global() member
|
/spdk/test/unit/lib/accel/dpdk_compressdev.c/ |
H A D | accel_dpdk_compressdev_ut.c | 398 struct spdk_thread *thread; test_setup() local 471 struct spdk_thread *thread; test_cleanup() local [all...] |
/spdk/module/scheduler/dynamic/ |
H A D | scheduler_dynamic.c | 216 struct spdk_thread *thread; _find_optimal_core() local [all...] |
/spdk/lib/iscsi/ |
H A D | iscsi_subsystem.c | 1011 struct spdk_thread *thread; in iscsi_poll_group_destroy() local 1057 struct spdk_thread *thread; in initialize_iscsi_poll_group() local
|