Lines Matching defs:sgroup

156 	struct spdk_nvmf_subsystem_poll_group *sgroup;
165 		sgroup = &group->sgroups[sid];
167 		assert(sgroup != NULL);
169 		for (nsid = 0; nsid < sgroup->num_ns; nsid++) {
170 			if (sgroup->ns_info[nsid].channel) {
171 				spdk_put_io_channel(sgroup->ns_info[nsid].channel);
172 				sgroup->ns_info[nsid].channel = NULL;
176 		free(sgroup->ns_info);
1314 _nvmf_qpair_sgroup_req_clean(struct spdk_nvmf_subsystem_poll_group *sgroup,
1318 	TAILQ_FOREACH_SAFE(req, &sgroup->queued, link, tmp) {
1320 			TAILQ_REMOVE(&sgroup->queued, req, link);
1334 	struct spdk_nvmf_subsystem_poll_group *sgroup;
1356 		sgroup = &qpair->group->sgroups[ctrlr->subsys->id];
1357 		_nvmf_qpair_sgroup_req_clean(sgroup, qpair);
1360 			sgroup = &qpair->group->sgroups[sid];
1361 			assert(sgroup != NULL);
1362 			_nvmf_qpair_sgroup_req_clean(sgroup, qpair);
1466 	struct spdk_nvmf_subsystem_poll_group *sgroup;
1480 	sgroup = &group->sgroups[subsystem->id];
1483 	if (sgroup->num_ns == 0 && subsystem->max_nsid > 0) {
1485 		sgroup->ns_info = calloc(subsystem->max_nsid, sizeof(struct spdk_nvmf_subsystem_pg_ns_info));
1486 		if (!sgroup->ns_info) {
1489 		sgroup->num_ns = subsystem->max_nsid;
1495 	for (i = 0; i < sgroup->num_ns; i++) {
1497 		ns_info = &sgroup->ns_info[i];
1608 	struct spdk_nvmf_subsystem_poll_group *sgroup = &group->sgroups[subsystem->id];
1612 	if (!TAILQ_EMPTY(&sgroup->queued)) {
1613 		SPDK_ERRLOG("sgroup->queued not empty when adding subsystem\n");
1614 		TAILQ_FOREACH_SAFE(req, &sgroup->queued, link, tmp) {
1615 			TAILQ_REMOVE(&sgroup->queued, req, link);
1628 	sgroup->state = SPDK_NVMF_SUBSYSTEM_ACTIVE;
1630 	for (i = 0; i < sgroup->num_ns; i++) {
1631 		sgroup->ns_info[i].state = SPDK_NVMF_SUBSYSTEM_ACTIVE;
1651 	struct spdk_nvmf_subsystem_poll_group *sgroup;
1660 	sgroup = &group->sgroups[subsystem->id];
1666 	for (nsid = 0; nsid < sgroup->num_ns; nsid++) {
1667 		if (sgroup->ns_info[nsid].channel) {
1668 			spdk_put_io_channel(sgroup->ns_info[nsid].channel);
1669 			sgroup->ns_info[nsid].channel = NULL;
1673 	sgroup->num_ns = 0;
1674 	free(sgroup->ns_info);
1675 	sgroup->ns_info = NULL;
1722 	struct spdk_nvmf_subsystem_poll_group *sgroup;
1743 	sgroup = &group->sgroups[subsystem->id];
1744 	sgroup->state = SPDK_NVMF_SUBSYSTEM_INACTIVE;
1746 	for (i = 0; i < sgroup->num_ns; i++) {
1747 		sgroup->ns_info[i].state = SPDK_NVMF_SUBSYSTEM_INACTIVE;
1759 	struct spdk_nvmf_subsystem_poll_group *sgroup;
1769 	sgroup = &group->sgroups[subsystem->id];
1770 	if (sgroup->state == SPDK_NVMF_SUBSYSTEM_PAUSED) {
1773 	sgroup->state = SPDK_NVMF_SUBSYSTEM_PAUSING;
1776 		for (i = 0; i < sgroup->num_ns; i++) {
1777 			ns_info = &sgroup->ns_info[i];
1782 		if (nsid - 1 < sgroup->num_ns) {
1783 			ns_info  = &sgroup->ns_info[nsid - 1];
1788 	if (sgroup->mgmt_io_outstanding > 0) {
1789 		assert(sgroup->cb_fn == NULL);
1790 		sgroup->cb_fn = cb_fn;
1791 		assert(sgroup->cb_arg == NULL);
1792 		sgroup->cb_arg = cb_arg;
1797 		for (i = 0; i < sgroup->num_ns; i++) {
1798 			ns_info = &sgroup->ns_info[i];
1801 				assert(sgroup->cb_fn == NULL);
1802 				sgroup->cb_fn = cb_fn;
1803 				assert(sgroup->cb_arg == NULL);
1804 				sgroup->cb_arg = cb_arg;
1810 			assert(sgroup->cb_fn == NULL);
1811 			sgroup->cb_fn = cb_fn;
1812 			assert(sgroup->cb_arg == NULL);
1813 			sgroup->cb_arg = cb_arg;
1818 	assert(sgroup->mgmt_io_outstanding == 0);
1819 	sgroup->state = SPDK_NVMF_SUBSYSTEM_PAUSED;
1832 	struct spdk_nvmf_subsystem_poll_group *sgroup;
1841 	sgroup = &group->sgroups[subsystem->id];
1843 	if (sgroup->state == SPDK_NVMF_SUBSYSTEM_ACTIVE) {
1852 	for (i = 0; i < sgroup->num_ns; i++) {
1853 		sgroup->ns_info[i].state = SPDK_NVMF_SUBSYSTEM_ACTIVE;
1856 	sgroup->state = SPDK_NVMF_SUBSYSTEM_ACTIVE;
1859 	TAILQ_FOREACH_SAFE(req, &sgroup->queued, link, tmp) {
1860 		TAILQ_REMOVE(&sgroup->queued, req, link);