Lines Matching defs:pg
993 struct spdk_iscsi_poll_group *pg = ctx_buf;
995 STAILQ_INIT(&pg->connections);
996 pg->sock_group = spdk_sock_group_create(NULL);
997 assert(pg->sock_group != NULL);
999 pg->poller = SPDK_POLLER_REGISTER(iscsi_poll_group_poll, pg, 0);
1001 pg->nop_poller = SPDK_POLLER_REGISTER(iscsi_poll_group_handle_nop, pg, 1000000);
1009 struct spdk_iscsi_poll_group *pg = ctx_buf;
1013 assert(pg->poller != NULL);
1014 assert(pg->sock_group != NULL);
1016 spdk_sock_group_close(&pg->sock_group);
1017 spdk_poller_unregister(&pg->poller);
1018 spdk_poller_unregister(&pg->nop_poller);
1020 ch = spdk_io_channel_from_ctx(pg);
1031 struct spdk_iscsi_poll_group *pg = ctx;
1033 TAILQ_INSERT_TAIL(&g_iscsi.poll_group_head, pg, link);
1043 struct spdk_iscsi_poll_group *pg;
1046 pg = spdk_io_channel_get_ctx(ch);
1048 spdk_thread_send_msg(g_init_thread, _iscsi_init_thread_done, pg);
1199 struct spdk_iscsi_poll_group *pg;
1202 pg = spdk_io_channel_get_ctx(ch);
1205 TAILQ_REMOVE(&g_iscsi.poll_group_head, pg, link);