Lines Matching refs:req_id
125 static inline int get_request(struct pvcalls_bedata *bedata, int *req_id)
127 *req_id = bedata->ring.req_prod_pvt & (RING_SIZE(&bedata->ring) - 1);
129 bedata->rsp[*req_id].req_id != PVCALLS_INVALID_ID)
171 int req_id = 0, more = 0, done = 0;
187 req_id = rsp->req_id;
203 dst = (uint8_t *)&bedata->rsp[req_id] +
204 sizeof(rsp->req_id);
205 src = (uint8_t *)rsp + sizeof(rsp->req_id);
206 memcpy(dst, src, sizeof(*rsp) - sizeof(rsp->req_id));
208 * First copy the rest of the data, then req_id. It is
212 bedata->rsp[req_id].req_id = req_id;
265 int notify, req_id, ret;
292 ret = get_request(bedata, &req_id);
309 req = RING_GET_REQUEST(&bedata->ring, req_id);
310 req->req_id = req_id;
324 READ_ONCE(bedata->rsp[req_id].req_id) == req_id);
326 /* read req_id, then the content */
328 ret = bedata->rsp[req_id].ret;
329 bedata->rsp[req_id].req_id = PVCALLS_INVALID_ID;
418 int notify, req_id, ret;
436 ret = get_request(bedata, &req_id);
451 req = RING_GET_REQUEST(&bedata->ring, req_id);
452 req->req_id = req_id;
471 READ_ONCE(bedata->rsp[req_id].req_id) == req_id);
473 /* read req_id, then the content */
475 ret = bedata->rsp[req_id].ret;
476 bedata->rsp[req_id].req_id = PVCALLS_INVALID_ID;
666 int notify, req_id, ret;
677 ret = get_request(bedata, &req_id);
683 req = RING_GET_REQUEST(&bedata->ring, req_id);
684 req->req_id = req_id;
702 READ_ONCE(bedata->rsp[req_id].req_id) == req_id);
704 /* read req_id, then the content */
706 ret = bedata->rsp[req_id].ret;
707 bedata->rsp[req_id].req_id = PVCALLS_INVALID_ID;
719 int notify, req_id, ret;
732 ret = get_request(bedata, &req_id);
738 req = RING_GET_REQUEST(&bedata->ring, req_id);
739 req->req_id = req_id;
751 READ_ONCE(bedata->rsp[req_id].req_id) == req_id);
753 /* read req_id, then the content */
755 ret = bedata->rsp[req_id].ret;
756 bedata->rsp[req_id].req_id = PVCALLS_INVALID_ID;
769 int notify, req_id, ret, nonblock;
789 req_id = READ_ONCE(map->passive.inflight_req_id);
790 if (req_id != PVCALLS_INVALID_ID &&
791 READ_ONCE(bedata->rsp[req_id].req_id) == req_id) {
823 ret = get_request(bedata, &req_id);
846 req = RING_GET_REQUEST(&bedata->ring, req_id);
847 req->req_id = req_id;
862 WRITE_ONCE(map->passive.inflight_req_id, req_id);
868 READ_ONCE(bedata->rsp[req_id].req_id) == req_id)) {
872 /* read req_id, then the content */
879 bedata->rsp[req_id].req_id = PVCALLS_INVALID_ID;
889 ret = bedata->rsp[req_id].ret;
890 bedata->rsp[req_id].req_id = PVCALLS_INVALID_ID;
905 int notify, req_id, ret;
910 uint32_t req_id = READ_ONCE(map->passive.inflight_req_id);
912 if (req_id != PVCALLS_INVALID_ID &&
913 READ_ONCE(bedata->rsp[req_id].req_id) == req_id)
937 ret = get_request(bedata, &req_id);
942 req = RING_GET_REQUEST(&bedata->ring, req_id);
943 req->req_id = req_id;
1004 int req_id, notify, ret;
1020 ret = get_request(bedata, &req_id);
1028 req = RING_GET_REQUEST(&bedata->ring, req_id);
1029 req->req_id = req_id;
1040 READ_ONCE(bedata->rsp[req_id].req_id) == req_id);
1077 WRITE_ONCE(bedata->rsp[req_id].req_id, PVCALLS_INVALID_ID);
1178 bedata->rsp[i].req_id = PVCALLS_INVALID_ID;