Lines Matching refs:recv_ioctx

1012 static int srpt_get_desc_tbl(struct srpt_recv_ioctx *recv_ioctx,  in srpt_get_desc_tbl()  argument
1074 if (recv_ioctx->byte_len < req_size) { in srpt_get_desc_tbl()
1076 recv_ioctx->byte_len, req_size); in srpt_get_desc_tbl()
1088 ioctx->recv_ioctx = recv_ioctx; in srpt_get_desc_tbl()
1232 WARN_ON_ONCE(ioctx->recv_ioctx); in srpt_get_send_ioctx()
1488 struct srpt_recv_ioctx *recv_ioctx, in srpt_handle_cmd() argument
1501 srp_cmd = recv_ioctx->ioctx.buf + recv_ioctx->ioctx.offset; in srpt_handle_cmd()
1521 rc = srpt_get_desc_tbl(recv_ioctx, send_ioctx, srp_cmd, &dir, in srpt_handle_cmd()
1581 struct srpt_recv_ioctx *recv_ioctx, in srpt_handle_tsk_mgmt() argument
1592 srp_tsk = recv_ioctx->ioctx.buf + recv_ioctx->ioctx.offset; in srpt_handle_tsk_mgmt()
1619 srpt_handle_new_iu(struct srpt_rdma_ch *ch, struct srpt_recv_ioctx *recv_ioctx) in srpt_handle_new_iu() argument
1627 BUG_ON(!recv_ioctx); in srpt_handle_new_iu()
1633 recv_ioctx->ioctx.dma, in srpt_handle_new_iu()
1634 recv_ioctx->ioctx.offset + srp_max_req_size, in srpt_handle_new_iu()
1637 srp_cmd = recv_ioctx->ioctx.buf + recv_ioctx->ioctx.offset; in srpt_handle_new_iu()
1645 if (!list_empty(&recv_ioctx->wait_list)) { in srpt_handle_new_iu()
1647 list_del_init(&recv_ioctx->wait_list); in srpt_handle_new_iu()
1652 srpt_handle_cmd(ch, recv_ioctx, send_ioctx); in srpt_handle_new_iu()
1655 srpt_handle_tsk_mgmt(ch, recv_ioctx, send_ioctx); in srpt_handle_new_iu()
1674 if (!send_ioctx || !send_ioctx->recv_ioctx) in srpt_handle_new_iu()
1675 srpt_post_recv(ch->sport->sdev, ch, recv_ioctx); in srpt_handle_new_iu()
1682 if (list_empty(&recv_ioctx->wait_list)) { in srpt_handle_new_iu()
1684 list_add_tail(&recv_ioctx->wait_list, &ch->cmd_wait_list); in srpt_handle_new_iu()
1716 struct srpt_recv_ioctx *recv_ioctx, *tmp; in srpt_process_wait_list() local
1725 list_for_each_entry_safe(recv_ioctx, tmp, &ch->cmd_wait_list, in srpt_process_wait_list()
1727 if (!srpt_handle_new_iu(ch, recv_ioctx)) in srpt_process_wait_list()
2746 if (ioctx->recv_ioctx) { in srpt_write_pending()
3319 struct srpt_recv_ioctx *recv_ioctx = ioctx->recv_ioctx; in srpt_release_cmd() local
3324 if (recv_ioctx) { in srpt_release_cmd()
3325 WARN_ON_ONCE(!list_empty(&recv_ioctx->wait_list)); in srpt_release_cmd()
3326 ioctx->recv_ioctx = NULL; in srpt_release_cmd()
3327 srpt_post_recv(ch->sport->sdev, ch, recv_ioctx); in srpt_release_cmd()