hc
2024-01-05 071106ecf68c401173c58808b1cf5f68cc50d390
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
/* SPDX-License-Identifier: GPL-2.0-only */
/*
 * Copyright (C) 2015 Cavium, Inc.
 */
 
#ifndef NICVF_QUEUES_H
#define NICVF_QUEUES_H
 
#include <linux/netdevice.h>
#include <linux/iommu.h>
#include <net/xdp.h>
#include "q_struct.h"
 
#define MAX_QUEUE_SET            128
#define MAX_RCV_QUEUES_PER_QS        8
#define MAX_RCV_BUF_DESC_RINGS_PER_QS    2
#define MAX_SND_QUEUES_PER_QS        8
#define MAX_CMP_QUEUES_PER_QS        8
 
/* VF's queue interrupt ranges */
#define    NICVF_INTR_ID_CQ        0
#define    NICVF_INTR_ID_SQ        8
#define    NICVF_INTR_ID_RBDR        16
#define    NICVF_INTR_ID_MISC        18
#define    NICVF_INTR_ID_QS_ERR        19
 
#define    for_each_cq_irq(irq)    \
   for (irq = NICVF_INTR_ID_CQ; irq < NICVF_INTR_ID_SQ; irq++)
#define    for_each_sq_irq(irq)    \
   for (irq = NICVF_INTR_ID_SQ; irq < NICVF_INTR_ID_RBDR; irq++)
#define    for_each_rbdr_irq(irq)    \
   for (irq = NICVF_INTR_ID_RBDR; irq < NICVF_INTR_ID_MISC; irq++)
 
#define RBDR_SIZE0        0ULL /* 8K entries */
#define RBDR_SIZE1        1ULL /* 16K entries */
#define RBDR_SIZE2        2ULL /* 32K entries */
#define RBDR_SIZE3        3ULL /* 64K entries */
#define RBDR_SIZE4        4ULL /* 126K entries */
#define RBDR_SIZE5        5ULL /* 256K entries */
#define RBDR_SIZE6        6ULL /* 512K entries */
 
#define SND_QUEUE_SIZE0        0ULL /* 1K entries */
#define SND_QUEUE_SIZE1        1ULL /* 2K entries */
#define SND_QUEUE_SIZE2        2ULL /* 4K entries */
#define SND_QUEUE_SIZE3        3ULL /* 8K entries */
#define SND_QUEUE_SIZE4        4ULL /* 16K entries */
#define SND_QUEUE_SIZE5        5ULL /* 32K entries */
#define SND_QUEUE_SIZE6        6ULL /* 64K entries */
 
#define CMP_QUEUE_SIZE0        0ULL /* 1K entries */
#define CMP_QUEUE_SIZE1        1ULL /* 2K entries */
#define CMP_QUEUE_SIZE2        2ULL /* 4K entries */
#define CMP_QUEUE_SIZE3        3ULL /* 8K entries */
#define CMP_QUEUE_SIZE4        4ULL /* 16K entries */
#define CMP_QUEUE_SIZE5        5ULL /* 32K entries */
#define CMP_QUEUE_SIZE6        6ULL /* 64K entries */
 
/* Default queue count per QS, its lengths and threshold values */
#define DEFAULT_RBDR_CNT    1
 
#define SND_QSIZE        SND_QUEUE_SIZE0
#define SND_QUEUE_LEN        (1ULL << (SND_QSIZE + 10))
#define MIN_SND_QUEUE_LEN    (1ULL << (SND_QUEUE_SIZE0 + 10))
#define MAX_SND_QUEUE_LEN    (1ULL << (SND_QUEUE_SIZE6 + 10))
#define SND_QUEUE_THRESH    2ULL
#define MIN_SQ_DESC_PER_PKT_XMIT    2
/* Since timestamp not enabled, otherwise 2 */
#define MAX_CQE_PER_PKT_XMIT        1
 
/* Keep CQ and SQ sizes same, if timestamping
 * is enabled this equation will change.
 */
#define CMP_QSIZE        CMP_QUEUE_SIZE0
#define CMP_QUEUE_LEN        (1ULL << (CMP_QSIZE + 10))
#define MIN_CMP_QUEUE_LEN    (1ULL << (CMP_QUEUE_SIZE0 + 10))
#define MAX_CMP_QUEUE_LEN    (1ULL << (CMP_QUEUE_SIZE6 + 10))
#define CMP_QUEUE_CQE_THRESH    (NAPI_POLL_WEIGHT / 2)
#define CMP_QUEUE_TIMER_THRESH    80 /* ~2usec */
 
/* No of CQEs that might anyway gets used by HW due to pipelining
 * effects irrespective of PASS/DROP/LEVELS being configured
 */
#define CMP_QUEUE_PIPELINE_RSVD 544
 
