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;
275 int notify, req_id, ret;
302 ret = get_request(bedata, &req_id);
319 req = RING_GET_REQUEST(&bedata->ring, req_id);
320 req->req_id = req_id;
334 READ_ONCE(bedata->rsp[req_id].req_id) == req_id);
336 /* read req_id, then the content */
338 ret = bedata->rsp[req_id].ret;
339 bedata->rsp[req_id].req_id = PVCALLS_INVALID_ID;
428 int notify, req_id, ret;
452 ret = get_request(bedata, &req_id);
460 req = RING_GET_REQUEST(&bedata->ring, req_id);
461 req->req_id = req_id;
480 READ_ONCE(bedata->rsp[req_id].req_id) == req_id);
482 /* read req_id, then the content */
484 ret = bedata->rsp[req_id].ret;
485 bedata->rsp[req_id].req_id = PVCALLS_INVALID_ID;
675 int notify, req_id, ret;
686 ret = get_request(bedata, &req_id);
692 req = RING_GET_REQUEST(&bedata->ring, req_id);
693 req->req_id = req_id;
711 READ_ONCE(bedata->rsp[req_id].req_id) == req_id);
713 /* read req_id, then the content */
715 ret = bedata->rsp[req_id].ret;
716 bedata->rsp[req_id].req_id = PVCALLS_INVALID_ID;
728 int notify, req_id, ret;
741 ret = get_request(bedata, &req_id);
747 req = RING_GET_REQUEST(&bedata->ring, req_id);
748 req->req_id = req_id;
760 READ_ONCE(bedata->rsp[req_id].req_id) == req_id);
762 /* read req_id, then the content */
764 ret = bedata->rsp[req_id].ret;
765 bedata->rsp[req_id].req_id = PVCALLS_INVALID_ID;
778 int notify, req_id, ret, nonblock;
798 req_id = READ_ONCE(map->passive.inflight_req_id);
799 if (req_id != PVCALLS_INVALID_ID &&
800 READ_ONCE(bedata->rsp[req_id].req_id) == req_id) {
842 ret = get_request(bedata, &req_id);
854 req = RING_GET_REQUEST(&bedata->ring, req_id);
855 req->req_id = req_id;
870 WRITE_ONCE(map->passive.inflight_req_id, req_id);
876 READ_ONCE(bedata->rsp[req_id].req_id) == req_id)) {
880 /* read req_id, then the content */
887 bedata->rsp[req_id].req_id = PVCALLS_INVALID_ID;
897 ret = bedata->rsp[req_id].ret;
898 bedata->rsp[req_id].req_id = PVCALLS_INVALID_ID;
913 int notify, req_id, ret;
918 uint32_t req_id = READ_ONCE(map->passive.inflight_req_id);
920 if (req_id != PVCALLS_INVALID_ID &&
921 READ_ONCE(bedata->rsp[req_id].req_id) == req_id)
945 ret = get_request(bedata, &req_id);
950 req = RING_GET_REQUEST(&bedata->ring, req_id);
951 req->req_id = req_id;
1012 int req_id, notify, ret;
1028 ret = get_request(bedata, &req_id);
1036 req = RING_GET_REQUEST(&bedata->ring, req_id);
1037 req->req_id = req_id;
1048 READ_ONCE(bedata->rsp[req_id].req_id) == req_id);
1085 WRITE_ONCE(bedata->rsp[req_id].req_id, PVCALLS_INVALID_ID);
1185 bedata->rsp[i].req_id = PVCALLS_INVALID_ID;