Lines Matching defs:fn
46 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);
883 msg->fn(msg->arg);
988 rc = poller->fn(poller->arg);
1049 rc = poller->fn(poller->arg);
1097 thread->pp_handlers[i].fn(thread->pp_handlers[i].fn_arg);
1098 thread->pp_handlers[i].fn = NULL;
1403 spdk_thread_send_msg(const struct spdk_thread *thread, spdk_msg_fn fn, void *ctx)
1436 msg->fn = fn;
1450 spdk_thread_send_critical_msg(struct spdk_thread *thread, spdk_msg_fn fn)
1454 if (!__atomic_compare_exchange_n(&thread->critical_msg, &expected, fn, false, __ATOMIC_SEQ_CST,
1480 SPDK_DTRACE_PROBE2(timerfd_exec, poller->fn, poller->arg);
1482 return poller->fn(poller->arg);
1588 poller->intr = spdk_interrupt_register(busy_efd, poller->fn, poller->arg, poller->name);
1691 poller_register(spdk_poller_fn fn,
1719 snprintf(poller->name, sizeof(poller->name), "%p", fn);
1723 poller->fn = fn;
1776 spdk_poller_register(spdk_poller_fn fn,
1780 return poller_register(fn, arg, period_microseconds, NULL);
1784 spdk_poller_register_named(spdk_poller_fn fn,
1789 return poller_register(fn, arg, period_microseconds, name);
2034 spdk_msg_fn fn;
2059 ct->fn(ct->ctx);
2084 spdk_for_each_thread(spdk_msg_fn fn, void *ctx, spdk_msg_fn cpl)
2097 ct->fn = fn;
2552 spdk_channel_msg fn;
2604 * the fn() on this thread.
2611 i->fn(i);
2618 spdk_for_each_channel(void *io_device, spdk_channel_msg fn, void *ctx,
2634 i->fn = fn;
2849 intr->fn, intr->arg);
2851 rc = intr->fn(intr->arg);
2861 spdk_interrupt_register(int efd, spdk_interrupt_fn fn,
2864 return spdk_interrupt_register_for_events(efd, SPDK_INTERRUPT_EVENT_IN, fn, arg, name);
2868 spdk_interrupt_register_for_events(int efd, uint32_t events, spdk_interrupt_fn fn, void *arg,
2877 return spdk_interrupt_register_ext(efd, fn, arg, name, &opts);
2881 alloc_interrupt(int efd, struct spdk_fd_group *fgrp, spdk_interrupt_fn fn, void *arg,
2907 snprintf(intr->name, sizeof(intr->name), "%p", fn);
2914 intr->fn = fn;
2921 spdk_interrupt_register_ext(int efd, spdk_interrupt_fn fn, void *arg, const char *name,
2927 intr = alloc_interrupt(efd, NULL, fn, arg, name);
3257 spdk_thread_register_post_poller_handler(spdk_post_poller_fn fn, void *fn_arg)
3268 thr->pp_handlers[thr->num_pp_handlers].fn = fn;