#define RBDR_SIZE        RBDR_SIZE0
#define RCV_BUF_COUNT        (1ULL << (RBDR_SIZE + 13))
#define MAX_RCV_BUF_COUNT    (1ULL << (RBDR_SIZE6 + 13))
#define RBDR_THRESH        (RCV_BUF_COUNT / 2)
#define DMA_BUFFER_LEN        1536 /* In multiples of 128bytes */
#define RCV_FRAG_LEN     (SKB_DATA_ALIGN(DMA_BUFFER_LEN + NET_SKB_PAD) + \
            SKB_DATA_ALIGN(sizeof(struct skb_shared_info)))
 
#define MAX_CQES_FOR_TX        ((SND_QUEUE_LEN / MIN_SQ_DESC_PER_PKT_XMIT) * \
                MAX_CQE_PER_PKT_XMIT)
 
/* RED and Backpressure levels of CQ for pkt reception
 * For CQ, level is a measure of emptiness i.e 0x0 means full
 * eg: For CQ of size 4K, and for pass/drop levels of 160/144
 * HW accepts pkt if unused CQE >= 2560
 * RED accepts pkt if unused CQE < 2304 & >= 2560
 * DROPs pkts if unused CQE < 2304
 */
#define RQ_PASS_CQ_LVL         224ULL
#define RQ_DROP_CQ_LVL         216ULL
 
/* RED and Backpressure levels of RBDR for pkt reception
 * For RBDR, level is a measure of fullness i.e 0x0 means empty
 * eg: For RBDR of size 8K, and for pass/drop levels of 4/0
 * HW accepts pkt if unused RBs >= 256
 * RED accepts pkt if unused RBs < 256 & >= 0
 * DROPs pkts if unused RBs < 0
 */
#define RQ_PASS_RBDR_LVL    8ULL
#define RQ_DROP_RBDR_LVL    0ULL
 
/* Descriptor size in bytes */
#define SND_QUEUE_DESC_SIZE    16
#define CMP_QUEUE_DESC_SIZE    512
 
/* Buffer / descriptor alignments */
#define NICVF_RCV_BUF_ALIGN        7
#define NICVF_RCV_BUF_ALIGN_BYTES    (1ULL << NICVF_RCV_BUF_ALIGN)
#define NICVF_CQ_BASE_ALIGN_BYTES    512  /* 9 bits */
#define NICVF_SQ_BASE_ALIGN_BYTES    128  /* 7 bits */
 
#define NICVF_ALIGNED_ADDR(ADDR, ALIGN_BYTES)    ALIGN(ADDR, ALIGN_BYTES)
 
/* Queue enable/disable */
#define NICVF_SQ_EN        BIT_ULL(19)
 
/* Queue reset */
#define NICVF_CQ_RESET        BIT_ULL(41)
#define NICVF_SQ_RESET        BIT_ULL(17)
#define NICVF_RBDR_RESET    BIT_ULL(43)
 
enum CQ_RX_ERRLVL_E {
   CQ_ERRLVL_MAC,
   CQ_ERRLVL_L2,
   CQ_ERRLVL_L3,
   CQ_ERRLVL_L4,
};
 
enum CQ_RX_ERROP_E {
   CQ_RX_ERROP_RE_NONE = 0x0,
   CQ_RX_ERROP_RE_PARTIAL = 0x1,
   CQ_RX_ERROP_RE_JABBER = 0x2,
   CQ_RX_ERROP_RE_FCS = 0x7,
   CQ_RX_ERROP_RE_TERMINATE = 0x9,
   CQ_RX_ERROP_RE_RX_CTL = 0xb,
   CQ_RX_ERROP_PREL2_ERR = 0x1f,
   CQ_RX_ERROP_L2_FRAGMENT = 0x20,
   CQ_RX_ERROP_L2_OVERRUN = 0x21,
   CQ_RX_ERROP_L2_PFCS = 0x22,
   CQ_RX_ERROP_L2_PUNY = 0x23,
   CQ_RX_ERROP_L2_MAL = 0x24,
   CQ_RX_ERROP_L2_OVERSIZE = 0x25,
   CQ_RX_ERROP_L2_UNDERSIZE = 0x26,
   CQ_RX_ERROP_L2_LENMISM = 0x27,
   CQ_RX_ERROP_L2_PCLP = 0x28,
   CQ_RX_ERROP_IP_NOT = 0x41,
   CQ_RX_ERROP_IP_CSUM_ERR = 0x42,
   CQ_RX_ERROP_IP_MAL = 0x43,
   CQ_RX_ERROP_IP_MALD = 0x44,
   CQ_RX_ERROP_IP_HOP = 0x45,
   CQ_RX_ERROP_L3_ICRC = 0x46,
   CQ_RX_ERROP_L3_PCLP = 0x47,
   CQ_RX_ERROP_L4_MAL = 0x61,
   CQ_RX_ERROP_L4_CHK = 0x62,
   CQ_RX_ERROP_UDP_LEN = 0x63,
   CQ_RX_ERROP_L4_PORT = 0x64,
   CQ_RX_ERROP_TCP_FLAG = 0x65,
   CQ_RX_ERROP_TCP_OFFSET = 0x66,
   CQ_RX_ERROP_L4_PCLP = 0x67,
   CQ_RX_ERROP_RBDR_TRUNC = 0x70,
};
 
