Files
Justin Hibbits aefd61a1de dpaa: Add LRO and receive callback batching
Reduce the code executed in the DQRR dequeue loop, and move the
heavy-weight operations to post-dequeue loop.

* Batch if_input() after DQRR dispatch loop completes.  Only do the
  DQRR_CI_CINH write at the end of the loop, so only up to 16 entries
  will be processed.
* Add software LRO per FQ.  Each per-CPU RX FQ gets its own LRO tracking
  structure.

Since LRO is configured at FQ initialization time, allocate the ifnet
earlier in attach to prevent a panic.
2026-08-23 23:11:27 -04:00

215 lines
4.7 KiB
C

/*
* Copyright (c) 2026 Justin Hibbits
*
* SPDX-License-Identifier: BSD-2-Clause
*/
#ifndef QMAN_VAR_H
#define QMAN_VAR_H
#include <sys/queue.h>
#include "dpaa_common.h"
#include "portals.h"
struct qman_eqcr_entry {
uint8_t verb;
uint8_t dca;
uint16_t seqnum;
uint32_t orp;
uint32_t fqid;
uint32_t tag;
struct dpaa_fd fd;
uint8_t _rsvd[32];
};
_Static_assert(sizeof(struct qman_eqcr_entry) == 64, "EQCR entry mis-sized");
DPAA_RING_DECLARE(qman_eqcr);
DPAA_RING_DECLARE(qman_dqrr);
DPAA_RING_DECLARE(qman_mr);
union qman_mc_command {
struct {
uint8_t verb;
uint8_t data[63];
} common;
struct {
uint8_t verb;
uint8_t _rsvd0;
uint16_t we_mask;
uint32_t fqid; /* Only bottom 24 bits allowed */
uint16_t count;
uint8_t orpc;
uint8_t cgid;
uint16_t fq_ctrl;
uint16_t dest_chan:13;
uint16_t dest_wq:3;
uint16_t ics_cred;
uint16_t td_thresh_oac;
uint32_t context_b;
uint64_t context_a;
uint8_t _rsvd1[32];
} init_fq;
struct {
uint8_t verb;
uint8_t _rsvd0[3];
uint32_t fqid; /* Only bottom 24 bits used */
uint8_t _rsvd1[56];
} query_fq;
struct {
uint8_t verb;
uint8_t _rsvd0[3];
uint32_t fqid;
uint8_t _rsvd1[56];
} query_fq_np;
struct {
uint8_t verb;
uint8_t _rsvd0[3];
uint32_t fqid;
uint8_t _rsvd1;
uint8_t count;
uint8_t _rsvd2[10];
uint32_t context_b;
uint8_t _rsvd3[40];
} alter_fqs;
};
union qman_mc_result {
struct {
uint8_t verb;
uint8_t data[63];
} common;
struct {
uint8_t verb;
uint8_t rslt;
uint8_t _rsvd[62];
} init_fq;
struct {
uint8_t verb;
uint8_t rslt;
uint8_t _rsvd0[8];
uint8_t orpc;
uint8_t cgid;
uint16_t fq_ctrl;
uint16_t dest_wq;
uint16_t ics_cred;
uint16_t td_thresh;
uint32_t context_b;
uint64_t context_a; /* 8 bytes on the wire */
uint16_t oac;
uint8_t _rsvd1[30];
} query_fq;
struct {
uint8_t verb;
uint8_t rslt;
uint8_t _rsvd0;
uint8_t state;
uint32_t fqd_link;
uint16_t odp_seq;
uint16_t orp_nesn;
uint16_t orp_ea_hseq;
uint16_t orp_ea_tseq;
uint32_t orp_ea_hptr;
uint32_t orp_ea_tptr;
uint32_t pfdr_hptr;
uint32_t pfdr_tptr;
uint8_t _rsvd1[5];
uint8_t is;
uint16_t ics_surp;
uint32_t byte_cnt;
uint32_t frm_cnt;
uint32_t _rsvd2;
uint16_t ra1_sfdr;
uint16_t ra2_sfdr;
uint16_t _rsvd3;
uint16_t od1_sfdr;
uint16_t od2_sfdr;
uint16_t od3_sfdr;
} query_fq_np;
struct {
uint8_t verb;
uint8_t rslt;
uint8_t fqs;
uint8_t _rsvd[61];
} alter_fqs;
};
_Static_assert(sizeof(union qman_mc_command) == 64, "MC command mis-sized");
_Static_assert(sizeof(union qman_mc_result) == 64, "MC result mis-sized");
#define QCSP_VERB_INIT_FQ_PARK 0x40
#define QCSP_VERB_INIT_FQ_SCHED 0x41
#define QCSP_VERB_QUERY_FQ 0x44
#define QCSP_VERB_QUERY_FQ_NP 0x45
#define QCSP_VERB_ALTER_FQ_SCHED 0x48
#define QCSP_VERB_ALTER_FQ_FE 0x49
#define QCSP_VERB_ALTER_FQ_RETIRE 0x4a
#define QCSP_VERB_ALTER_FQ_TAKE_OUT 0x4b
#define QCSP_VERB_ALTER_FQ_RETIRE_CTXB 0x4c
#define QCSP_VERB_ALTER_FQ_XON 0x4d
#define QCSP_VERB_ALTER_FQ_XOFF 0x4e
/* Init FQ */
#define QCSP_INIT_FQ_WE_OAC 0x0100
#define QCSP_INIT_FQ_WE_ORPC 0x0080
#define QCSP_INIT_FQ_WE_CGID 0x0040
#define QCSP_INIT_FQ_WE_FQ_CTRL 0x0020
#define QCSP_INIT_FQ_WE_DEST_WQ 0x0010
#define QCSP_INIT_FQ_WE_ICS_CRED 0x0008
#define QCSP_INIT_FQ_WE_TD_THRESH 0x0004
#define QCSP_INIT_FQ_WE_CONTEXT_B 0x0002
#define QCSP_INIT_FQ_WE_CONTEXT_A 0x0001
#define QMAN_MC_RES_OK 0xf0
#define QMAN_MC_AFQS_NE 0x01
/* Init FQ options */
#define QM_FQCTRL_CGE 0x0400
#define QM_FQCTRL_TDE 0x0200
#define QM_FQCTRL_ORP 0x0100
#define QM_FQCTRL_CTXASTASH 0x0080
#define QM_FQCTRL_CPCSTASH 0x0040
#define QM_FQCTRL_FORCESFDR 0x0008
#define QM_FQCTRL_AVOIDBLOCK 0x0004
#define QM_FQCTRL_HOLDACTIVE 0x0002
#define QM_FQCTRL_LIC 0x0001
struct qman_mc {
uint8_t polarity;
bool busy;
};
struct qman_fq {
uint32_t fqid; /* base FQID of the range */
uint32_t fqid_count; /* length of the range (>=1) */
bool force_fqid; /* caller owns the FQID allocation */
bool dirty; /* on a portal's dirty list this poll */
SLIST_ENTRY(qman_fq) dirty_next;/* DQRR loop dirty list. */
struct qman_cb cb;
};
struct qman_portal_softc {
struct dpaa_portal_softc sc_base;
/* Rings (Enqueue, Dequeue, Message */
struct qman_eqcr_ring sc_eqcr;
struct qman_dqrr_ring sc_dqrr;
struct qman_mr_ring sc_mr;
struct qman_mc sc_mc;
int sc_affine_channel;
};
struct qman_fq *qman_fq_from_index(uint32_t fqid);
union qman_mc_result *
qman_portal_mc_send_raw(device_t, union qman_mc_command *);
int qman_portal_fq_enqueue(device_t, struct qman_fq *, struct dpaa_fd *);
void qman_portal_static_dequeue_channel(device_t, int);
void qman_portal_static_dequeue_rm_channel(device_t dev, int channel);
extern int qman_channel_base;
DPCPU_DECLARE(device_t, qman_affine_portal);
#endif /* QMAN_VAR_H */