Lines Matching defs:fgrp

44 	struct spdk_fd_group	*fgrp;
163 struct spdk_fd_group *fgrp;
1235 rc = spdk_fd_group_wait(thread->fgrp, 0);
2740 struct spdk_fd_group *fgrp = thread->fgrp;
2742 SPDK_INFOLOG(thread, "destroy fgrp for thread (%s)\n", thread->name);
2748 spdk_fd_group_remove(fgrp, thread->msg_fd);
2752 spdk_fd_group_destroy(fgrp);
2753 thread->fgrp = NULL;
2805 SPDK_INFOLOG(thread, "Create fgrp for thread (%s)\n", thread->name);
2807 rc = spdk_fd_group_create(&thread->fgrp);
2816 spdk_fd_group_destroy(thread->fgrp);
2817 thread->fgrp = NULL;
2825 return SPDK_FD_GROUP_ADD_EXT(thread->fgrp, thread->msg_fd,
2881 alloc_interrupt(int efd, struct spdk_fd_group *fgrp, spdk_interrupt_fn fn, void *arg,
2910 assert(efd < 0 || fgrp == NULL);
2912 intr->fgrp = fgrp;
2932 ret = spdk_fd_group_add_ext(intr->thread->fgrp, efd,
2963 spdk_interrupt_register_fd_group(struct spdk_fd_group *fgrp, const char *name)
2968 intr = alloc_interrupt(-1, fgrp, NULL, NULL, name);
2973 rc = spdk_fd_group_set_wrapper(fgrp, interrupt_fd_group_wrapper, intr);
2976 intr->thread->name, spdk_fd_group_get_fd(fgrp), spdk_strerror(-rc));
2981 rc = spdk_fd_group_nest(intr->thread->fgrp, fgrp);
2984 intr->thread->name, spdk_fd_group_get_fd(fgrp), spdk_strerror(-rc));
2985 spdk_fd_group_set_wrapper(fgrp, NULL, NULL);
3017 if (intr->fgrp != NULL) {
3019 spdk_fd_group_unnest(thread->fgrp, intr->fgrp);
3020 spdk_fd_group_set_wrapper(thread->fgrp, NULL, NULL);
3022 spdk_fd_group_remove(thread->fgrp, intr->efd);
3050 return spdk_fd_group_event_modify(thread->fgrp, intr->efd, event_types);
3056 return spdk_fd_group_get_fd(thread->fgrp);
3062 return thread->fgrp;