Lines Matching refs:wc
119 static int client_recv(struct thread_data *td, struct ibv_wc *wc) in client_recv() argument
123 if (wc->byte_len != sizeof(rd->recv_buf)) { in client_recv()
124 log_err("Received bogus data, size %d\n", wc->byte_len); in client_recv()
151 static int server_recv(struct thread_data *td, struct ibv_wc *wc) in server_recv() argument
155 if (wc->wr_id == FIO_RDMA_MAX_IO_DEPTH) { in server_recv()
169 struct ibv_wc wc; in cq_event_handler() local
175 while ((ret = ibv_poll_cq(rd->cq, 1, &wc)) == 1) { in cq_event_handler()
179 if (wc.status) { in cq_event_handler()
181 wc.status, ibv_wc_status_str(wc.status)); in cq_event_handler()
185 switch (wc.opcode) { in cq_event_handler()
189 client_recv(td, &wc); in cq_event_handler()
191 server_recv(td, &wc); in cq_event_handler()
193 if (wc.wr_id == FIO_RDMA_MAX_IO_DEPTH) in cq_event_handler()
199 if (wc.wr_id == r_io_u_d->rq_wr.wr_id) { in cq_event_handler()
202 - wc.byte_len; in cq_event_handler()
215 wc.wr_id); in cq_event_handler()
228 if (wc.wr_id == FIO_RDMA_MAX_IO_DEPTH) in cq_event_handler()
234 if (wc.wr_id == r_io_u_d->sq_wr.wr_id) { in cq_event_handler()
244 wc.wr_id); in cq_event_handler()
256 wc.opcode); in cq_event_handler()