74ada6ef42b8dea06f873ca4d2421428f7c553a1
[dpdk.git] / drivers / common / cnxk / roc_cpt.c
1 /* SPDX-License-Identifier: BSD-3-Clause
2  * Copyright(C) 2021 Marvell.
3  */
4
5 #include "roc_api.h"
6 #include "roc_priv.h"
7
8 #define CPT_IQ_FC_LEN  128
9 #define CPT_IQ_GRP_LEN 16
10
11 #define CPT_IQ_NB_DESC_MULTIPLIER 40
12
13 /* The effective queue size to software is (CPT_LF_Q_SIZE[SIZE_DIV40] - 1 - 8).
14  *
15  * CPT requires 320 free entries (+8). And 40 entries are required for
16  * allowing CPT to discard packet when the queues are full (+1).
17  */
18 #define CPT_IQ_NB_DESC_SIZE_DIV40(nb_desc)                                     \
19         (PLT_DIV_CEIL(nb_desc, CPT_IQ_NB_DESC_MULTIPLIER) + 1 + 8)
20
21 #define CPT_IQ_GRP_SIZE(nb_desc)                                               \
22         (CPT_IQ_NB_DESC_SIZE_DIV40(nb_desc) * CPT_IQ_GRP_LEN)
23
24 #define CPT_LF_MAX_NB_DESC     128000
25 #define CPT_LF_DEFAULT_NB_DESC 1024
26
27 static void
28 cpt_lf_misc_intr_enb_dis(struct roc_cpt_lf *lf, bool enb)
29 {
30         /* Enable all cpt lf error irqs except RQ_DISABLED and CQ_DISABLED */
31         if (enb)
32                 plt_write64((BIT_ULL(6) | BIT_ULL(5) | BIT_ULL(3) | BIT_ULL(2) |
33                              BIT_ULL(1)),
34                             lf->rbase + CPT_LF_MISC_INT_ENA_W1S);
35         else
36                 plt_write64((BIT_ULL(6) | BIT_ULL(5) | BIT_ULL(3) | BIT_ULL(2) |
37                              BIT_ULL(1)),
38                             lf->rbase + CPT_LF_MISC_INT_ENA_W1C);
39 }
40
41 static void
42 cpt_lf_misc_irq(void *param)
43 {
44         struct roc_cpt_lf *lf = (struct roc_cpt_lf *)param;
45         struct dev *dev = lf->dev;
46         uint64_t intr;
47
48         intr = plt_read64(lf->rbase + CPT_LF_MISC_INT);
49         if (intr == 0)
50                 return;
51
52         plt_err("Err_irq=0x%" PRIx64 " pf=%d, vf=%d", intr, dev->pf, dev->vf);
53
54         /* Dump lf registers */
55         cpt_lf_print(lf);
56
57         /* Clear interrupt */
58         plt_write64(intr, lf->rbase + CPT_LF_MISC_INT);
59 }
60
61 static int
62 cpt_lf_register_misc_irq(struct roc_cpt_lf *lf)
63 {
64         struct plt_pci_device *pci_dev = lf->pci_dev;
65         struct plt_intr_handle *handle;
66         int rc, vec;
67
68         handle = &pci_dev->intr_handle;
69
70         vec = lf->msixoff + CPT_LF_INT_VEC_MISC;
71         /* Clear err interrupt */
72         cpt_lf_misc_intr_enb_dis(lf, false);
73         /* Set used interrupt vectors */
74         rc = dev_irq_register(handle, cpt_lf_misc_irq, lf, vec);
75         /* Enable all dev interrupt except for RQ_DISABLED */
76         cpt_lf_misc_intr_enb_dis(lf, true);
77
78         return rc;
79 }
80
81 static void
82 cpt_lf_unregister_misc_irq(struct roc_cpt_lf *lf)
83 {
84         struct plt_pci_device *pci_dev = lf->pci_dev;
85         struct plt_intr_handle *handle;
86         int vec;
87
88         handle = &pci_dev->intr_handle;
89
90         vec = lf->msixoff + CPT_LF_INT_VEC_MISC;
91         /* Clear err interrupt */
92         cpt_lf_misc_intr_enb_dis(lf, false);
93         dev_irq_unregister(handle, cpt_lf_misc_irq, lf, vec);
94 }
95
96 static void
97 cpt_lf_done_intr_enb_dis(struct roc_cpt_lf *lf, bool enb)
98 {
99         if (enb)
100                 plt_write64(0x1, lf->rbase + CPT_LF_DONE_INT_ENA_W1S);
101         else
102                 plt_write64(0x1, lf->rbase + CPT_LF_DONE_INT_ENA_W1C);
103 }
104
105 static void
106 cpt_lf_done_irq(void *param)
107 {
108         struct roc_cpt_lf *lf = param;
109         uint64_t done_wait;
110         uint64_t intr;
111
112         /* Read the number of completed requests */
113         intr = plt_read64(lf->rbase + CPT_LF_DONE);
114         if (intr == 0)
115                 return;
116
117         done_wait = plt_read64(lf->rbase + CPT_LF_DONE_WAIT);
118
119         /* Acknowledge the number of completed requests */
120         plt_write64(intr, lf->rbase + CPT_LF_DONE_ACK);
121
122         plt_write64(done_wait, lf->rbase + CPT_LF_DONE_WAIT);
123 }
124
125 static int
126 cpt_lf_register_done_irq(struct roc_cpt_lf *lf)
127 {
128         struct plt_pci_device *pci_dev = lf->pci_dev;
129         struct plt_intr_handle *handle;
130         int rc, vec;
131
132         handle = &pci_dev->intr_handle;
133
134         vec = lf->msixoff + CPT_LF_INT_VEC_DONE;
135
136         /* Clear done interrupt */
137         cpt_lf_done_intr_enb_dis(lf, false);
138
139         /* Set used interrupt vectors */
140         rc = dev_irq_register(handle, cpt_lf_done_irq, lf, vec);
141
142         /* Enable done interrupt */
143         cpt_lf_done_intr_enb_dis(lf, true);
144
145         return rc;
146 }
147
148 static void
149 cpt_lf_unregister_done_irq(struct roc_cpt_lf *lf)
150 {
151         struct plt_pci_device *pci_dev = lf->pci_dev;
152         struct plt_intr_handle *handle;
153         int vec;
154
155         handle = &pci_dev->intr_handle;
156
157         vec = lf->msixoff + CPT_LF_INT_VEC_DONE;
158
159         /* Clear done interrupt */
160         cpt_lf_done_intr_enb_dis(lf, false);
161         dev_irq_unregister(handle, cpt_lf_done_irq, lf, vec);
162 }
163
164 static int
165 cpt_lf_register_irqs(struct roc_cpt_lf *lf)
166 {
167         int rc;
168
169         if (lf->msixoff == MSIX_VECTOR_INVALID) {
170                 plt_err("Invalid CPTLF MSIX vector offset vector: 0x%x",
171                         lf->msixoff);
172                 return -EINVAL;
173         }
174
175         /* Register lf err interrupt */
176         rc = cpt_lf_register_misc_irq(lf);
177         if (rc)
178                 plt_err("Error registering IRQs");
179
180         rc = cpt_lf_register_done_irq(lf);
181         if (rc)
182                 plt_err("Error registering IRQs");
183
184         return rc;
185 }
186
187 static void
188 cpt_lf_unregister_irqs(struct roc_cpt_lf *lf)
189 {
190         cpt_lf_unregister_misc_irq(lf);
191         cpt_lf_unregister_done_irq(lf);
192 }
193
194 static void
195 cpt_lf_dump(struct roc_cpt_lf *lf)
196 {
197         plt_cpt_dbg("CPT LF");
198         plt_cpt_dbg("RBASE: 0x%016" PRIx64, lf->rbase);
199         plt_cpt_dbg("LMT_BASE: 0x%016" PRIx64, lf->lmt_base);
200         plt_cpt_dbg("MSIXOFF: 0x%x", lf->msixoff);
201         plt_cpt_dbg("LF_ID: 0x%x", lf->lf_id);
202         plt_cpt_dbg("NB DESC: %d", lf->nb_desc);
203         plt_cpt_dbg("FC_ADDR: 0x%016" PRIx64, (uintptr_t)lf->fc_addr);
204         plt_cpt_dbg("CQ.VADDR: 0x%016" PRIx64, (uintptr_t)lf->iq_vaddr);
205
206         plt_cpt_dbg("CPT LF REG:");
207         plt_cpt_dbg("LF_CTL[0x%016llx]: 0x%016" PRIx64, CPT_LF_CTL,
208                     plt_read64(lf->rbase + CPT_LF_CTL));
209         plt_cpt_dbg("LF_INPROG[0x%016llx]: 0x%016" PRIx64, CPT_LF_INPROG,
210                     plt_read64(lf->rbase + CPT_LF_INPROG));
211
212         plt_cpt_dbg("Q_BASE[0x%016llx]: 0x%016" PRIx64, CPT_LF_Q_BASE,
213                     plt_read64(lf->rbase + CPT_LF_Q_BASE));
214         plt_cpt_dbg("Q_SIZE[0x%016llx]: 0x%016" PRIx64, CPT_LF_Q_SIZE,
215                     plt_read64(lf->rbase + CPT_LF_Q_SIZE));
216         plt_cpt_dbg("Q_INST_PTR[0x%016llx]: 0x%016" PRIx64, CPT_LF_Q_INST_PTR,
217                     plt_read64(lf->rbase + CPT_LF_Q_INST_PTR));
218         plt_cpt_dbg("Q_GRP_PTR[0x%016llx]: 0x%016" PRIx64, CPT_LF_Q_GRP_PTR,
219                     plt_read64(lf->rbase + CPT_LF_Q_GRP_PTR));
220 }
221
222 int
223 cpt_lf_outb_cfg(struct dev *dev, uint16_t sso_pf_func, uint16_t nix_pf_func,
224                 uint8_t lf_id, bool ena)
225 {
226         struct cpt_inline_ipsec_cfg_msg *req;
227         struct mbox *mbox = dev->mbox;
228
229         req = mbox_alloc_msg_cpt_inline_ipsec_cfg(mbox);
230         if (req == NULL)
231                 return -ENOSPC;
232
233         req->dir = CPT_INLINE_OUTBOUND;
234         req->slot = lf_id;
235         if (ena) {
236                 req->enable = 1;
237                 req->sso_pf_func = sso_pf_func;
238                 req->nix_pf_func = nix_pf_func;
239         } else {
240                 req->enable = 0;
241         }
242
243         return mbox_process(mbox);
244 }
245
246 int
247 roc_cpt_inline_ipsec_cfg(struct dev *cpt_dev, uint8_t lf_id,
248                          struct roc_nix *roc_nix)
249 {
250         bool ena = roc_nix ? true : false;
251         uint16_t nix_pf_func = 0;
252         uint16_t sso_pf_func = 0;
253
254         if (ena) {
255                 nix_pf_func = roc_nix_get_pf_func(roc_nix);
256                 sso_pf_func = idev_sso_pffunc_get();
257         }
258
259         return cpt_lf_outb_cfg(cpt_dev, sso_pf_func, nix_pf_func, lf_id, ena);
260 }
261
262 int
263 roc_cpt_inline_ipsec_inb_cfg(struct roc_cpt *roc_cpt, uint16_t param1,
264                              uint16_t param2)
265 {
266         struct cpt *cpt = roc_cpt_to_cpt_priv(roc_cpt);
267         struct cpt_rx_inline_lf_cfg_msg *req;
268         struct mbox *mbox;
269
270         mbox = cpt->dev.mbox;
271
272         req = mbox_alloc_msg_cpt_rx_inline_lf_cfg(mbox);
273         if (req == NULL)
274                 return -ENOSPC;
275
276         req->sso_pf_func = idev_sso_pffunc_get();
277         req->param1 = param1;
278         req->param2 = param2;
279
280         return mbox_process(mbox);
281 }
282
283 int
284 roc_cpt_rxc_time_cfg(struct roc_cpt *roc_cpt, struct roc_cpt_rxc_time_cfg *cfg)
285 {
286         struct cpt *cpt = roc_cpt_to_cpt_priv(roc_cpt);
287         struct cpt_rxc_time_cfg_req *req;
288         struct dev *dev = &cpt->dev;
289
290         req = mbox_alloc_msg_cpt_rxc_time_cfg(dev->mbox);
291         if (req == NULL)
292                 return -ENOSPC;
293
294         req->blkaddr = 0;
295
296         /* The step value is in microseconds. */
297         req->step = cfg->step;
298
299         /* The timeout will be: limit * step microseconds */
300         req->zombie_limit = cfg->zombie_limit;
301         req->zombie_thres = cfg->zombie_thres;
302
303         /* The timeout will be: limit * step microseconds */
304         req->active_limit = cfg->active_limit;
305         req->active_thres = cfg->active_thres;
306
307         return mbox_process(dev->mbox);
308 }
309
310 int
311 cpt_get_msix_offset(struct dev *dev, struct msix_offset_rsp **msix_rsp)
312 {
313         struct mbox *mbox = dev->mbox;
314         int rc;
315
316         /* Get MSIX vector offsets */
317         mbox_alloc_msg_msix_offset(mbox);
318         rc = mbox_process_msg(mbox, (void *)msix_rsp);
319
320         return rc;
321 }
322
323 int
324 cpt_lfs_attach(struct dev *dev, uint8_t blkaddr, bool modify, uint16_t nb_lf)
325 {
326         struct mbox *mbox = dev->mbox;
327         struct rsrc_attach_req *req;
328
329         if (blkaddr != RVU_BLOCK_ADDR_CPT0 && blkaddr != RVU_BLOCK_ADDR_CPT1)
330                 return -EINVAL;
331
332         /* Attach CPT(lf) */
333         req = mbox_alloc_msg_attach_resources(mbox);
334         if (req == NULL)
335                 return -ENOSPC;
336
337         req->cptlfs = nb_lf;
338         req->modify = modify;
339         req->cpt_blkaddr = blkaddr;
340
341         return mbox_process(mbox);
342 }
343
344 int
345 cpt_lfs_detach(struct dev *dev)
346 {
347         struct mbox *mbox = dev->mbox;
348         struct rsrc_detach_req *req;
349
350         req = mbox_alloc_msg_detach_resources(mbox);
351         if (req == NULL)
352                 return -ENOSPC;
353
354         req->cptlfs = 1;
355         req->partial = 1;
356
357         return mbox_process(mbox);
358 }
359
360 static int
361 cpt_available_lfs_get(struct dev *dev, uint16_t *nb_lf)
362 {
363         struct mbox *mbox = dev->mbox;
364         struct free_rsrcs_rsp *rsp;
365         int rc;
366
367         mbox_alloc_msg_free_rsrc_cnt(mbox);
368
369         rc = mbox_process_msg(mbox, (void *)&rsp);
370         if (rc)
371                 return -EIO;
372
373         *nb_lf = PLT_MAX((uint16_t)rsp->cpt, (uint16_t)rsp->cpt1);
374         return 0;
375 }
376
377 int
378 cpt_lfs_alloc(struct dev *dev, uint8_t eng_grpmsk, uint8_t blkaddr,
379               bool inl_dev_sso)
380 {
381         struct cpt_lf_alloc_req_msg *req;
382         struct mbox *mbox = dev->mbox;
383
384         if (blkaddr != RVU_BLOCK_ADDR_CPT0 && blkaddr != RVU_BLOCK_ADDR_CPT1)
385                 return -EINVAL;
386
387         req = mbox_alloc_msg_cpt_lf_alloc(mbox);
388         req->nix_pf_func = 0;
389         if (inl_dev_sso && nix_inl_dev_pffunc_get())
390                 req->sso_pf_func = nix_inl_dev_pffunc_get();
391         else
392                 req->sso_pf_func = idev_sso_pffunc_get();
393         req->eng_grpmsk = eng_grpmsk;
394         req->blkaddr = blkaddr;
395
396         return mbox_process(mbox);
397 }
398
399 int
400 cpt_lfs_free(struct dev *dev)
401 {
402         mbox_alloc_msg_cpt_lf_free(dev->mbox);
403
404         return mbox_process(dev->mbox);
405 }
406
407 static int
408 cpt_hardware_caps_get(struct dev *dev, struct roc_cpt *roc_cpt)
409 {
410         struct cpt_caps_rsp_msg *rsp;
411         int ret;
412
413         mbox_alloc_msg_cpt_caps_get(dev->mbox);
414
415         ret = mbox_process_msg(dev->mbox, (void *)&rsp);
416         if (ret)
417                 return -EIO;
418
419         roc_cpt->cpt_revision = rsp->cpt_revision;
420         mbox_memcpy(roc_cpt->hw_caps, rsp->eng_caps,
421                     sizeof(union cpt_eng_caps) * CPT_MAX_ENG_TYPES);
422
423         return 0;
424 }
425
426 static uint32_t
427 cpt_lf_iq_mem_calc(uint32_t nb_desc)
428 {
429         uint32_t len;
430
431         /* Space for instruction group memory */
432         len = CPT_IQ_GRP_SIZE(nb_desc);
433
434         /* Align to 128B */
435         len = PLT_ALIGN(len, ROC_ALIGN);
436
437         /* Space for FC */
438         len += CPT_IQ_FC_LEN;
439
440         /* For instruction queues */
441         len += PLT_ALIGN(CPT_IQ_NB_DESC_SIZE_DIV40(nb_desc) *
442                                  CPT_IQ_NB_DESC_MULTIPLIER *
443                                  sizeof(struct cpt_inst_s),
444                          ROC_ALIGN);
445
446         return len;
447 }
448
449 static inline void
450 cpt_iq_init(struct roc_cpt_lf *lf)
451 {
452         union cpt_lf_q_size lf_q_size = {.u = 0x0};
453         union cpt_lf_q_base lf_q_base = {.u = 0x0};
454         uintptr_t addr;
455
456         lf->io_addr = lf->rbase + CPT_LF_NQX(0);
457
458         /* Disable command queue */
459         roc_cpt_iq_disable(lf);
460
461         /* Set command queue base address */
462         addr = (uintptr_t)lf->iq_vaddr +
463                PLT_ALIGN(CPT_IQ_GRP_SIZE(lf->nb_desc), ROC_ALIGN);
464
465         lf_q_base.u = addr;
466
467         plt_write64(lf_q_base.u, lf->rbase + CPT_LF_Q_BASE);
468
469         /* Set command queue size */
470         lf_q_size.s.size_div40 = CPT_IQ_NB_DESC_SIZE_DIV40(lf->nb_desc);
471         plt_write64(lf_q_size.u, lf->rbase + CPT_LF_Q_SIZE);
472
473         lf->fc_addr = (uint64_t *)addr;
474         lf->fc_hyst_bits = plt_log2_u32(lf->nb_desc) / 2;
475         lf->fc_thresh = lf->nb_desc - (lf->nb_desc % (1 << lf->fc_hyst_bits));
476 }
477
478 int
479 roc_cpt_dev_configure(struct roc_cpt *roc_cpt, int nb_lf)
480 {
481         struct cpt *cpt = roc_cpt_to_cpt_priv(roc_cpt);
482         uint8_t blkaddr[ROC_CPT_MAX_BLKS];
483         struct msix_offset_rsp *rsp;
484         uint8_t eng_grpmsk;
485         int blknum = 0;
486         int rc, i;
487
488         blkaddr[0] = RVU_BLOCK_ADDR_CPT0;
489         blkaddr[1] = RVU_BLOCK_ADDR_CPT1;
490
491         if ((roc_cpt->cpt_revision == ROC_CPT_REVISION_ID_98XX) &&
492             (cpt->dev.pf_func & 0x1))
493                 blknum = (blknum + 1) % ROC_CPT_MAX_BLKS;
494
495         /* Request LF resources */
496         rc = cpt_lfs_attach(&cpt->dev, blkaddr[blknum], true, nb_lf);
497
498         /* Request LFs from another block if current block has less LFs */
499         if (roc_cpt->cpt_revision == ROC_CPT_REVISION_ID_98XX && rc == ENOSPC) {
500                 blknum = (blknum + 1) % ROC_CPT_MAX_BLKS;
501                 rc = cpt_lfs_attach(&cpt->dev, blkaddr[blknum], true, nb_lf);
502         }
503         if (rc) {
504                 plt_err("Could not attach LFs");
505                 return rc;
506         }
507
508         for (i = 0; i < nb_lf; i++)
509                 cpt->lf_blkaddr[i] = blkaddr[blknum];
510
511         eng_grpmsk = (1 << roc_cpt->eng_grp[CPT_ENG_TYPE_AE]) |
512                      (1 << roc_cpt->eng_grp[CPT_ENG_TYPE_SE]) |
513                      (1 << roc_cpt->eng_grp[CPT_ENG_TYPE_IE]);
514
515         rc = cpt_lfs_alloc(&cpt->dev, eng_grpmsk, blkaddr[blknum], false);
516         if (rc)
517                 goto lfs_detach;
518
519         rc = cpt_get_msix_offset(&cpt->dev, &rsp);
520         if (rc)
521                 goto lfs_free;
522
523         for (i = 0; i < nb_lf; i++)
524                 cpt->lf_msix_off[i] =
525                         (cpt->lf_blkaddr[i] == RVU_BLOCK_ADDR_CPT1) ?
526                                 rsp->cpt1_lf_msixoff[i] :
527                                 rsp->cptlf_msixoff[i];
528
529         roc_cpt->nb_lf = nb_lf;
530
531         return 0;
532
533 lfs_free:
534         cpt_lfs_free(&cpt->dev);
535 lfs_detach:
536         cpt_lfs_detach(&cpt->dev);
537         return rc;
538 }
539
540 uint64_t
541 cpt_get_blkaddr(struct dev *dev)
542 {
543         uint64_t reg;
544         uint64_t off;
545
546         /* Reading the discovery register to know which CPT is the LF
547          * attached to. Assume CPT LF's of only one block are attached
548          * to a pffunc.
549          */
550         if (dev_is_vf(dev))
551                 off = RVU_VF_BLOCK_ADDRX_DISC(RVU_BLOCK_ADDR_CPT1);
552         else
553                 off = RVU_PF_BLOCK_ADDRX_DISC(RVU_BLOCK_ADDR_CPT1);
554
555         reg = plt_read64(dev->bar2 + off);
556
557         return reg & 0x1FFULL ? RVU_BLOCK_ADDR_CPT1 : RVU_BLOCK_ADDR_CPT0;
558 }
559
560 int
561 cpt_lf_init(struct roc_cpt_lf *lf)
562 {
563         struct dev *dev = lf->dev;
564         uint64_t blkaddr;
565         void *iq_mem;
566         int rc;
567
568         if (lf->nb_desc == 0 || lf->nb_desc > CPT_LF_MAX_NB_DESC)
569                 lf->nb_desc = CPT_LF_DEFAULT_NB_DESC;
570
571         /* Allocate memory for instruction queue for CPT LF. */
572         iq_mem = plt_zmalloc(cpt_lf_iq_mem_calc(lf->nb_desc), ROC_ALIGN);
573         if (iq_mem == NULL)
574                 return -ENOMEM;
575         plt_atomic_thread_fence(__ATOMIC_ACQ_REL);
576
577         blkaddr = cpt_get_blkaddr(dev);
578         lf->rbase = dev->bar2 + ((blkaddr << 20) | (lf->lf_id << 12));
579         lf->iq_vaddr = iq_mem;
580         lf->lmt_base = dev->lmt_base;
581         lf->pf_func = dev->pf_func;
582
583         /* Initialize instruction queue */
584         cpt_iq_init(lf);
585
586         rc = cpt_lf_register_irqs(lf);
587         if (rc)
588                 goto disable_iq;
589
590         return 0;
591
592 disable_iq:
593         roc_cpt_iq_disable(lf);
594         plt_free(iq_mem);
595         return rc;
596 }
597
598 int
599 roc_cpt_lf_init(struct roc_cpt *roc_cpt, struct roc_cpt_lf *lf)
600 {
601         struct cpt *cpt = roc_cpt_to_cpt_priv(roc_cpt);
602         int rc;
603
604         lf->dev = &cpt->dev;
605         lf->roc_cpt = roc_cpt;
606         lf->msixoff = cpt->lf_msix_off[lf->lf_id];
607         lf->pci_dev = cpt->pci_dev;
608
609         rc = cpt_lf_init(lf);
610         if (rc)
611                 return rc;
612
613         /* LF init successful */
614         roc_cpt->lf[lf->lf_id] = lf;
615         return rc;
616 }
617
618 int
619 roc_cpt_dev_init(struct roc_cpt *roc_cpt)
620 {
621         struct plt_pci_device *pci_dev;
622         uint16_t nb_lf_avail;
623         struct dev *dev;
624         struct cpt *cpt;
625         int rc;
626
627         if (roc_cpt == NULL || roc_cpt->pci_dev == NULL)
628                 return -EINVAL;
629
630         PLT_STATIC_ASSERT(sizeof(struct cpt) <= ROC_CPT_MEM_SZ);
631
632         cpt = roc_cpt_to_cpt_priv(roc_cpt);
633         memset(cpt, 0, sizeof(*cpt));
634         pci_dev = roc_cpt->pci_dev;
635         dev = &cpt->dev;
636
637         /* Initialize device  */
638         rc = dev_init(dev, pci_dev);
639         if (rc) {
640                 plt_err("Failed to init roc device");
641                 goto fail;
642         }
643
644         cpt->pci_dev = pci_dev;
645         roc_cpt->lmt_base = dev->lmt_base;
646
647         rc = cpt_hardware_caps_get(dev, roc_cpt);
648         if (rc) {
649                 plt_err("Could not determine hardware capabilities");
650                 goto fail;
651         }
652
653         rc = cpt_available_lfs_get(&cpt->dev, &nb_lf_avail);
654         if (rc) {
655                 plt_err("Could not get available lfs");
656                 goto fail;
657         }
658
659         /* Reserve 1 CPT LF for inline inbound */
660         nb_lf_avail = PLT_MIN(nb_lf_avail, (uint16_t)(ROC_CPT_MAX_LFS - 1));
661
662         roc_cpt->nb_lf_avail = nb_lf_avail;
663
664         dev->roc_cpt = roc_cpt;
665
666         /* Set it to idev if not already present */
667         if (!roc_idev_cpt_get())
668                 roc_idev_cpt_set(roc_cpt);
669
670         return 0;
671
672 fail:
673         return rc;
674 }
675
676 int
677 roc_cpt_lf_ctx_flush(struct roc_cpt_lf *lf, uint64_t cptr)
678 {
679         union cpt_lf_ctx_flush reg;
680
681         if (lf == NULL)
682                 return -ENOTSUP;
683
684         reg.u = 0;
685         reg.s.pf_func = lf->pf_func;
686         reg.s.inval = 1;
687         reg.s.cptr = cptr;
688
689         plt_write64(reg.u, lf->rbase + CPT_LF_CTX_FLUSH);
690
691         return 0;
692 }
693
694 void
695 cpt_lf_fini(struct roc_cpt_lf *lf)
696 {
697         /* Unregister IRQ's */
698         cpt_lf_unregister_irqs(lf);
699
700         /* Disable IQ */
701         roc_cpt_iq_disable(lf);
702
703         /* Free memory */
704         plt_free(lf->iq_vaddr);
705         lf->iq_vaddr = NULL;
706 }
707
708 void
709 roc_cpt_lf_fini(struct roc_cpt_lf *lf)
710 {
711         if (lf == NULL)
712                 return;
713         lf->roc_cpt->lf[lf->lf_id] = NULL;
714         cpt_lf_fini(lf);
715 }
716
717 int
718 roc_cpt_dev_fini(struct roc_cpt *roc_cpt)
719 {
720         struct cpt *cpt = roc_cpt_to_cpt_priv(roc_cpt);
721
722         if (cpt == NULL)
723                 return -EINVAL;
724
725         /* Remove idev references */
726         if (roc_idev_cpt_get() == roc_cpt)
727                 roc_idev_cpt_set(NULL);
728
729         roc_cpt->nb_lf_avail = 0;
730
731         roc_cpt->lmt_base = 0;
732
733         return dev_fini(&cpt->dev, cpt->pci_dev);
734 }
735
736 void
737 roc_cpt_dev_clear(struct roc_cpt *roc_cpt)
738 {
739         struct cpt *cpt = roc_cpt_to_cpt_priv(roc_cpt);
740         int i;
741
742         if (cpt == NULL)
743                 return;
744
745         for (i = 0; i < roc_cpt->nb_lf; i++)
746                 cpt->lf_msix_off[i] = 0;
747
748         roc_cpt->nb_lf = 0;
749
750         cpt_lfs_free(&cpt->dev);
751
752         cpt_lfs_detach(&cpt->dev);
753 }
754
755 int
756 roc_cpt_eng_grp_add(struct roc_cpt *roc_cpt, enum cpt_eng_type eng_type)
757 {
758         struct cpt *cpt = roc_cpt_to_cpt_priv(roc_cpt);
759         struct dev *dev = &cpt->dev;
760         struct cpt_eng_grp_req *req;
761         struct cpt_eng_grp_rsp *rsp;
762         int ret;
763
764         req = mbox_alloc_msg_cpt_eng_grp_get(dev->mbox);
765         if (req == NULL)
766                 return -EIO;
767
768         switch (eng_type) {
769         case CPT_ENG_TYPE_AE:
770         case CPT_ENG_TYPE_SE:
771         case CPT_ENG_TYPE_IE:
772                 break;
773         default:
774                 return -EINVAL;
775         }
776
777         req->eng_type = eng_type;
778         ret = mbox_process_msg(dev->mbox, (void *)&rsp);
779         if (ret)
780                 return -EIO;
781
782         if (rsp->eng_grp_num > 8) {
783                 plt_err("Invalid CPT engine group");
784                 return -ENOTSUP;
785         }
786
787         roc_cpt->eng_grp[eng_type] = rsp->eng_grp_num;
788
789         return rsp->eng_grp_num;
790 }
791
792 void
793 roc_cpt_iq_disable(struct roc_cpt_lf *lf)
794 {
795         union cpt_lf_ctl lf_ctl = {.u = 0x0};
796         union cpt_lf_q_grp_ptr grp_ptr;
797         union cpt_lf_inprog lf_inprog;
798         int timeout = 20;
799         int cnt;
800
801         /* Disable instructions enqueuing */
802         plt_write64(lf_ctl.u, lf->rbase + CPT_LF_CTL);
803
804         /* Wait for instruction queue to become empty */
805         do {
806                 lf_inprog.u = plt_read64(lf->rbase + CPT_LF_INPROG);
807                 if (!lf_inprog.s.inflight)
808                         break;
809
810                 plt_delay_ms(20);
811                 if (timeout-- < 0) {
812                         plt_err("CPT LF %d is still busy", lf->lf_id);
813                         break;
814                 }
815
816         } while (1);
817
818         /* Disable executions in the LF's queue.
819          * The queue should be empty at this point
820          */
821         lf_inprog.s.eena = 0x0;
822         plt_write64(lf_inprog.u, lf->rbase + CPT_LF_INPROG);
823
824         /* Wait for instruction queue to become empty */
825         cnt = 0;
826         do {
827                 lf_inprog.u = plt_read64(lf->rbase + CPT_LF_INPROG);
828                 if (lf_inprog.s.grb_partial)
829                         cnt = 0;
830                 else
831                         cnt++;
832                 grp_ptr.u = plt_read64(lf->rbase + CPT_LF_Q_GRP_PTR);
833         } while ((cnt < 10) && (grp_ptr.s.nq_ptr != grp_ptr.s.dq_ptr));
834
835         cnt = 0;
836         do {
837                 lf_inprog.u = plt_read64(lf->rbase + CPT_LF_INPROG);
838                 if ((lf_inprog.s.inflight == 0) && (lf_inprog.s.gwb_cnt < 40) &&
839                     ((lf_inprog.s.grb_cnt == 0) || (lf_inprog.s.grb_cnt == 40)))
840                         cnt++;
841                 else
842                         cnt = 0;
843         } while (cnt < 10);
844 }
845
846 void
847 roc_cpt_iq_enable(struct roc_cpt_lf *lf)
848 {
849         union cpt_lf_inprog lf_inprog;
850         union cpt_lf_ctl lf_ctl;
851
852         /* Disable command queue */
853         roc_cpt_iq_disable(lf);
854
855         /* Enable instruction queue enqueuing */
856         lf_ctl.u = plt_read64(lf->rbase + CPT_LF_CTL);
857         lf_ctl.s.ena = 1;
858         lf_ctl.s.fc_ena = 1;
859         lf_ctl.s.fc_up_crossing = 0;
860         lf_ctl.s.fc_hyst_bits = lf->fc_hyst_bits;
861         plt_write64(lf_ctl.u, lf->rbase + CPT_LF_CTL);
862
863         /* Enable command queue execution */
864         lf_inprog.u = plt_read64(lf->rbase + CPT_LF_INPROG);
865         lf_inprog.s.eena = 1;
866         plt_write64(lf_inprog.u, lf->rbase + CPT_LF_INPROG);
867
868         cpt_lf_dump(lf);
869 }
870
871 int
872 roc_cpt_lmtline_init(struct roc_cpt *roc_cpt, struct roc_cpt_lmtline *lmtline,
873                      int lf_id)
874 {
875         struct roc_cpt_lf *lf;
876
877         lf = roc_cpt->lf[lf_id];
878         if (lf == NULL)
879                 return -ENOTSUP;
880
881         lmtline->io_addr = lf->io_addr;
882         if (roc_model_is_cn10k())
883                 lmtline->io_addr |= ROC_CN10K_CPT_INST_DW_M1 << 4;
884
885         lmtline->fc_addr = lf->fc_addr;
886         lmtline->lmt_base = lf->lmt_base;
887
888         return 0;
889 }