Lines Matching refs:req
129 struct p9_req_t *req;
136 while ((req = virtqueue_get_buf(chan->vq, &len)) != NULL) {
143 req->rc.size = len;
144 p9_client_cb(chan->client, req, REQ_STATUS_RCVD);
190 static int p9_virtio_cancel(struct p9_client *client, struct p9_req_t *req)
195 /* Reply won't come, so drop req ref */
196 static int p9_virtio_cancelled(struct p9_client *client, struct p9_req_t *req)
198 p9_req_put(req);
246 * @req: request to be issued
251 p9_virtio_request(struct p9_client *client, struct p9_req_t *req)
261 req->status = REQ_STATUS_SENT;
268 VIRTQUEUE_NUM, req->tc.sdata, req->tc.size);
273 VIRTQUEUE_NUM, req->rc.sdata, req->rc.capacity);
277 err = virtqueue_add_sgs(chan->vq, sgs, out_sgs, in_sgs, req,
378 * @req: request to be issued
387 p9_virtio_zc_request(struct p9_client *client, struct p9_req_t *req,
414 memcpy(&req->tc.sdata[req->tc.size - 4], &v, 4);
421 sz = cpu_to_le32(req->tc.size + outlen);
422 memcpy(&req->tc.sdata[0], &sz, sizeof(sz));
433 memcpy(&req->tc.sdata[req->tc.size - 4], &v, 4);
437 req->status = REQ_STATUS_SENT;
445 VIRTQUEUE_NUM, req->tc.sdata, req->tc.size);
464 VIRTQUEUE_NUM, req->rc.sdata, in_hdr_len);
475 err = virtqueue_add_sgs(chan->vq, sgs, out_sgs, in_sgs, req,
500 err = wait_event_killable(req->wq, req->status >= REQ_STATUS_RCVD);
521 p9_req_put(req);