Lines Matching defs:pg
4175 nvmf_poll_group_get_io_qpair_count(struct spdk_nvmf_poll_group *pg)
4183 pthread_mutex_lock(&pg->mutex);
4184 count = pg->stat.current_io_qpairs + pg->current_unassociated_qpairs;
4185 pthread_mutex_unlock(&pg->mutex);
4194 struct spdk_nvmf_rdma_poll_group **pg;
4205 pg = &rtransport->conn_sched.next_admin_pg;
4210 pg = &rtransport->conn_sched.next_io_pg;
4211 pg_min = *pg;
4212 pg_start = *pg;
4213 pg_current = *pg;
4233 *pg = pg_min;
4236 assert(*pg != NULL);
4238 result = &(*pg)->group;
4240 *pg = TAILQ_NEXT(*pg, link);
4241 if (*pg == NULL) {
4242 *pg = TAILQ_FIRST(&rtransport->poll_groups);