Lines Matching defs:sgroup
976 struct spdk_nvmf_subsystem_poll_group *sgroup;
987 sgroup = nvmf_subsystem_pg_from_connect_cmd(req);
988 if (!sgroup) {
994 sgroup->mgmt_io_outstanding++;
1037 struct spdk_nvmf_subsystem_poll_group *sgroup;
1044 sgroup = nvmf_subsystem_pg_from_connect_cmd(req);
1045 assert(sgroup != NULL);
1046 sgroup->mgmt_io_outstanding--;
1048 TAILQ_INSERT_TAIL(&sgroup->queued, req, link);
3852 struct spdk_nvmf_subsystem_poll_group *sgroup;
3861 sgroup = &req->qpair->group->sgroups[ctrlr->subsys->id];
3862 assert(sgroup != NULL);
3863 sgroup->mgmt_io_outstanding--;
4684 struct spdk_nvmf_subsystem_poll_group *sgroup = NULL;
4699 sgroup = &qpair->group->sgroups[qpair->ctrlr->subsys->id];
4700 assert(sgroup != NULL);
4717 sgroup = nvmf_subsystem_pg_from_connect_cmd(req);
4752 if (spdk_likely(sgroup && !is_aer)) {
4755 assert(sgroup->mgmt_io_outstanding > 0);
4756 sgroup->mgmt_io_outstanding--;
4764 if (spdk_likely(nsid - 1 < sgroup->num_ns)) {
4765 sgroup->ns_info[nsid - 1].io_outstanding--;
4770 if (spdk_unlikely(sgroup->state == SPDK_NVMF_SUBSYSTEM_PAUSING &&
4771 sgroup->mgmt_io_outstanding == 0)) {
4773 for (nsid = 0; nsid < sgroup->num_ns; nsid++) {
4774 ns_info = &sgroup->ns_info[nsid];
4784 sgroup->state = SPDK_NVMF_SUBSYSTEM_PAUSED;
4785 sgroup->cb_fn(sgroup->cb_arg, 0);
4786 sgroup->cb_fn = NULL;
4787 sgroup->cb_arg = NULL;
4810 struct spdk_nvmf_subsystem_poll_group *sgroup = NULL;
4815 sgroup = &qpair->group->sgroups[qpair->ctrlr->subsys->id];
4816 assert(sgroup != NULL);
4818 sgroup = nvmf_subsystem_pg_from_connect_cmd(req);
4822 if (spdk_unlikely(sgroup == NULL)) {
4828 if (sgroup->state != SPDK_NVMF_SUBSYSTEM_ACTIVE) {
4830 TAILQ_INSERT_TAIL(&sgroup->queued, req, link);
4833 sgroup->mgmt_io_outstanding++;
4838 if (spdk_unlikely(nsid - 1 >= sgroup->num_ns)) {
4847 ns_info = &sgroup->ns_info[nsid - 1];
4864 TAILQ_INSERT_TAIL(&sgroup->queued, req, link);