enum CQ_TX_ERROP_E {
   CQ_TX_ERROP_GOOD = 0x0,
   CQ_TX_ERROP_DESC_FAULT = 0x10,
   CQ_TX_ERROP_HDR_CONS_ERR = 0x11,
   CQ_TX_ERROP_SUBDC_ERR = 0x12,
   CQ_TX_ERROP_MAX_SIZE_VIOL = 0x13,
   CQ_TX_ERROP_IMM_SIZE_OFLOW = 0x80,
   CQ_TX_ERROP_DATA_SEQUENCE_ERR = 0x81,
   CQ_TX_ERROP_MEM_SEQUENCE_ERR = 0x82,
   CQ_TX_ERROP_LOCK_VIOL = 0x83,
   CQ_TX_ERROP_DATA_FAULT = 0x84,
   CQ_TX_ERROP_TSTMP_CONFLICT = 0x85,
   CQ_TX_ERROP_TSTMP_TIMEOUT = 0x86,
   CQ_TX_ERROP_MEM_FAULT = 0x87,
   CQ_TX_ERROP_CK_OVERLAP = 0x88,
   CQ_TX_ERROP_CK_OFLOW = 0x89,
   CQ_TX_ERROP_ENUM_LAST = 0x8a,
};
 
enum RQ_SQ_STATS {
   RQ_SQ_STATS_OCTS,
   RQ_SQ_STATS_PKTS,
};
 
struct rx_tx_queue_stats {
   u64    bytes;
   u64    pkts;
} ____cacheline_aligned_in_smp;
 
struct q_desc_mem {
   dma_addr_t    dma;
   u64        size;
   u32        q_len;
   dma_addr_t    phys_base;
   void        *base;
   void        *unalign_base;
};
 
struct pgcache {
   struct page    *page;
   int        ref_count;
   u64        dma_addr;
};
 
struct rbdr {
   bool        enable;
   u32        dma_size;
   u32        frag_len;
   u32        thresh;        /* Threshold level for interrupt */
   void        *desc;
   u32        head;
   u32        tail;
   struct q_desc_mem   dmem;
   bool        is_xdp;
 
   /* For page recycling */
   int        pgidx;
   int        pgcnt;
   int        pgalloc;
   struct pgcache    *pgcache;
} ____cacheline_aligned_in_smp;
 
struct rcv_queue {
   bool        enable;
   struct    rbdr    *rbdr_start;
   struct    rbdr    *rbdr_cont;
   bool        en_tcp_reassembly;
   u8        cq_qs;  /* CQ's QS to which this RQ is assigned */
   u8        cq_idx; /* CQ index (0 to 7) in the QS */
   u8        cont_rbdr_qs;      /* Continue buffer ptrs - QS num */
   u8        cont_qs_rbdr_idx;  /* RBDR idx in the cont QS */
   u8        start_rbdr_qs;     /* First buffer ptrs - QS num */
   u8        start_qs_rbdr_idx; /* RBDR idx in the above QS */
   u8        caching;
   struct        rx_tx_queue_stats stats;
   struct xdp_rxq_info xdp_rxq;
} ____cacheline_aligned_in_smp;
 
struct cmp_queue {
   bool        enable;
   u16        thresh;
   spinlock_t    lock;  /* lock to serialize processing CQEs */
   void        *desc;
   struct q_desc_mem   dmem;
   int        irq;
} ____cacheline_aligned_in_smp;
 
struct snd_queue {
   bool        enable;
   u8        cq_qs;  /* CQ's QS to which this SQ is pointing */
   u8        cq_idx; /* CQ index (0 to 7) in the above QS */
   u16        thresh;
   atomic_t    free_cnt;
   u32        head;
   u32        tail;
   u64        *skbuff;
   void        *desc;
   u64        *xdp_page;
   u16        xdp_desc_cnt;
   u16        xdp_free_cnt;
   bool        is_xdp;
 
   /* For TSO segment's header */
   char        *tso_hdrs;
   dma_addr_t    tso_hdrs_phys;
 
   cpumask_t    affinity_mask;
   struct q_desc_mem   dmem;
   struct rx_tx_queue_stats stats;
} ____cacheline_aligned_in_smp;
 
