2 * QEMU paravirtual RDMA - Device rings
4 * Copyright (C) 2018 Oracle
5 * Copyright (C) 2018 Red Hat Inc
8 * Yuval Shaia <yuval.shaia@oracle.com>
9 * Marcel Apfelbaum <marcel@redhat.com>
11 * This work is licensed under the terms of the GNU GPL, version 2 or later.
12 * See the COPYING file in the top-level directory.
16 #include "qemu/osdep.h"
17 #include "hw/pci/pci.h"
22 #include "../rdma_utils.h"
23 #include "standard-headers/drivers/infiniband/hw/vmw_pvrdma/pvrdma_ring.h"
24 #include "pvrdma_dev_ring.h"
26 int pvrdma_ring_init(PvrdmaRing
*ring
, const char *name
, PCIDevice
*dev
,
27 struct pvrdma_ring
*ring_state
, uint32_t max_elems
,
28 size_t elem_sz
, dma_addr_t
*tbl
, uint32_t npages
)
33 strncpy(ring
->name
, name
, MAX_RING_NAME_SZ
);
34 ring
->name
[MAX_RING_NAME_SZ
- 1] = 0;
36 ring
->ring_state
= ring_state
;
37 ring
->max_elems
= max_elems
;
38 ring
->elem_sz
= elem_sz
;
39 /* TODO: Give a moment to think if we want to redo driver settings
40 atomic_set(&ring->ring_state->prod_tail, 0);
41 atomic_set(&ring->ring_state->cons_head, 0);
43 ring
->npages
= npages
;
44 ring
->pages
= g_malloc(npages
* sizeof(void *));
46 for (i
= 0; i
< npages
; i
++) {
48 rdma_error_report("npages=%d but tbl[%d] is NULL", npages
, i
);
52 ring
->pages
[i
] = rdma_pci_dma_map(dev
, tbl
[i
], TARGET_PAGE_SIZE
);
53 if (!ring
->pages
[i
]) {
55 rdma_error_report("Failed to map to page %d in ring %s", i
, name
);
58 memset(ring
->pages
[i
], 0, TARGET_PAGE_SIZE
);
65 rdma_pci_dma_unmap(dev
, ring
->pages
[i
], TARGET_PAGE_SIZE
);
73 void *pvrdma_ring_next_elem_read(PvrdmaRing
*ring
)
76 unsigned int idx
= 0, offset
;
78 e
= pvrdma_idx_ring_has_data(ring
->ring_state
, ring
->max_elems
, &idx
);
80 trace_pvrdma_ring_next_elem_read_no_data(ring
->name
);
84 offset
= idx
* ring
->elem_sz
;
85 return ring
->pages
[offset
/ TARGET_PAGE_SIZE
] + (offset
% TARGET_PAGE_SIZE
);
88 void pvrdma_ring_read_inc(PvrdmaRing
*ring
)
90 pvrdma_idx_ring_inc(&ring
->ring_state
->cons_head
, ring
->max_elems
);
93 void *pvrdma_ring_next_elem_write(PvrdmaRing
*ring
)
96 unsigned int offset
, tail
;
98 idx
= pvrdma_idx_ring_has_space(ring
->ring_state
, ring
->max_elems
, &tail
);
100 rdma_error_report("CQ is full");
104 idx
= pvrdma_idx(&ring
->ring_state
->prod_tail
, ring
->max_elems
);
105 if (idx
< 0 || tail
!= idx
) {
106 rdma_error_report("Invalid idx %d", idx
);
110 offset
= idx
* ring
->elem_sz
;
111 return ring
->pages
[offset
/ TARGET_PAGE_SIZE
] + (offset
% TARGET_PAGE_SIZE
);
114 void pvrdma_ring_write_inc(PvrdmaRing
*ring
)
116 pvrdma_idx_ring_inc(&ring
->ring_state
->prod_tail
, ring
->max_elems
);
119 void pvrdma_ring_free(PvrdmaRing
*ring
)
129 while (ring
->npages
--) {
130 rdma_pci_dma_unmap(ring
->dev
, ring
->pages
[ring
->npages
],