Lines Matching defs:rgroup
509 struct spdk_nvmf_rdma_poll_group *rgroup;
1645 struct spdk_nvmf_rdma_poll_group *rgroup;
1653 rgroup = rqpair->poller->group;
1665 rc = spdk_nvmf_request_get_buffers(req, &rgroup->group, &rtransport->transport,
1677 rc = nvmf_request_get_stripped_buffers(req, &rgroup->group,
1717 spdk_nvmf_request_free_buffers(req, &rgroup->group, &rtransport->transport);
1729 struct spdk_nvmf_rdma_poll_group *rgroup;
1739 rgroup = rqpair->poller->group;
1773 rc = spdk_nvmf_request_get_buffers(req, &rgroup->group, &rtransport->transport, total_length);
1783 rc = nvmf_request_get_stripped_buffers(req, &rgroup->group,
1839 spdk_nvmf_request_free_buffers(req, &rgroup->group, &rtransport->transport);
1959 struct spdk_nvmf_rdma_poll_group *rgroup;
1963 rgroup = rqpair->poller->group;
1965 spdk_nvmf_request_free_buffers(&rdma_req->req, &rgroup->group, &rtransport->transport);
2051 nvmf_rdma_poll_group_insert_need_buffer_req(struct spdk_nvmf_rdma_poll_group *rgroup,
2063 STAILQ_INSERT_TAIL(&rgroup->group.pending_buf_queue, &rdma_req->req, buf_link);
2070 r = STAILQ_FIRST(&rgroup->group.pending_buf_queue);
2072 STAILQ_INSERT_HEAD(&rgroup->group.pending_buf_queue, &rdma_req->req, buf_link);
2080 STAILQ_INSERT_AFTER(&rgroup->group.pending_buf_queue, r, &rdma_req->req, buf_link);
2094 struct spdk_nvmf_rdma_poll_group *rgroup;
2105 rgroup = rqpair->poller->group;
2114 STAILQ_REMOVE(&rgroup->group.pending_buf_queue, &rdma_req->req, spdk_nvmf_request, buf_link);
2195 nvmf_rdma_poll_group_insert_need_buffer_req(rgroup, rdma_req);
2203 if (&rdma_req->req != STAILQ_FIRST(&rgroup->group.pending_buf_queue)) {
2211 STAILQ_REMOVE_HEAD(&rgroup->group.pending_buf_queue, buf_link);
2219 rgroup->stat.pending_data_buffer++;
2223 STAILQ_REMOVE_HEAD(&rgroup->group.pending_buf_queue, buf_link);
3153 struct spdk_nvmf_rdma_poll_group *rgroup;
3169 TAILQ_FOREACH(rgroup, &rtransport->poll_groups, link) {
3173 TAILQ_FOREACH(rgroup, &rtransport->poll_groups, link) {
3175 TAILQ_FOREACH(rpoller, &rgroup->pollers, link) {
3196 ctx->rgroup = rgroup;
3203 poll_group = rgroup->group.group;
3566 struct spdk_nvmf_rdma_poll_group *rgroup;
3570 TAILQ_FOREACH(rgroup, &rtransport->poll_groups, link) {
3571 TAILQ_FOREACH(rpoller, &rgroup->pollers, link) {
4034 struct spdk_nvmf_rdma_poll_group *rgroup, struct spdk_nvmf_rdma_device *device,
4049 poller->group = rgroup;
4056 TAILQ_INSERT_TAIL(&rgroup->pollers, poller, link);
4057 SPDK_DEBUGLOG(rdma, "Create poller %p on device %p in poll group %p.\n", poller, device, rgroup);
4120 rc = nvmf_rdma_poller_create(ctx->rtransport, ctx->rgroup, ctx->device, &poller);
4138 struct spdk_nvmf_rdma_poll_group *rgroup;
4150 rgroup = calloc(1, sizeof(*rgroup));
4151 if (!rgroup) {
4155 TAILQ_INIT(&rgroup->pollers);
4158 rc = nvmf_rdma_poller_create(rtransport, rgroup, device, &poller);
4160 nvmf_rdma_poll_group_destroy(&rgroup->group);
4165 TAILQ_INSERT_TAIL(&rtransport->poll_groups, rgroup, link);
4167 rtransport->conn_sched.next_admin_pg = rgroup;
4168 rtransport->conn_sched.next_io_pg = rgroup;
4171 return &rgroup->group;
4285 struct spdk_nvmf_rdma_poll_group *rgroup, *next_rgroup;
4289 rgroup = SPDK_CONTAINEROF(group, struct spdk_nvmf_rdma_poll_group, group);
4290 if (!rgroup) {
4294 TAILQ_FOREACH_SAFE(poller, &rgroup->pollers, link, tmp) {
4298 if (rgroup->group.transport == NULL) {
4301 free(rgroup);
4305 rtransport = SPDK_CONTAINEROF(rgroup->group.transport, struct spdk_nvmf_rdma_transport, transport);
4307 next_rgroup = TAILQ_NEXT(rgroup, link);
4308 TAILQ_REMOVE(&rtransport->poll_groups, rgroup, link);
4312 if (rtransport->conn_sched.next_admin_pg == rgroup) {
4315 if (rtransport->conn_sched.next_io_pg == rgroup) {
4319 free(rgroup);
4334 struct spdk_nvmf_rdma_poll_group *rgroup;
4340 rgroup = SPDK_CONTAINEROF(group, struct spdk_nvmf_rdma_poll_group, group);
4345 TAILQ_FOREACH(poller, &rgroup->pollers, link) {
4918 struct spdk_nvmf_rdma_poll_group *rgroup;
4923 rgroup = SPDK_CONTAINEROF(group, struct spdk_nvmf_rdma_poll_group, group);
4925 TAILQ_FOREACH_SAFE(rpoller, &rgroup->pollers, link, tmp) {
5154 struct spdk_nvmf_rdma_poll_group *rgroup;
5159 rgroup = SPDK_CONTAINEROF(group, struct spdk_nvmf_rdma_poll_group, group);
5161 spdk_json_write_named_uint64(w, "pending_data_buffer", rgroup->stat.pending_data_buffer);
5165 TAILQ_FOREACH(rpoller, &rgroup->pollers, link) {