Home
last modified time | relevance | path

Searched refs:spdk_thread_send_msg (Results 1 – 25 of 81) sorted by relevance

1234

/spdk/test/thread/lock/
H A Dspdk_lock.c188 spdk_thread_send_msg(g_thread[i], contend_start_worker_poller, &g_contend_data[i]); in contend_setup()
216 spdk_thread_send_msg(spdk_thread_get_app_thread(), launch_next_test, NULL); in contend_end()
288 spdk_thread_send_msg(g_thread[0], hold_by_poller_start, NULL); in hold_by_poller_setup()
309 spdk_thread_send_msg(spdk_thread_get_app_thread(), launch_next_test, NULL); in hold_by_poller_end()
335 spdk_thread_send_msg(g_thread[0], hold_by_message, NULL); in hold_by_message_setup()
355 spdk_thread_send_msg(spdk_thread_get_app_thread(), launch_next_test, NULL); in hold_by_message_end()
407 spdk_thread_send_msg(g_thread[i], stop_thread, g_thread[i]); in stop_threads()
466 spdk_thread_send_msg(g_thread[test->poller_thread_number - 1], in launch_next_test()
484 spdk_thread_send_msg(spdk_thread_get_app_thread(), launch_next_test, NULL); in start_tests()
/spdk/test/unit/lib/blob/
H A Dbs_dev_common.c151 spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args); in dev_write()
183 spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args); in __check_iov()
234 spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args); in dev_readv_ext()
285 spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args); in dev_writev_ext()
319 spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args); in dev_unmap()
349 spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args); in dev_write_zeroes()
380 spdk_thread_send_msg(spdk_get_thread(), dev_complete, cb_args); in dev_translate_lba()
/spdk/module/event/subsystems/nvmf/
H A Dnvmf_tgt.c79 spdk_thread_send_msg(spdk_get_thread(), nvmf_shutdown_cb, NULL); in nvmf_shutdown_cb()
119 spdk_thread_send_msg(g_tgt_fini_thread, _nvmf_tgt_destroy_poll_group_done, NULL); in nvmf_tgt_destroy_poll_group()
142 spdk_thread_send_msg(pg->thread, nvmf_tgt_destroy_poll_group, pg); in nvmf_get_cpuset_count()
197 spdk_thread_send_msg(g_tgt_init_thread, nvmf_tgt_create_poll_group_done, pg); in nvmf_tgt_create_poll_groups()
219 spdk_thread_send_msg(thread, nvmf_tgt_create_poll_group, NULL); in nvmf_tgt_subsystem_started()
/spdk/test/dma/test_dma/
H A Dtest_dma.c196 spdk_thread_send_msg(g_main_thread, dma_test_task_complete, task); in dma_test_task_update_stats()
395 spdk_thread_send_msg(req->task->thread, dma_test_data_cpl, cpl_ctx); in dma_test_submit_io()
444 spdk_thread_send_msg(req->task->thread, dma_test_data_cpl, cpl_ctx); in dma_test_task_run()
577 spdk_thread_send_msg(task->thread, dma_test_drain_task, task); in dma_test_check_bdev_supports_rdma_memory_domain()
627 spdk_thread_send_msg(task->thread, dma_test_task_run, task); in allocate_task()
641 spdk_thread_send_msg(g_main_thread, dma_test_construct_task_done, NULL); in allocate_task()
651 spdk_thread_send_msg(g_main_thread, dma_test_construct_task_done, NULL); in allocate_task()
667 spdk_thread_send_msg(g_main_thread, dma_test_construct_task_done, NULL); in destroy_task()
674 spdk_thread_send_msg(g_main_thread, dma_test_construct_task_done, NULL); in destroy_tasks()
678 spdk_thread_send_msg(g_main_threa in destroy_tasks()
[all...]
/spdk/module/blobfs/bdev/
H A Dblobfs_bdev.c89 spdk_thread_send_msg(spdk_get_thread(), blobfs_bdev_unload, ctx); in blobfs_bdev_load_cb_to_unload()
190 spdk_thread_send_msg(ctx->fs_loading_thread, blobfs_bdev_unload, ctx); in SPDK_LOG_REGISTER_COMPONENT()
237 spdk_thread_send_msg(spdk_get_thread(), _blobfs_bdev_mount_fuse_start, ctx); in _blobfs_bdev_mount_load_cb()
/spdk/scripts/bpf/
H A Dsend_msg.bt1 uprobe:__EXE__:spdk_thread_send_msg {
/spdk/lib/init/
H A Djson_config.c343 spdk_thread_send_msg(ctx->thread, app_json_config_load_subsystem, ctx); in app_json_config_load_subsystem_config_entry()
359 spdk_thread_send_msg(ctx->thread, app_json_config_load_subsystem_config_entry, ctx); in app_json_config_load_subsystem_config_entry()
376 spdk_thread_send_msg(ctx->thread, app_json_config_load_subsystem_config_entry, ctx); in app_json_config_load_subsystem_config_entry()
388 spdk_thread_send_msg(ctx->thread, app_json_config_load_subsystem_config_entry, ctx); in app_json_config_load_subsystem_config_entry()
397 spdk_thread_send_msg(ctx->thread, app_json_config_load_subsystem_config_entry, ctx); in app_json_config_load_subsystem_config_entry()
H A Dsubsystem.c244 spdk_thread_send_msg(g_fini_thread, subsystem_fini_next, NULL); in spdk_subsystem_fini_next()
/spdk/lib/ftl/mngt/
H A Dftl_mngt_ioch.c108 if (spdk_thread_send_msg(dev->core_thread, ftl_dev_register_channel, ioch)) { in io_channel_create_cb()
140 spdk_thread_send_msg(ftl_get_core_thread(dev), in io_channel_destroy_cb()
H A Dftl_mngt.c472 spdk_thread_send_msg(mngt->caller.thread, finish_msg, mngt); in ftl_mngt_finish()
514 spdk_thread_send_msg(mngt->dev->core_thread, action_msg, mngt); in action_execute()
577 spdk_thread_send_msg(mngt->dev->core_thread, rollback_msg, mngt); in rollback_execute()
H A Dftl_mngt_misc.c365 rc = spdk_thread_send_msg(cctx->cb_thread, ftl_get_properties_cb, cctx); in ftl_get_properties_msg()
385 rc = spdk_thread_send_msg(dev->core_thread, ftl_get_properties_msg, ctx); in spdk_ftl_get_properties()
/spdk/lib/ftl/
H A Dftl_debug.h40 spdk_thread_send_msg(band->dev->core_thread, _validate_cb, band); in ftl_band_validate_md()
/spdk/test/event/scheduler/
H A Dscheduler.c188 spdk_thread_send_msg(sched_thread->thread, rpc_register_poller, sched_thread); in rpc_scheduler_thread_create()
279 spdk_thread_send_msg(thread, rpc_scheduler_thread_set_active_cb, ctx); in rpc_scheduler_thread_set_active()
351 spdk_thread_send_msg(thread, rpc_scheduler_thread_delete_cb, ctx); in rpc_scheduler_thread_delete()
/spdk/lib/nvmf/
H A Dfc_ls.c1290 spdk_thread_send_msg(cb_info->cb_thread, nvmf_fc_poller_api_cb_event, in nvmf_fc_poller_api_perform_cb()
1669 spdk_thread_send_msg(hwqp->thread, in nvmf_fc_poller_api_func()
1674 spdk_thread_send_msg(hwqp->thread, in nvmf_fc_poller_api_func()
1681 spdk_thread_send_msg(hwqp->thread, in nvmf_fc_poller_api_func()
1686 spdk_thread_send_msg(hwqp->thread, in nvmf_fc_poller_api_func()
1691 spdk_thread_send_msg(hwqp->thread, in nvmf_fc_poller_api_func()
1696 spdk_thread_send_msg(hwqp->thread, in nvmf_fc_poller_api_func()
1701 spdk_thread_send_msg(hwqp->thread, in nvmf_fc_poller_api_func()
1706 spdk_thread_send_msg(hwqp->thread, in nvmf_fc_poller_api_func()
1711 spdk_thread_send_msg(hwq in nvmf_fc_poller_api_func()
[all...]
/spdk/module/vfu_device/
H A Dvfu_virtio_blk.c141 spdk_thread_send_msg(virtio_endpoint->thread, _virtio_blk_stop_msg, blk_endpoint); in virtio_blk_stop()
388 spdk_thread_send_msg(blk_endpoint->virtio.thread, _virtio_blk_stop_msg, blk_endpoint); in bdev_event_cb()
392 spdk_thread_send_msg(blk_endpoint->init_thread, _vfu_virtio_blk_bdev_close, in bdev_event_cb()
547 spdk_thread_send_msg(blk_endpoint->init_thread, _vfu_virtio_blk_bdev_close, in vfu_virtio_blk_endpoint_destruct()
H A Dvfu_virtio_scsi.c744 spdk_thread_send_msg(scsi_endpoint->virtio.thread, vfu_virtio_scsi_lun_resize_msg, ctx); in vfu_virtio_scsi_lun_resize()
810 spdk_thread_send_msg(scsi_endpoint->virtio.thread, vfu_virtio_scsi_lun_hotremove_msg, ctx); in vfu_virtio_scsi_lun_hotremove()
900 spdk_thread_send_msg(virtio_endpoint->thread, vfu_virtio_scsi_lun_hotplug_msg, ctx); in vfu_virtio_scsi_add_target()
947 spdk_thread_send_msg(scsi_endpoint->virtio.thread, vfu_virtio_scsi_lun_hotremove_msg, ctx); in vfu_virtio_scsi_remove_target()
/spdk/lib/thread/
H A Dspdk_thread.map34 spdk_thread_send_msg;
H A Dthread.c747 spdk_thread_send_msg(thread, _thread_exit, thread); in spdk_thread_destroy()
1203 spdk_thread_send_msg(thread, _thread_exit, thread); in spdk_thread_next_poller_expiration()
1403 spdk_thread_send_msg(const struct spdk_thread *thread, spdk_msg_fn fn, void *ctx) in spdk_thread_send_msg()
1840 spdk_thread_send_msg(thread, _thread_remove_pollers, thread); in spdk_poller_pause()
2073 rc = spdk_thread_send_msg(ct->orig_thread, _back_to_orig_thread, ctx);
2078 rc = spdk_thread_send_msg(ct->cur_thread, _on_thread, ctx); in poller_set_interrupt_mode()
2119 rc = spdk_thread_send_msg(ct->cur_thread, _on_thread, ct); in spdk_thread_set_interrupt_mode()
2260 rc = spdk_thread_send_msg(dev->unregister_thread, _finish_unregister, dev); in spdk_io_device_unregister()
2514 rc = spdk_thread_send_msg(thread, put_io_channel, ch);
2666 rc = spdk_thread_send_msg(threa in spdk_for_each_channel_continue()
1359 spdk_thread_send_msg(const struct spdk_thread *thread, spdk_msg_fn fn, void *ctx) spdk_thread_send_msg() function
[all...]
/spdk/module/bdev/compress/
H A Dvbdev_compress.c311 * by 'spdk_thread_send_msg'. in _device_unregister_cb()
319 spdk_thread_send_msg(spdk_get_thread(), _comp_submit_unmap_split, split_ctx);
512 spdk_thread_send_msg(comp_bdev->thread, in _vbdev_reduce_init_cb()
570 spdk_thread_send_msg(comp_bdev->reduce_thread, in comp_reduce_io_cb()
724 spdk_thread_send_msg(comp_bdev->reduce_thread, in _prepare_for_load_init()
790 spdk_thread_send_msg(comp_bdev->thread, _vbdev_reduce_init_cb, init_ctx); in comp_bdev_ch_create_cb()
1144 spdk_thread_send_msg(comp_bdev->reduce_thread, in vbdev_reduce_load_cb()
1380 spdk_thread_send_msg(ctx->orig_thread, _vbdev_compress_delete_done, ctx);
1507 spdk_thread_send_msg(comp_bdev->thread, _vbdev_reduce_load_cb, comp_bdev);
/spdk/lib/vhost/
H A Drte_vhost_user.c1159 spdk_thread_send_msg(vdev->thread, vhost_user_session_start, vsession);
1307 spdk_thread_send_msg(spdk_get_thread(), vhost_user_session_stop_event, arg1);
1327 spdk_thread_send_msg(vdev->thread, vhost_user_session_stop_event, &ev_ctx);
1344 spdk_thread_send_msg(spdk_get_thread(),
1369 spdk_thread_send_msg(spdk_get_thread(), foreach_session, arg1);
1382 spdk_thread_send_msg(g_vhost_user_init_thread, foreach_session_finish_cb, arg1);
1411 spdk_thread_send_msg(vdev->thread, foreach_session, ev_ctx);
1842 spdk_thread_send_msg(vdev->thread, vhost_dev_thread_exit, NULL);
1919 spdk_thread_send_msg(vdev->thread, vhost_dev_thread_exit, NULL);
1991 spdk_thread_send_msg(g_vhost_user_init_threa
[all...]
/spdk/module/bdev/iscsi/
H A Dbdev_iscsi.c240 spdk_thread_send_msg(iscsi_io->submit_td, _bdev_iscsi_io_complete, iscsi_io); in bdev_iscsi_io_complete()
278 spdk_thread_send_msg(iscsi_io->lun->main_td, in bdev_iscsi_command_cb()
425 spdk_thread_send_msg(lun->no_main_ch_poller_td, bdev_iscsi_destruct_cb, lun); in bdev_iscsi_destruct()
523 spdk_thread_send_msg(lun->main_td, _bdev_iscsi_reset, bdev_io); in bdev_iscsi_reset()
647 spdk_thread_send_msg(lun->main_td, _bdev_iscsi_submit_request, bdev_io); in bdev_iscsi_submit_request()
739 spdk_thread_send_msg(thread, _iscsi_destroy_cb, lun); in bdev_iscsi_destroy_cb()
/spdk/lib/iscsi/
H A Dconn.c262 spdk_thread_send_msg(spdk_io_channel_get_thread(spdk_io_channel_from_ctx(pg)), in iscsi_conn_construct()
511 spdk_thread_send_msg(spdk_io_channel_get_thread(spdk_io_channel_from_ctx(conn->pg)), in iscsi_conn_hotremove_lun()
750 spdk_thread_send_msg(spdk_get_thread(), iscsi_conn_check_shutdown_cb, NULL); in iscsi_send_logout_request()
825 spdk_thread_send_msg(thread, _iscsi_conn_request_logout, conn); in iscsi_conns_request_logout()
921 spdk_thread_send_msg(thread, _iscsi_conn_drop, xconn); in iscsi_drop_conns()
1600 spdk_thread_send_msg(spdk_io_channel_get_thread(spdk_io_channel_from_ctx(pg)), in iscsi_conn_get_state()
/spdk/test/bdev/bdevio/
H A Dbdevio.c64 spdk_thread_send_msg(g_thread_io, fn, arg); in execute_spdk_function()
1269 spdk_thread_send_msg(g_thread_init, __stop_init_thread, request); in stop_init_thread()
1403 spdk_thread_send_msg(g_thread_ut, __run_ut_thread, NULL); in __construct_targets()
1443 spdk_thread_send_msg(g_thread_init, __construct_targets, NULL); in test_main()
1529 spdk_thread_send_msg(g_thread_ut, __run_ut_thread, request); in rpc_perform_tests()
1542 spdk_thread_send_msg(g_thread_init, __stop_init_thread, NULL); in spdk_bdevio_shutdown_cb()
/spdk/lib/ftl/utils/
H A Dftl_md.c886 spdk_thread_send_msg(spdk_get_thread(), exception, primary); in persist_mirror_cb()
911 spdk_thread_send_msg(spdk_get_thread(), exception, md); in ftl_md_persist()
1021 spdk_thread_send_msg(spdk_get_thread(), exception, md); in ftl_md_restore()
1083 spdk_thread_send_msg(spdk_get_thread(), exception, md); in ftl_md_clear()
1091 spdk_thread_send_msg(spdk_get_thread(), exception, md); in ftl_md_clear()
/spdk/lib/vfu_tgt/
H A Dtgt_endpoint.c550 spdk_thread_send_msg(endpoint->thread, tgt_endpoint_thread_try_exit, endpoint); in tgt_endpoint_thread_exit()
685 spdk_thread_send_msg(endpoint->thread, tgt_endpoint_start_thread, endpoint);
706 spdk_thread_send_msg(endpoint->thread, tgt_endpoint_thread_exit, endpoint); in spdk_vfu_init()
834 spdk_thread_send_msg(endpoint->thread, tgt_endpoint_thread_exit, endpoint);

1234