event/dlb2: add queue setup
[dpdk.git] / drivers / event / dlb2 / pf / dlb2_pf.c
1 /* SPDX-License-Identifier: BSD-3-Clause
2  * Copyright(c) 2016-2020 Intel Corporation
3  */
4
5 #include <stdint.h>
6 #include <stdbool.h>
7 #include <stdio.h>
8 #include <sys/mman.h>
9 #include <sys/fcntl.h>
10 #include <sys/time.h>
11 #include <errno.h>
12 #include <assert.h>
13 #include <unistd.h>
14 #include <string.h>
15 #include <rte_debug.h>
16 #include <rte_log.h>
17 #include <rte_dev.h>
18 #include <rte_devargs.h>
19 #include <rte_mbuf.h>
20 #include <rte_ring.h>
21 #include <rte_errno.h>
22 #include <rte_kvargs.h>
23 #include <rte_malloc.h>
24 #include <rte_cycles.h>
25 #include <rte_io.h>
26 #include <rte_pci.h>
27 #include <rte_bus_pci.h>
28 #include <rte_eventdev.h>
29 #include <rte_eventdev_pmd.h>
30 #include <rte_eventdev_pmd_pci.h>
31 #include <rte_memory.h>
32 #include <rte_string_fns.h>
33
34 #include "../dlb2_priv.h"
35 #include "../dlb2_iface.h"
36 #include "../dlb2_inline_fns.h"
37 #include "dlb2_main.h"
38 #include "base/dlb2_hw_types.h"
39 #include "base/dlb2_osdep.h"
40 #include "base/dlb2_resource.h"
41
42 static const char *event_dlb2_pf_name = RTE_STR(EVDEV_DLB2_NAME_PMD);
43
44 static void
45 dlb2_pf_low_level_io_init(void)
46 {
47         int i;
48         /* Addresses will be initialized at port create */
49         for (i = 0; i < DLB2_MAX_NUM_PORTS; i++) {
50                 /* First directed ports */
51                 dlb2_port[i][DLB2_DIR_PORT].pp_addr = NULL;
52                 dlb2_port[i][DLB2_DIR_PORT].cq_base = NULL;
53                 dlb2_port[i][DLB2_DIR_PORT].mmaped = true;
54
55                 /* Now load balanced ports */
56                 dlb2_port[i][DLB2_LDB_PORT].pp_addr = NULL;
57                 dlb2_port[i][DLB2_LDB_PORT].cq_base = NULL;
58                 dlb2_port[i][DLB2_LDB_PORT].mmaped = true;
59         }
60 }
61
62 static int
63 dlb2_pf_open(struct dlb2_hw_dev *handle, const char *name)
64 {
65         RTE_SET_USED(handle);
66         RTE_SET_USED(name);
67
68         return 0;
69 }
70
71 static int
72 dlb2_pf_get_device_version(struct dlb2_hw_dev *handle,
73                            uint8_t *revision)
74 {
75         struct dlb2_dev *dlb2_dev = (struct dlb2_dev *)handle->pf_dev;
76
77         *revision = dlb2_dev->revision;
78
79         return 0;
80 }
81
82 static void
83 dlb2_pf_hardware_init(struct dlb2_hw_dev *handle)
84 {
85         struct dlb2_dev *dlb2_dev = (struct dlb2_dev *)handle->pf_dev;
86
87         dlb2_hw_enable_sparse_ldb_cq_mode(&dlb2_dev->hw);
88         dlb2_hw_enable_sparse_dir_cq_mode(&dlb2_dev->hw);
89 }
90
91 static int
92 dlb2_pf_get_num_resources(struct dlb2_hw_dev *handle,
93                           struct dlb2_get_num_resources_args *rsrcs)
94 {
95         struct dlb2_dev *dlb2_dev = (struct dlb2_dev *)handle->pf_dev;
96
97         return dlb2_hw_get_num_resources(&dlb2_dev->hw, rsrcs, false, 0);
98 }
99
100 static int
101 dlb2_pf_get_cq_poll_mode(struct dlb2_hw_dev *handle,
102                          enum dlb2_cq_poll_modes *mode)
103 {
104         RTE_SET_USED(handle);
105
106         *mode = DLB2_CQ_POLL_MODE_SPARSE;
107
108         return 0;
109 }
110
111 static int
112 dlb2_pf_sched_domain_create(struct dlb2_hw_dev *handle,
113                             struct dlb2_create_sched_domain_args *arg)
114 {
115         struct dlb2_dev *dlb2_dev = (struct dlb2_dev *)handle->pf_dev;
116         struct dlb2_cmd_response response = {0};
117         int ret;
118
119         DLB2_INFO(dev->dlb2_device, "Entering %s()\n", __func__);
120
121         if (dlb2_dev->domain_reset_failed) {
122                 response.status = DLB2_ST_DOMAIN_RESET_FAILED;
123                 ret = -EINVAL;
124                 goto done;
125         }
126
127         ret = dlb2_pf_create_sched_domain(&dlb2_dev->hw, arg, &response);
128         if (ret)
129                 goto done;
130
131 done:
132
133         arg->response = response;
134
135         DLB2_INFO(dev->dlb2_device, "Exiting %s() with ret=%d\n",
136                   __func__, ret);
137
138         return ret;
139 }
140
141 static void
142 dlb2_pf_domain_reset(struct dlb2_eventdev *dlb2)
143 {
144         struct dlb2_dev *dlb2_dev;
145         int ret;
146
147         dlb2_dev = (struct dlb2_dev *)dlb2->qm_instance.pf_dev;
148         ret = dlb2_pf_reset_domain(&dlb2_dev->hw, dlb2->qm_instance.domain_id);
149         if (ret)
150                 DLB2_LOG_ERR("dlb2_pf_reset_domain err %d", ret);
151 }
152
153 static int
154 dlb2_pf_ldb_queue_create(struct dlb2_hw_dev *handle,
155                          struct dlb2_create_ldb_queue_args *cfg)
156 {
157         struct dlb2_dev *dlb2_dev = (struct dlb2_dev *)handle->pf_dev;
158         struct dlb2_cmd_response response = {0};
159         int ret;
160
161         DLB2_INFO(dev->dlb2_device, "Entering %s()\n", __func__);
162
163         ret = dlb2_pf_create_ldb_queue(&dlb2_dev->hw,
164                                        handle->domain_id,
165                                        cfg,
166                                        &response);
167
168         cfg->response = response;
169
170         DLB2_INFO(dev->dlb2_device, "Exiting %s() with ret=%d\n",
171                   __func__, ret);
172
173         return ret;
174 }
175
176 static int
177 dlb2_pf_get_sn_occupancy(struct dlb2_hw_dev *handle,
178                          struct dlb2_get_sn_occupancy_args *args)
179 {
180         struct dlb2_dev *dlb2_dev = (struct dlb2_dev *)handle->pf_dev;
181         struct dlb2_cmd_response response = {0};
182         int ret;
183
184         ret = dlb2_get_group_sequence_number_occupancy(&dlb2_dev->hw,
185                                                        args->group);
186
187         response.id = ret;
188         response.status = 0;
189
190         args->response = response;
191
192         return ret;
193 }
194
195 static int
196 dlb2_pf_get_sn_allocation(struct dlb2_hw_dev *handle,
197                           struct dlb2_get_sn_allocation_args *args)
198 {
199         struct dlb2_dev *dlb2_dev = (struct dlb2_dev *)handle->pf_dev;
200         struct dlb2_cmd_response response = {0};
201         int ret;
202
203         ret = dlb2_get_group_sequence_numbers(&dlb2_dev->hw, args->group);
204
205         response.id = ret;
206         response.status = 0;
207
208         args->response = response;
209
210         return ret;
211 }
212
213 static int
214 dlb2_pf_set_sn_allocation(struct dlb2_hw_dev *handle,
215                           struct dlb2_set_sn_allocation_args *args)
216 {
217         struct dlb2_dev *dlb2_dev = (struct dlb2_dev *)handle->pf_dev;
218         struct dlb2_cmd_response response = {0};
219         int ret;
220
221         ret = dlb2_set_group_sequence_numbers(&dlb2_dev->hw, args->group,
222                                               args->num);
223
224         response.status = 0;
225
226         args->response = response;
227
228         return ret;
229 }
230
231 static void
232 dlb2_pf_iface_fn_ptrs_init(void)
233 {
234         dlb2_iface_low_level_io_init = dlb2_pf_low_level_io_init;
235         dlb2_iface_open = dlb2_pf_open;
236         dlb2_iface_domain_reset = dlb2_pf_domain_reset;
237         dlb2_iface_get_device_version = dlb2_pf_get_device_version;
238         dlb2_iface_hardware_init = dlb2_pf_hardware_init;
239         dlb2_iface_get_num_resources = dlb2_pf_get_num_resources;
240         dlb2_iface_get_cq_poll_mode = dlb2_pf_get_cq_poll_mode;
241         dlb2_iface_sched_domain_create = dlb2_pf_sched_domain_create;
242         dlb2_iface_ldb_queue_create = dlb2_pf_ldb_queue_create;
243         dlb2_iface_get_sn_allocation = dlb2_pf_get_sn_allocation;
244         dlb2_iface_set_sn_allocation = dlb2_pf_set_sn_allocation;
245         dlb2_iface_get_sn_occupancy = dlb2_pf_get_sn_occupancy;
246 }
247
248 /* PCI DEV HOOKS */
249 static int
250 dlb2_eventdev_pci_init(struct rte_eventdev *eventdev)
251 {
252         int ret = 0;
253         struct rte_pci_device *pci_dev;
254         struct dlb2_devargs dlb2_args = {
255                 .socket_id = rte_socket_id(),
256                 .max_num_events = DLB2_MAX_NUM_LDB_CREDITS,
257                 .num_dir_credits_override = -1,
258                 .qid_depth_thresholds = { {0} },
259                 .cos_id = DLB2_COS_DEFAULT
260         };
261         struct dlb2_eventdev *dlb2;
262
263         DLB2_LOG_DBG("Enter with dev_id=%d socket_id=%d",
264                      eventdev->data->dev_id, eventdev->data->socket_id);
265
266         dlb2_pf_iface_fn_ptrs_init();
267
268         pci_dev = RTE_DEV_TO_PCI(eventdev->dev);
269
270         if (rte_eal_process_type() == RTE_PROC_PRIMARY) {
271                 dlb2 = dlb2_pmd_priv(eventdev); /* rte_zmalloc_socket mem */
272
273                 /* Probe the DLB2 PF layer */
274                 dlb2->qm_instance.pf_dev = dlb2_probe(pci_dev);
275
276                 if (dlb2->qm_instance.pf_dev == NULL) {
277                         DLB2_LOG_ERR("DLB2 PF Probe failed with error %d\n",
278                                      rte_errno);
279                         ret = -rte_errno;
280                         goto dlb2_probe_failed;
281                 }
282
283                 /* Were we invoked with runtime parameters? */
284                 if (pci_dev->device.devargs) {
285                         ret = dlb2_parse_params(pci_dev->device.devargs->args,
286                                                 pci_dev->device.devargs->name,
287                                                 &dlb2_args);
288                         if (ret) {
289                                 DLB2_LOG_ERR("PFPMD failed to parse args ret=%d, errno=%d\n",
290                                              ret, rte_errno);
291                                 goto dlb2_probe_failed;
292                         }
293                 }
294
295                 ret = dlb2_primary_eventdev_probe(eventdev,
296                                                   event_dlb2_pf_name,
297                                                   &dlb2_args);
298         } else {
299                 ret = dlb2_secondary_eventdev_probe(eventdev,
300                                                     event_dlb2_pf_name);
301         }
302         if (ret)
303                 goto dlb2_probe_failed;
304
305         DLB2_LOG_INFO("DLB2 PF Probe success\n");
306
307         return 0;
308
309 dlb2_probe_failed:
310
311         DLB2_LOG_INFO("DLB2 PF Probe failed, ret=%d\n", ret);
312
313         return ret;
314 }
315
316 #define EVENTDEV_INTEL_VENDOR_ID 0x8086
317
318 static const struct rte_pci_id pci_id_dlb2_map[] = {
319         {
320                 RTE_PCI_DEVICE(EVENTDEV_INTEL_VENDOR_ID,
321                                PCI_DEVICE_ID_INTEL_DLB2_PF)
322         },
323         {
324                 .vendor_id = 0,
325         },
326 };
327
328 static int
329 event_dlb2_pci_probe(struct rte_pci_driver *pci_drv,
330                      struct rte_pci_device *pci_dev)
331 {
332         int ret;
333
334         ret = rte_event_pmd_pci_probe_named(pci_drv, pci_dev,
335                                              sizeof(struct dlb2_eventdev),
336                                              dlb2_eventdev_pci_init,
337                                              event_dlb2_pf_name);
338         if (ret) {
339                 DLB2_LOG_INFO("rte_event_pmd_pci_probe_named() failed, "
340                                 "ret=%d\n", ret);
341         }
342
343         return ret;
344 }
345
346 static int
347 event_dlb2_pci_remove(struct rte_pci_device *pci_dev)
348 {
349         int ret;
350
351         ret = rte_event_pmd_pci_remove(pci_dev, NULL);
352
353         if (ret) {
354                 DLB2_LOG_INFO("rte_event_pmd_pci_remove() failed, "
355                                 "ret=%d\n", ret);
356         }
357
358         return ret;
359
360 }
361
362 static struct rte_pci_driver pci_eventdev_dlb2_pmd = {
363         .id_table = pci_id_dlb2_map,
364         .drv_flags = RTE_PCI_DRV_NEED_MAPPING,
365         .probe = event_dlb2_pci_probe,
366         .remove = event_dlb2_pci_remove,
367 };
368
369 RTE_PMD_REGISTER_PCI(event_dlb2_pf, pci_eventdev_dlb2_pmd);
370 RTE_PMD_REGISTER_PCI_TABLE(event_dlb2_pf, pci_id_dlb2_map);