struct queue_set {
   bool        enable;
   bool        be_en;
   u8        vnic_id;
   u8        rq_cnt;
   u8        cq_cnt;
   u64        cq_len;
   u8        sq_cnt;
   u64        sq_len;
   u8        rbdr_cnt;
   u64        rbdr_len;
   struct    rcv_queue    rq[MAX_RCV_QUEUES_PER_QS];
   struct    cmp_queue    cq[MAX_CMP_QUEUES_PER_QS];
   struct    snd_queue    sq[MAX_SND_QUEUES_PER_QS];
   struct    rbdr        rbdr[MAX_RCV_BUF_DESC_RINGS_PER_QS];
} ____cacheline_aligned_in_smp;
 
#define GET_RBDR_DESC(RING, idx)\
       (&(((struct rbdr_entry_t *)((RING)->desc))[idx]))
#define GET_SQ_DESC(RING, idx)\
       (&(((struct sq_hdr_subdesc *)((RING)->desc))[idx]))
#define GET_CQ_DESC(RING, idx)\
       (&(((union cq_desc_t *)((RING)->desc))[idx]))
 
/* CQ status bits */
#define    CQ_WR_FULL    BIT(26)
#define    CQ_WR_DISABLE    BIT(25)
#define    CQ_WR_FAULT    BIT(24)
#define    CQ_CQE_COUNT    (0xFFFF << 0)
 
#define    CQ_ERR_MASK    (CQ_WR_FULL | CQ_WR_DISABLE | CQ_WR_FAULT)
 
static inline u64 nicvf_iova_to_phys(struct nicvf *nic, dma_addr_t dma_addr)
{
   /* Translation is installed only when IOMMU is present */
   if (nic->iommu_domain)
       return iommu_iova_to_phys(nic->iommu_domain, dma_addr);
   return dma_addr;
}
 
void nicvf_unmap_sndq_buffers(struct nicvf *nic, struct snd_queue *sq,
                 int hdr_sqe, u8 subdesc_cnt);
void nicvf_config_vlan_stripping(struct nicvf *nic,
                netdev_features_t features);
int nicvf_set_qset_resources(struct nicvf *nic);
int nicvf_config_data_transfer(struct nicvf *nic, bool enable);
void nicvf_qset_config(struct nicvf *nic, bool enable);
void nicvf_cmp_queue_config(struct nicvf *nic, struct queue_set *qs,
               int qidx, bool enable);
 
void nicvf_sq_enable(struct nicvf *nic, struct snd_queue *sq, int qidx);
void nicvf_sq_disable(struct nicvf *nic, int qidx);
void nicvf_put_sq_desc(struct snd_queue *sq, int desc_cnt);
void nicvf_sq_free_used_descs(struct net_device *netdev,
                 struct snd_queue *sq, int qidx);
int nicvf_sq_append_skb(struct nicvf *nic, struct snd_queue *sq,
           struct sk_buff *skb, u8 sq_num);
int nicvf_xdp_sq_append_pkt(struct nicvf *nic, struct snd_queue *sq,
               u64 bufaddr, u64 dma_addr, u16 len);
void nicvf_xdp_sq_doorbell(struct nicvf *nic, struct snd_queue *sq, int sq_num);
 
struct sk_buff *nicvf_get_rcv_skb(struct nicvf *nic,
                 struct cqe_rx_t *cqe_rx, bool xdp);
void nicvf_rbdr_task(struct tasklet_struct *t);
void nicvf_rbdr_work(struct work_struct *work);
 
void nicvf_enable_intr(struct nicvf *nic, int int_type, int q_idx);
void nicvf_disable_intr(struct nicvf *nic, int int_type, int q_idx);
void nicvf_clear_intr(struct nicvf *nic, int int_type, int q_idx);
int nicvf_is_intr_enabled(struct nicvf *nic, int int_type, int q_idx);
 
/* Register access APIs */
void nicvf_reg_write(struct nicvf *nic, u64 offset, u64 val);
u64  nicvf_reg_read(struct nicvf *nic, u64 offset);
void nicvf_qset_reg_write(struct nicvf *nic, u64 offset, u64 val);
u64 nicvf_qset_reg_read(struct nicvf *nic, u64 offset);
void nicvf_queue_reg_write(struct nicvf *nic, u64 offset,
              u64 qidx, u64 val);
u64  nicvf_queue_reg_read(struct nicvf *nic,
             u64 offset, u64 qidx);
 
/* Stats */
void nicvf_update_rq_stats(struct nicvf *nic, int rq_idx);
void nicvf_update_sq_stats(struct nicvf *nic, int sq_idx);
int nicvf_check_cqe_rx_errs(struct nicvf *nic, struct cqe_rx_t *cqe_rx);
int nicvf_check_cqe_tx_errs(struct nicvf *nic, struct cqe_send_t *cqe_tx);
#endif /* NICVF_QUEUES_H */