Home
last modified time | relevance | path

Searched refs:fn (Results 1 – 25 of 49) sorted by relevance

12

/spdk/test/unit/lib/blob/
H A Dbs_scheduler.c11 spdk_msg_fn fn; member
22 _bs_send_msg(spdk_msg_fn fn, void *ctx, void *thread_ctx) in _bs_send_msg() argument
28 ops->fn = fn; in _bs_send_msg()
33 fn(ctx); in _bs_send_msg()
50 op->fn(op->ctx); in _bs_flush_scheduler_single()
/spdk/lib/util/
H A Dfd_group.c35 spdk_fd_fn fn;
376 spdk_fd_group_add(struct spdk_fd_group *fgrp, int efd, spdk_fd_fn fn,
379 return spdk_fd_group_add_for_events(fgrp, efd, EPOLLIN, fn, arg, name); in spdk_fd_group_create()
384 spdk_fd_fn fn, void *arg, const char *name) in spdk_fd_group_create()
392 return spdk_fd_group_add_ext(fgrp, efd, fn, arg, name, &opts); in spdk_fd_group_create()
396 spdk_fd_group_add_ext(struct spdk_fd_group *fgrp, int efd, spdk_fd_fn fn, void *arg, in spdk_fd_group_create()
406 if (fgrp == NULL || efd < 0 || fn == NULL) {
429 ehdlr->fn = fn; in spdk_fd_group_wait()
646 if (ehdlr == NULL || ehdlr->fn
40 spdk_fd_fn fn; global() member
228 spdk_fd_group_add(struct spdk_fd_group * fgrp,int efd,spdk_fd_fn fn,void * arg,const char * name) spdk_fd_group_add() argument
236 spdk_fd_group_add_for_events(struct spdk_fd_group * fgrp,int efd,uint32_t events,spdk_fd_fn fn,void * arg,const char * name) spdk_fd_group_add_for_events() argument
510 spdk_fd_group_add(struct spdk_fd_group * fgrp,int efd,spdk_fd_fn fn,void * arg,const char * name) spdk_fd_group_add() argument
517 spdk_fd_group_add_for_events(struct spdk_fd_group * fgrp,int efd,uint32_t events,spdk_fd_fn fn,void * arg,const char * name) spdk_fd_group_add_for_events() argument
[all...]
H A Dcpuset.c109 void (*fn)(void *ctx, uint32_t cpu), void *ctx) in spdk_cpuset_for_each_cpu()
117 fn(ctx, i * 8 + j); in spdk_cpuset_for_each_cpu()
/spdk/test/app/fuzz/llvm_nvme_fuzz/
H A Dllvm_nvme_fuzz.c40 fuzz_build_cmd_fn fn; member
704 { .fn = fuzz_admin_command, .bytes_per_cmd = sizeof(struct spdk_nvme_cmd), .is_admin = true},
705 { .fn = fuzz_admin_get_log_page_command, .bytes_per_cmd = 6, .is_admin = true},
706 { .fn = fuzz_admin_identify_command, .bytes_per_cmd = 7, .is_admin = true},
707 { .fn = fuzz_admin_abort_command, .bytes_per_cmd = 4, .is_admin = true},
708 { .fn = fuzz_admin_create_io_completion_queue_command, .bytes_per_cmd = 7, .is_admin = true},
709 { .fn = fuzz_admin_create_io_submission_queue_command, .bytes_per_cmd = 9, .is_admin = true},
710 { .fn = fuzz_admin_delete_io_completion_queue_command, .bytes_per_cmd = 2, .is_admin = true},
711 { .fn = fuzz_admin_delete_io_submission_queue_command, .bytes_per_cmd = 2, .is_admin = true},
712 { .fn = fuzz_admin_namespace_attachment_command, .bytes_per_cmd = 1, .is_admin = true},
[all …]
/spdk/lib/thread/
H A Dthread.c46 spdk_interrupt_fn fn;
52 /* The poller is registered with a thread but not currently executing its fn. */
55 /* The poller is currently running its fn. */
58 /* The poller was unregistered during the execution of its fn. */
84 spdk_poller_fn fn;
108 spdk_post_poller_fn fn;
296 spdk_msg_fn fn;
881 SPDK_DTRACE_PROBE2(msg_exec, msg->fn, msg->arg); in poller_insert_timer()
883 msg->fn(msg->arg); in poller_insert_timer()
988 rc = poller->fn(polle in thread_execute_poller()
45 spdk_interrupt_fn fn; global() member
83 spdk_poller_fn fn; global() member
276 spdk_msg_fn fn; global() member
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
1648 poller_register(spdk_poller_fn fn,void * arg,uint64_t period_microseconds,const char * name) poller_register() argument
1733 spdk_poller_register(spdk_poller_fn fn,void * arg,uint64_t period_microseconds) spdk_poller_register() argument
1741 spdk_poller_register_named(spdk_poller_fn fn,void * arg,uint64_t period_microseconds,const char * name) spdk_poller_register_named() argument
1985 spdk_msg_fn fn; global() member
2035 spdk_for_each_thread(spdk_msg_fn fn,void * ctx,spdk_msg_fn cpl) spdk_for_each_thread() argument
2507 spdk_channel_msg fn; global() member
2573 spdk_for_each_channel(void * io_device,spdk_channel_msg fn,void * ctx,spdk_channel_for_each_cpl cpl) spdk_for_each_channel() argument
2820 spdk_interrupt_register(int efd,spdk_interrupt_fn fn,void * arg,const char * name) spdk_interrupt_register() argument
2827 spdk_interrupt_register_for_events(int efd,uint32_t events,spdk_interrupt_fn fn,void * arg,const char * name) spdk_interrupt_register_for_events() argument
[all...]
/spdk/test/app/fuzz/llvm_vfio_fuzz/
H A Dllvm_vfio_fuzz.c28 fuzzer_fn fn; member
206 { .fn = fuzz_vfio_user_region_rw, .bytes_per_cmd = 6},
207 { .fn = fuzz_vfio_user_version, .bytes_per_cmd = 4},
208 { .fn = fuzz_vfio_user_get_region_info, .bytes_per_cmd = 8},
209 { .fn = fuzz_vfio_user_dma_map, .bytes_per_cmd = 32},
210 { .fn = fuzz_vfio_user_dma_unmap, .bytes_per_cmd = 32},
211 { .fn = fuzz_vfio_user_irq_set, .bytes_per_cmd = 13},
212 { .fn = fuzz_vfio_user_set_msix, .bytes_per_cmd = 9},
213 { .fn = NULL, .bytes_per_cmd = 0}
247 if (g_fuzzer->fn ! in TestOneInput()
[all...]
/spdk/lib/nvme/
H A Dnvme_io_msg.c15 nvme_io_msg_send(struct spdk_nvme_ctrlr *ctrlr, uint32_t nsid, spdk_nvme_io_msg_fn fn, in nvme_io_msg_send() argument
33 io->fn = fn; in nvme_io_msg_send()
84 io->fn(io->ctrlr, io->nsid, io->arg); in nvme_io_msg_process()
H A Dnvme_io_msg.h21 spdk_nvme_io_msg_fn fn; member
32 int nvme_io_msg_send(struct spdk_nvme_ctrlr *ctrlr, uint32_t nsid, spdk_nvme_io_msg_fn fn,
/spdk/lib/ftl/
H A Dftl_band.h203 ftl_band_state_change_fn fn, in ftl_band_set_owner() argument
209 band->owner.state_change_fn = fn; in ftl_band_set_owner()
215 ftl_band_state_change_fn fn, in ftl_band_clear_owner() argument
219 assert(fn == band->owner.state_change_fn); in ftl_band_clear_owner()
/spdk/test/unit/lib/blobfs/blobfs_bdev.c/
H A Dblobfs_bdev_ut.c126 spdk_thread_send_msg(const struct spdk_thread *thread, spdk_msg_fn fn, void *ctx) in spdk_thread_send_msg() argument
128 fn(ctx); in spdk_thread_send_msg()
152 blobfs_fuse_send_request(fs_request_fn fn, void *arg) in blobfs_fuse_send_request() argument
/spdk/test/unit/lib/blobfs/blobfs_sync_ut/
H A Dblobfs_sync_ut.c26 fs_request_fn fn; member
37 send_request(fs_request_fn fn, void *arg) in send_request() argument
39 spdk_thread_send_msg(g_dispatch_thread, (spdk_msg_fn)fn, arg); in send_request()
47 req->fn(req->arg); in ut_call_fn()
52 ut_send_request(fs_request_fn fn, void *arg) in ut_send_request() argument
56 req.fn = fn; in ut_send_request()
/spdk/test/unit/lib/ftl/ftl_mngt/
H A Dftl_mngt_ut.c26 spdk_msg_fn fn; member
33 spdk_thread_send_msg(const struct spdk_thread *thread, spdk_msg_fn fn, void *ctx) in spdk_thread_send_msg() argument
35 g_thread_send_msg_container.fn = fn; in spdk_thread_send_msg()
86 g_thread_send_msg_container.fn = NULL; in fn_finish()
100 while (g_thread_send_msg_container.fn != NULL) { in run_ftl_mngt_with_cb_cntx()
101 g_thread_send_msg_container.fn(g_thread_send_msg_container.ctx); in run_ftl_mngt_with_cb_cntx()
/spdk/lib/event/
H A Dreactor.c388 _event_call(uint32_t lcore, spdk_event_fn fn, void *arg1, void *arg2) in _reactor_set_interrupt_mode()
392 ev = spdk_event_allocate(lcore, fn, arg1, arg2); in _reactor_set_interrupt_mode()
532 spdk_event_allocate(uint32_t lcore, spdk_event_fn fn, void *arg1, void *arg2) in spdk_event_call()
549 event->fn = fn; in event_queue_run_batch()
637 SPDK_DTRACE_PROBE3(event_exec, event->fn, in spdk_framework_enable_context_switch_monitor()
639 event->fn(event->arg1, event->arg2); in spdk_framework_enable_context_switch_monitor()
1008 /* Execute interrupt process fn if this reactor currently runs in interrupt state */ in reactor_run()
1385 spdk_event_fn fn; in spdk_for_each_reactor()
1399 cr->fn(c in reactor_schedule_thread_event()
339 _event_call(uint32_t lcore,spdk_event_fn fn,void * arg1,void * arg2) _event_call() argument
483 spdk_event_allocate(uint32_t lcore,spdk_event_fn fn,void * arg1,void * arg2) spdk_event_allocate() argument
1317 spdk_event_fn fn; global() member
1351 spdk_for_each_reactor(spdk_event_fn fn,void * arg1,void * arg2,spdk_event_fn cpl) spdk_for_each_reactor() argument
[all...]
/spdk/lib/log/
H A Dlog_deprecated.c107 spdk_log_for_each_deprecation(void *ctx, spdk_log_for_each_deprecation_fn fn) in spdk_log_for_each_deprecation() argument
113 rc = fn(ctx, dep); in spdk_log_for_each_deprecation()
/spdk/module/blobfs/bdev/
H A Dblobfs_fuse.h14 void blobfs_fuse_send_request(fs_request_fn fn, void *arg);
H A Dblobfs_fuse.c50 blobfs_fuse_send_request(fs_request_fn fn, void *arg) in blobfs_fuse_send_request() argument
52 spdk_thread_send_msg(spdk_thread_get_app_thread(), fn, arg); in blobfs_fuse_send_request()
/spdk/include/spdk/
H A Dkeyring.h98 void (*fn)(void *ctx, struct spdk_key *key), uint32_t flags);
H A Dhistogram_data.h155 spdk_histogram_data_fn fn, void *ctx) in spdk_histogram_data_iterate() argument
177 fn(ctx, last_bucket, bucket, count, total, so_far); in spdk_histogram_data_iterate()
H A Dcpuset.h126 void (*fn)(void *ctx, uint32_t cpu), void *ctx);
/spdk/module/bdev/ocf/
H A Dutils.h32 void vbdev_ocf_mngt_poll(struct vbdev_ocf *vbdev, vbdev_ocf_mngt_fn fn);
H A Dvbdev_ocf.h204 void vbdev_ocf_foreach(vbdev_ocf_foreach_fn fn, void *ctx);
/spdk/lib/accel/
H A Daccel_internal.h47 void _accel_for_each_module(struct module_info *info, _accel_for_each_module_fn fn);
/spdk/lib/keyring/
H A Dkeyring.c307 void *ctx, void (*fn)(void *ctx, struct spdk_key *key), uint32_t flags) in spdk_keyring_for_each_key()
314 fn(ctx, key); in spdk_keyring_for_each_key()
319 fn(ctx, key); in spdk_keyring_register_module()
/spdk/module/scheduler/dynamic/
H A Dscheduler_dynamic.c57 _foreach_thread(struct spdk_scheduler_core_info *cores_info, _foreach_fn fn) in _foreach_thread()
69 fn(&core->thread_infos[j]);
56 _foreach_thread(struct spdk_scheduler_core_info * cores_info,_foreach_fn fn) _foreach_thread() argument
/spdk/test/common/lib/
H A Dut_multithread.c21 spdk_msg_fn fn; member

12