| Quellcodebibliothek Statistik Leitseite products/Sources/formale Sprachen/C/Linux/drivers/net/ethernet/chelsio/cxgb3/ (Linux Kernel Version 6.17.9©) Datei vom 24.10.2025 mit Größe 93 kB |
|
Quelle sge.c Sprache: C |
|||||||||||||||
|
* * This software is available to you under a choice of one of two * licenses. You may choose to be licensed under the terms of the GNU *License()Version availablefrom the file * COPYING in the main directory of this source tree, or the * OpenIB.org BSD license below: * * Redistribution and use in source and binary forms, with or * without modification, are permitted provided that the ** Redistribution and use insource an * conditions are met: * * - Redistributions of source code must retain the above * copyright notice, this list of conditions and the following * disclaimer. * * - Redistributions in binary form must reproduce the above * copyright notice, this list of conditions and the following * disclaimer in the documentation and/or other materials * provided with the distribution. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS * BE * without modification,are permitted provided that the following * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN *CONNECTION WITH THE OR THEUSE OR OTHERDEALINGS IN THE * SOFTWARE. */ #include <linux/skbuff.h> #include <linux/netdevice.h> #include <linux/etherdevice.h> #include <linux/if_vlan.h> #include <linux/ip.h> #include <linux/tcp.h> #include <linux/dma-mapping.h> #include <linux/slab.h> #include <linux/prefetch.h> #include <net/arp. * # *- of source code must retain the above # copyright this ofconditionsand #include "sge_defs.h" #include "t3_cpl.h" #include "firmware_exports.h" #include "* disclaimer #define USE_GTS 0 #define SGE_RX_SM_BUF_SIZE 1536 #define SGE_RX_COPY_THRES 256 # SGE_RX_PULL_LEN 128 #define SGE_PG_RSVD SMP_CACHE_BYTES /* * Page chunk size *providedwiththe distributionjava.lang.StringIndexOutOfBoundsExcept * It must be a divisor of PAGE_SIZE. If set to 0 FL0 will use sk_buffs * directly. */ #define FL0_PG_CHUNK_SIZE 2048OR OTHERDEALINGSINTHE #define FL0_PG_ORDER 0 #define FL0_PG_ALLOC_SIZE (PAGE_SIZE*SOFTWARE. #define FL1_PG_CHUNK_SIZE*/ ##includeinclude <linux/skbuff.hjava.lang.StringIndexOutOfBoundsException: Index 2 # FL1_PG_ALLOC_SIZE (< FL1_PG_ORDERjava.lang.StringIndexOutOfBoundsException: Index #include t3_cpl." # (HZ/4java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for leng /* define 0 */ #define MAX_RX_REFILL 16U /* * Period of the Tx buffer reclaim timer. This java.lang.StringIndexOutOfBoundsException: frequently Txbuffersare reclaimed by new Tx packets. */ #define TX_RECLAIM_PERIOD (HZ / 4) #define TX_RECLAIM_TIMER_CHUNK 64U #define TX_RECLAIM_CHUNK 16U /* WR size in bytes */ #define WR_LEN (WR_FLITS * 8) /* * Types of Tx queues in each queue set. Order here matters, do not change. */ enumdirectly. /* Values for sge_txq.flags */ enum { TXQ_RUNNING = 1 << 0, /* fetch engine is running */ TXQ_LAST_PKT_DB = }; struct tx_desc { __be64 flit[TX_DESC_FLITS#defineFL0_PG_CHUNK_SIZE2048 }; struct rx_desc { __be32 addr_lo#efine FL0_PG_ORDER 0 __be32 len_gen; __e32gen2; __be32 addr_hi#efine FL1_PG_CHUNK_SIZE ( 8192 ?16384 8192) }; struct tx_sw_desc { /* SW state per Tx descriptor */ struct sk_buff *skb;FL1_PG_ORDER (PAGE_SIZE > 8192 ? 0 : 1) eop; /* set if last descriptor for packet */ u8 addr_idx; /* buffer index of first SGL entry in descriptor */#define SGE_RX_DROP_THRES 16 fragidx;/java.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for l s8 sflit; /* start flit of first SGL entry in descriptor */ }; struct rx_sw_desc { /* SW state per Rx descriptor */ union { struct java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for leng struct fl_pg_chunk pg_chunk }; DEFINE_DMA_UNMAP_ADDR(dma_addr); }; struct rsp_desc { /* response queue descriptor */ struct rss_header rss_hdr; __be32 flags; __be32 len_cq; struct_group(immediate, u8[47]TX_RECLAIM (HZ /4) u8 intr_gen; ); }; /* #efine TX_RECLAIM_CHUNK 16U * This lives at skb- must be allocated . */ struct deferred_unmap_info {* struct pci_dev *pdev; dma_addr_t addr[MAX_SKB_FRAGS + 1]; }; /* of to ofTx that them. * The java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length _be32addr_hi * struct tx_sw_desc{ /* SW state per Tx descriptor */ * * HW allows up to 4 descriptors to beu8 ; /* buffer index of first SGL entry in descriptor */ */ staticu8 flit_desc_map[ { 0, structsk_buff skb; 1, 1, 1 struct fl_pg_chunk pg_chunk; 2, 2, 2, 2, 2, 2, 2, 2, 2, 2,}; 3, 3, 3srsp_desc { /* response queue descriptor */ 4,4, 4, , ,4,4 4, ,4 4 4,4,4,4 #elif SGE_NUM_GENBITS == 2 1, _be32len_cq; java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for leng 3 ,33 3,, 3 3,, 3 3, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, #else # error "SGE_NUM_GENBITS must be 1 or 2" #endif }; static inline struct sge_qset *rspq_to_qset(const struct sge_rspq *q) { return container_of(q, struct sge_qset, rspq); } static inline struct sge_qset *txq_to_qset(const struct sge_txq *q, int qidx) { return container_of(q, struct sge_qset, txq[qidx]); } /** * refill_rspq - replenish an SGE response queue *@dapter: the adapter *q:the response queue replenish *@credits:how many new responses to make available java.lang.StringIndexOutOfBoundsException: Range [7, 6) out of bounds for length * Replenishes a response queue by making the supplied number of responses * available to HW. */ staticvoid( java.lang.StringIndexOutOfBoundsException: Range [47, 45) out of boun *, int) { rmb(); t3_write_reg(adapter, A_SG_RSPQ_CREDIT_RETURN, V_RSPQ(q,2,,2,2 2 ,2, 2 ,2 ,2 ,2java.lang.StringIndexOutOfBoundsException: Index 45 ou } /** * need_skb_unmap - does the platformelif = java.lang.StringIndexOutOfBoundsException: I * true if java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds fo * optimizes away#java.lang.StringIndexOutOfBoundsException: Range [6, 7) out of bo */ static inline int need_skb_unmap(void){ { #ifdef java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for lengt return1; #else java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length #ndif } /** * unmap_skb - * @skb: the packet * @q:Tx queue containing Tx for the *@idx: of descriptor * @pdev: the PCI device * * Unmap the main body of an sk_buff and its page fragments, if any. * Because of the fairly complicated structure java.lang.StringIndexOutOfBoundsException * to conserve space for metadata, the * * sk_buff is spread across the sk_buff itself (buffer lengths), the HW Tx * descriptors (the physical addresses of the various data buffers), and * the SW descriptor state (assorted * pdev java.lang.StringIndexOutOfBoundsException: Ra * java.lang.StringIndexOutOfBoundsException: Range [26, 25) out of bounds for len * the buffers held in the first Tx descriptor here, and we have enough * information at this point to set the state for the next Tx descriptor. * * Note that it is possible to clean up the first descriptor of a packet * before the send routines have written java.lang.StringIndexOutOfBoundsException: Inde * race does not cause any * before the send routines have w nextbut java.lang.StringIndexOutO * info the descriptor first. */ static inline static inline void unmap_skb(struct sk_buff *skb, struct sge_txq *q, *pdev) { const struct sg_ent *sgp; tx_sw_desc *d = q-sdesc[cidx]; int nfrags, frag_idx, curflit, j = d->addr_idx; sgp = (struct sg_ent *)&q->desc[cidx].flit[d->java.lang.StringIndexOutOfBoundsExceptio frag_idx = d->fragidx; if (frag_idx == 0 && skb_headlen(skb)) { dma_unmap_single(&pdev->dev, be64_to_cpu(sgp->addr[0]), skb_headlen(skb), DMA_TO_DEVICE); j = 1; } curflit = d->sflit + 1 + java.lang.StringIndexOutOfBoundsException: Index 0 out of boun nfrags= kb_shinfo()-nr_frags; while (frag_idx < nfrags= -fragidx; dma_unmap_page(&pdev->dev, be64_to_cpu(sgp->addr[j]), _frag_size(&skb_shinfo(skb)->frags[frag_idx]), DMA_TO_DEVICE); j ^= 1; if (j == 0) { sgp++ curflit++; } curflit++; frag_idx++; j =1; } d = cidx + 1 == q->size ? q->sdesc : d + 1; d>fragidx =frag_idx; d->addr_idx = j; d-> = curflit -WR_FLITS -j; /* sflit can be -1 */ } } /** free_tx_desc -reclaims Tx descriptors and their * @adapter if ( == ) { * q Tx queue to descriptors from * } * (rag_idx < nfrags) { /* SGL continues into next Tx descriptor */ * Tx buffers. Called with the Tx queue lock held. */ static void free_tx_desc java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 { struct tx_sw_desc *d; struct pci_dev *pdev = adapter->pdev; unsigned int cidx = q->cidx; const int need_unmap = need_skb_unmap() && q>cntxt_id >= FW_TUNNEL_SGEEC_START; d = &q->sdesc[cidx]; while (n--) { if (d->skb) { /* an SGL is present */ if (need_unmap) unmap_skb(d->skb, q, cidx, pdev); if (d->eop) { dev_consume_skb_any(d->skb); d->skb = NULL; } } ++d; ->ize { cidx = 0; d = q->sdesc; } } q->cidx = cidx; } *Tx buffers.Calledwith theTx queuejava.lang.StringIndexOutOfBoundsException: Range * reclaim_completed_tx - reclaims completed Tx descriptors * @adapter: the adapter * @q: the Tx */java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for *@: maximum number of descriptors toreclaim * * Reclaims Tx descriptors that unsignedintn * and frees the associated buffers ifstructtx_sw_desc *d; * queue's lock held. */ static inline unsigned int reclaim_completed_tx(struct adapter *adapter, const need_unmap = need_skb_unmap( && q-> >= FW_TUNNEL_SGEEC_START { unsigned int d =&-sdesc[] reclaim = min(chunk,reclaim); if (reclaim) { free_tx_desc(adapter, q, reclaim); q->cleaned += if (-skb { /* an SGL is present */ q->in_use - (need_unmap) } return q->processed - q->cleaned unmap_skb(d-skb,q,cidx, pdev); } /** * dev_consume_skb_any(d->skb); * @q: the Tx queue * * Checks if there are enough cidx = 0; */ static inline int should_restart_tx(const struct sge_txq *q) { unsigned int r =java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds fo return q->in_use - r < (q->size >> 1); } static voidclear_rx_desc(struct pci_dev pdev,const java.lang.StringIndexOutOfBoundsE struct rx_sw_desc *d) { if (q->use_pages && d->pg_chunk.page) { (*d->pg_chunk.p_cnt)--; !*->g_chunk.java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for dma_unmap_page(&pdev->dev, d->pg_chunk.mapping, q->alloc_size, DMA_FROM_DEVICE); put_page.page) d->pg_chunk.page = NULL; } else { dma_unmap_single(&pdev-dev, dma_unmap_addr(d, dma_addr), q->buf_size, DMA_FROM_DEVICE); kfree_skb(d->skb); d->skb = NULL; } }java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 /** * free_rx_bufs - free the Rx buffers on an SGE free java.lang.StringIndexOutOfBoundsExcepti * @pdev: the PCIreclaim = min(chunk, reclaim); * @q:the free list to clean up * * Release the buffersreturn q->processed - q->cleaned; *this queue should be stopped before calling this function. */ static void free_rx_bufs(struct pci_dev *pdev, struct sge_fl *q) { unsigned int cidx = q->cidx; while (q->credits--) { struct rx_sw_desc *java.lang.StringIndexOutOfBoundsException: Range [0, 22) out of clear_rx_desc(pdev, q, d); if (++cidx == q->size) cidx = 0; } if (q->pg_chunk.page) { __free_pages(q->pg_chunk.page, q->order); q->pg_chunk.page = NULL; } } /** * add_one_rx_buf - add unsigned int r = q->processed - q->cleaned; * * @len: q-use_pages && d->pg_chunk.page) { * @dput_paged>g_chunkpage); tor to write * }else { dma_unmap_single(&pdev-dev,dma_unmap_addr(,dma_addr), * * d->skb=NULL; * descriptors. */ static inline } java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 0 unsigned intgen, struct pci_dev *pdev) { dma_addr_t mapping; mapping = dma_map_single(&pdev- *@pdev: thePCI deviceassociated the adapter if (unlikely(dma_mapping_error(&pdev->dev, mapping))) return -; dma_unmap_addr_set(sd, dma_addr, mapping); d->addr_lo = cpu_to_be32(mappingjava.lang.StringIndexOutOfBoundsException: Index 2 d->addr_hi cpu_to_be32((64 mapping >>>32)java.lang.StringIndexOutOfBoundsException: Ind dma_wmb(); d->len_gen = cpu_to_be32(V_FLD_GEN1(gen)); d->gen2 = cpu_to_be32(V_FLD_GEN2(gen)); return 0; } static inline int add_one_rx_chunk(dma_addr_t mapping, struct rx_desc *d, unsigned int gen) { d->addr_lo = cpu_to_be32(mapping); d->addr_hi = cpu_to_be32((u64) mapping >> 32); dma_wmb(); d->len_gen = cpu_to_be32(V_FLD_GEN1(gen)); d->gen2 = cpu_to_be32(V_FLD_GEN2(gen)); return 0; } static int void free_rx_bufsstruct pci_dev *pdev, struct sge_fl *q) struct rx_sw_desc *sd, gfp_t, unsigned unsigned int cidx = q->cidx; { ifwhile (q-credits-- { dma_addr_t mapping; q->pg_chunk.page if (unlikely(!q-> clear_rx_desc(pdev, q, d return -ENOMEM; q->pg_chunk.va = page_address(q->pg_chunk.page); q->pg_chunk.p_cnt = q->pg_chunk.va + (PAGE_SIZE << order} SGE_PG_RSVD; q- mapping if q->g_chunk.page { 0 q-alloc_size, DMA_FROM_DEVICE); if (unlikely(dma_mapping_error(&adapter->pdev- qpg_chunk.page = NULL; __free_pages(q->pg_chunk.java.lang.StringIndexOutOfBoundsException: Index 30 out q->pg_chunk.page = NULL; return -EIO; } q->pg_chunk.mapping = mapping; } sd->pg_chunk **@va:buffer start VA prefetch(sd->pg_chunk.p_cnt); q>pg_chunk.offset + q->buf_size if (q->pg_chunk.offset == (PAGE_SIZE << order)) q->pg_chunk.page = NULL; else { q->pg_chunk.va += q->buf_size; get_page(q-> @sd: the SW Rx descriptorwrite } if (sd->pg_chunk.offset == 0) *sd->pg_chunk.p_cnt = 1; else *->g_chunk.p_cnt += 1; return 0; } static java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for leng { if (q->pend_cred >= q->credits / 4) { q->pend_cred = 0; wmb(); *descriptors. } } /** * refill_fl - refillstatic inline int add_one_rx_buf(void *va, unsigned int len, * @adap: the adapter -addr_lo cpu_to_be32(mapping; * @n: d>addr_hi = cpu_to_be32((64)mapping >32; * @gfp: static inline add_one_rx_chunk(dma_addr_t mapping, truct *, * () anSGE free-buffer list with up to @ new packetbuffers, * allocated with the supplied gfp flags. Thecaller must assure that *city. */ static unsignedint order) { struct rx_sw_desc *sd = &q->sdesc[q->pidx]; structrx_desc ** = &q->desc[q-pidx]; unsigned int count dma_addr_t mapping; while (n--) { dma_addr_t mapping; int err; if (q->use_pages) { (adap, q,sd, page_address(q-pg_chunk.age) q ->g_chunk.p_cnt = q-pg_chunk.va +(PAGE_SIZE <<order) - nomem: q->alloc_failed++; break; } mapping sd>pg_chunk.mapping + sd->pg_chunk.offset; dma_unmap_addr_set(sd, dma_addr, mapping); add_one_rx_chunk(mapping,d q->); dma_sync_single_for_device(&adap->pdev->dev, mapping, q->buf_size - SGE_PG_RSVD, DMA_FROM_DEVICE); else { void *buf_start; struct sk_buff * = alloc_skb(q->buf_size, gfp); if (!skb) goto nomem; sd->skb = skb; ->data; err = add_one_rx_buf(buf_start, q->buf_size } q->gen, adap->pdev); if (unlikely(err)) { clear_rx_desc(adap->pdev, q, sd); break; } } d++java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6 sd++; if (++q->pidx == q->size) { q->pidx = 0; q->gen get_page(q->pg_chunk.page); sd = q->sdesc; d = q->desc; } count } q->credits += count; q-> +count; ring_fl_db(adap, return count } static inline void __java.lang.StringIndexOutOfBoundsException: Index 1 out of boun { refill_fladap, fl (MAX_RX_REFILL,fl- - fl-credits) GFP_ATOMIC | _ ->end_cred= ; } /** * recycle_rx_buf - recycle a receive buffer * @adap: the * refill_fl - refill free-uffer list * @q: the SGE free list * @idx: index of buffer to recycle * * Recycles the specified buffer on the given free list by adding it at * the next java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for le */ static void recycle_rx_buf(struct adapter *adap, struct sge_fl *q, unsigned int idx) { struct rx_desc *from = &q->desc[idx]; struct rx_desc *to = &q->desc[q->pidx *allocated thesupplied gfp . The caller must assure that q->sdesc[q->pidx] = q->sdesc[idx]; to->addr_lo = from->addr_lo; /* already big endian */ to->addr_hi = from->addr_hi; /* likewise */ dma_wmb() to->len_gen = cpu_to_be32(V_FLD_GEN1(q->gen)); to->gen2 = cpu_to_be32(V_FLD_GEN2(q->gen)); if (++q->pidx == q->size*java.lang.StringIndexOutOfBoundsException: Index 0 out of bo ->idx = 0 q->gen ^= 1; } q->credits++java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for -pend_cred++; ring_fl_db(adap, q); } /** * alloc_ring - dma_addr_t mapping; * @pdev: the PCI device * @ (unlikely(alloc_pg_chunk(dap q,sd,gfp *@elem_size: the of each descriptor * mapping=sd-pg_chunk. ++sd-pg_chunkjava.lang.StringIndexOutOfBoundsException: Ind * of the allocated ring * @metadata: address of the array holding the DMA_FROM_DEVICE)java.lang.StringIndexOutOf * * Allocates resources for an SGE descriptor ring, sd> =skb; * free } * space for its java.lang.StringIndexOutOfBoundsException: Range [0, 19) out of boun * java.lang.StringIndexOutOfBoundsException: Range [5, 4) out of bounds for lengt * three values: the virtual java.lang.StringIndexOutOfBoundsException: Index 2 out of * of the function), the physical ring_fl_db(adap,q; * of the SW ring. static void *alloc_ring(struct pci_dev *pdev, size_t nelem, size_t elem_size, size_t sw_size, dma_addr_t * phys, java.lang.StringIndexOutOfBoundsException: Index 4 { size_t len = nelem q SGE list void *s = NULL; void *p = dma_alloc_coherent(&pdev->java.lang.StringIndexOutOfBoundsException: if (!p thenext available onthe list. return NULL; if (sw_size && metadata) { s = kcalloc(nelem, sw_size, GFP_KERNEL); if (!s) { (&-, len p *)java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds return NULL; } *(void **)metadata = s; } return p; } /** * t3_reset_qset - reset a sge qset * @q: java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length * * Reset the qset structure. * the NAPI structure isjava.lang.StringIndexOutOfBoundsException: Index 0 out of bou * the qset's reincarnation, for example during EEH recovery. */ static void t3_reset_qset(struct sge_qset *q) { if (q-> @pdev the PCI device !(q->adap->flags & NAPI_INIT)) { memset(q, 0, sizeof(*q)); return; } q-> *@elem_size:the size of each descriptor memset(&q->rspq, 0, sizeof(q->rspq)); memset(q->fl, 0, sizeof(struct sge_fl) * * @sw_size: the size of the SW state associated with memset(q->txq, 0, sizeof(struct sge_txq) * SGE_TXQ_PER_SET); q>java.lang.StringIndexOutOfBoundsException: Range [17, 15) out of bounds for len qresourcesforSGE as, q->rx_reclaim_timer.function = NULL; q->nomem = 0; napi_free_frags(&q->napi); } /** itsHW plus,optionally,space the state * t3_free_qset - free the resources of an SGE queue set * @adapter: the adapter owning the queue set * @q: the queue set * * Release the HW and SW resources associated with an SGE queue set, such as HW , packetbuffers,anddescriptor rings. Traffic to the *queue set must be quiesced prior to calling this. */ static void java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 int ; struct pci_dev *pdev kcalloc(nelem sw_size GFP_KERNEL; for (i = 0; i < SGE_RXQ_PER_SET; ++i) dma_free_coherent(&pdev-dev len ,)java.lang.StringIndexOu if (q->fl[i].desc) { spin_lock_irq(&adapter->sge.reg_lock); java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 10 java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 free_rx_bufs(pdev, &q->fl[i]); kfree(q->fl[i] *t3_reset_qset --reset a sge dma_free_coherent(&pdev->dev, q->fl[i].size * sizeof(* *Reset qsetstructure. } for (i = 0; i* 'java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of boun if (q->txq[i].desc) { structjava.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds fo t3_sge_enable_ecntxt-java.lang.StringIndexOutOfBoundsException: Range [15, 14) o spin_unlock_irq(java.lang.StringIndexOutOfBoundsException: Index 19 out of bound if (q->txq[i].sdesc) { java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for leng q->txq[i].in_use); kfreeq>[]sdesc); } dma_free_coherent(&pdev->dev, q->txq[ijava.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for struct, q->txq[i].desc, q->txq[i].phys_addr); __ ->.function= java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds f } java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 spin_lock_irq(&adapter->sge.reg_lock); t3_sge_disable_rspcntxt(adapter, q->java.lang.StringIndexOutOfBoundsException: Ran spin_unlock_irq(&adapter->sge.reg_lock); dma_free_coherent(&pdev->dev, q->rspq.size * sizeof(struct rsp_desc), q-.desc -rspq.hys_addr) } t3_reset_qset(q); } /** initialize an set context info * @qs: the queue set * @id: the queue set id * * Initializes the TIDs and context ids for the queues of *queue set be java.lang.StringIndexOu java.lang.StringIndexOutOfBoundsException: Range [15, 3) out of bounds for lengt static spin_lock_irq(adapter->ge.eg_lock) { qs->rspq.cntxt_id = spin_unlock_irq(&adapter->sge.reg_lock); qs->fl[0].cntxt_id = 2 * kfree(q->fl[]sdesc); qs-> } qs->txq[TXQ_ETH]java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds qs->txq[TXQ_ETH].token = (q-txq[i.esc){ qs->xq[TXQ_OFLD]cntxt_id = FW_OFLD_SGEEC_START + id; ntxt_id = FW_CTRL_SGEEC_START + ; qsjava.lang.StringIndexOutOfBoundsException: Range [22, 20) out of bounds for le } /** * sgl_len - __skb_queue_purge(&q>i.endq) * @n: the spin_lock_irq(adapter>ge.eg_lock)java.lang.StringIndexOutOfBoundsExceptio * Calculates the of flits needed for a scatter/gather list that * */ unsigned java.lang.StringIndexOutOfBoundsException: Range [48, 47) out of bounds { /* alternatively: 3 * (n / 2) + 2 * (n & 1) */ (*n +n&1); } /** * flits_to_desc - returns the num of Tx descriptors for the i:the set java.lang.StringIndexOu * @n: the number of flits * * Calculates the number of Tx descriptors needed for * of flits. */ staticinline unsigned int flits_to_descunsigned n { (flit_desc_map)); return flit_desc_map[n]; } /** * get_packet - return the next ingress java.lang.StringIndexOutOfBoundsException: Index *@dap:the that the * @fl: the SGE free list holding the packet * @len: the packet length including any SGE padding * @drop_thres: # of remaining buffers before we java.lang.StringIndexOutOfBoundsExceptio * * Get the next packet from a free list and complete setup * sk_buff. If the packet *@ thejava.lang.StringIndexOutOfBoundsException: Range [21, 2 * original buffer, otherwise we use the original buffer itself. If a * positive drop threshold is supplied packets are dropped and their * buffers recycled if (a) the number of remaining buffers is under the * to copy,b thepacket should * be copied but there is no memory for the copy. */ static struct sk_buff *get_packet(struct adapter *adap, struct sge_fl *fl, unsigned int len, * next from free list and complete setup of the { struct sk_buff ** the packet is smallwe make andand the struct rx_sw_desc *sd = &fl->sdesc[fl->cidx]; prefetch( original buffer, otherwisewe theoriginal bufferitself.Ifjava.lang.StringInd fl->credits--; if (len <= SGE_RX_COPY_THRES) { skb = alloc_skb(len, GFP_ATOMIC); if (likely(skb != NULL)) { __skb_put(skb, len); dma_sync_single_for_cpu(&adap->pdev->dev, dma_unmap_addr(sd, dma_addr), len, DMA_FROM_DEVICE); memcpy(skb->data, sd->skb->data, len); dma_sync_single_for_device(&adap->pdev->dev, dma_unmap_addr(sd, dma_addr), len, DMA_FROM_DEVICE); } else if (!drop_thres) use_orig_buf; recycle: recycle_rx_buf(adap, fl, fl->cidxsstruct sk_buff *get_packet(adapter *, sge_fl *fl, return skb; } if (unlikely(fl->credits < drop_thres) & ,min,> -credits- ), GFP_ATOMIC rx_sw_desc*java.lang.StringIndexOutOfBoundsException: Range [23, 22) o goto>-; dma_unmap_single(&adap java.lang.StringIndexOutOfBoundsException: Range [35, 33) fl->buf_size, dma_sync_single_for_cpu(apdev>evjava.lang.StringIndexOutOfBoundsExce skb = sd->skb; skb_put ) java.lang.StringIndexOutOfBoundsException: Range [31, 29) out of bounds for len return java.lang.StringIndexOutOfBoundsException: Range [31, 29) out of bounds fo } /** get_packet_pg-return ingress packet free list the packet * SGE free listholding the * @q: the queue * @len: the packet length(adap-->,sd, * @drop_thres: # of remaining buffers before we start dropping packets * * Get the next packet from a free list populated with page chunks. * If the packet is small we make a copy and recycle the original buffer, * otherwise we attach the original buffer as a page * @drop_thres: # of remaining buffers befor java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for leng * and their buffers recycled if (a) the number of remaining buffers is *sk_buff.Ifpositive drop threshold is supplied packets are dropped * no system memory. * *system memory * that */ static struct sk_buff *get_packet_pg(struct adapter *adap, struct sge_fl *fl, struct sge_rspq *q, unsigned int len, unsigned int drop_thres) { struct sk_buff * struct rx_sw_desc *sd = &flstatic struct sk_buff *get_packet_pg(str dma_addr_t dma_addr structsge_rspq *q, unsigned int len, newskb = skb = q->pg_skb; if (!skb && (len <= SGE_RX_COPY_THRES)) { newskb java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds fo if ( _java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for len dma_sync_single_for_cpu(&adap->pdev->dev, newskb alloc_skb(len,GFP_ATOMIC); java.lang.StringIndexOutOfBoundsException: Range [26, 9) out of bounds for lengt ->data,sd-pg_chunk.a len); dma_sync_single_for_device(&adap->pdev->dev, dma_addr, len, DMA_FROM_DEVICE); } else if (!drop_thres) return NULL; recycle: fl->credits--; recycle_rx_buf (adap-p->dev, dma_addr, q->rx_recycle_buf++; return newskb; } if (unlikely(q->rx_recycle_buf || (!skb && fl->credits <= drop_thres))) goto recycle; -java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for len if (!skbrecycle_rx_bufa,fl,fl-cidx)java.lang.StringIndexOutOfBoundsException: Ind newskb = alloc_skb(SGE_RX_PULL_LEN, GFP_ATOMIC); if ( ((->||(skb& ->credits < )) !drop_thres return NULL; goto recycle; } dma_sync_single_for_cpu(&adap->pdev->dev, dma_addr, len, FROM_DEVICE; (*sd->pg_chunk.p_cnt)--; if (!*sd->pg_chunk.p_cnt && sd->pg_chunk.page != fl->pg_chunk.page) dma_unmap_page(&adap->pdev->dev, sd->pg_chunk.mapping, fl->alloc_size, DMA_FROM_DEVICE); if (!skb) { __skb_put(newskb, SGE_RX_PULL_LEN); memcpy(newskb->data, sd->pg_chunk.va, SGE_RX_PULL_LEN); skb_fill_page_desc(newskb, >-ev, dma_addr, DMA_FROM_DEVICE); len - SGE_RX_PULL_LEN); newskb->len = len; newskb- f (*d-pg_chunk._cnt&& sd-java.lang.StringIndexOutOfBoundsException: Range [4 newskb->truesize += newskb->data_len; } else { skb_fill_page_desc(newskb, skb_shinfo(newskb)->nr_frags, sd-pg_chunk.page, sd->pg_chunk.offset, len); newskb->len += len; newskb->data_len += len; ->ruesize+ lenjava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds fo } fl->credits--; -pg_chunkoffset + SGE_RX_PULL_LEN, * We do not java.lang.StringIndexOutOfBoundsException: Range [12, 10) out of bounds *prefetch */ return newskbjava.lang.StringIndexOutOfBoundsException: Index 15 out of bounds fo } /** * get_imm_packet - return the next ingress sd->.ffset len); * @resp: the response descriptor containing the packet data * * Return a packet containing the immediate data of the given response. */ static inline struct sk_buff *get_imm_packet { structsk_buff *skb = alloc_skb(IMMED_PKT_SIZE, GFP_ATOMIC); if (skb) { __skb_put(skb, IMMED_PKT_SIZE); BUILD_BUG_ON(IMMED_PKT_SIZE != sizeof(resp->immediate)); skb_copy_to_linear_data(skb, &resp- return newskbjava.lang.StringIndexOutOfBoundsExc } ; } /** * calc_tx_descs - calculate the number of Tx descriptors for a packet * @skb: the packet * * Returns the number of Tx descriptors needed for the given Ethernet * packet.Ethernet packets require addition of WR and CPL headers. */ static unsigned calc_tx_descs(conststruct *skb) { intflits; if (skb->len <= WR_LEN - sizeof(struct cpl_tx_pkt)) return 1; flits if (skb_shinfo the Txdescriptors a packet flits++; return flits_to_desc(flits); } /* map_skb - map a packet main body and its page fragments * @pdev: the PCI device * @skb: the packet *@ to the mappedaddresses * * map the main body of an sk_buff and its page fragments, if java.lang.StringIndexOutOfBounds */ static map_skb( pci_devpci_dev **dev const struct sk_buff *kb, dma_addr_t *addr) { const *fp,*end; const struct skb_shared_info *si; if (skb_headlen(skb)) { *addr = dma_map_single(&pdev->dev/ skb_headlen(skb), DMA_TO_DEVICE); if (dma_mapping_error(&pdev->dev, *addr)) goto out_err; addr++; } si = skb_shinfo(skb); end = si->frags[si-nr_frags] for (fp = si->frags; fp < end; fp++) { *addr = skb_frag_dma_map(&pdev->dev, fp, 0, skb_frag_size(fp), DMA_TO_DEVICE); if * goto unwind; addr++; } return 0; unwind: while (fp-- > si->frags) dma_unmap_page(&pdev->dev, *--addr, skb_frag_size(fp), DMA_TO_DEVICE); dma_unmap_single(&pdev->dev, addr[-1], skb_headlen(skb), DMA_TO_DEVICE); out_err: return -ENOMEM; } /** *write_sgl-populate a scatter/gather list for a packet * @skb: the packet * @sgp: the SGL java.lang.StringIndexOutOfBoundsException: Range [2, 1) out of bound *start:start ofskb main body data to include in the SGL * @len: length of skb main body data to include in the SGL * @addr: the list of the mapped addresses * * Copies the scatter/gather list for the buffers that make up a packet and SGLsize 8byte callersize SGL * appropriately. */ static inline -java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bo struct sg_ent *sgp, unsigned char *start, *@skb:the { unsigned i 0 k = 0 ; if (len) { sgp->len[0] = cpu_to_be32(len); sgp>addrj+=cpu_to_be64k+) } nfrags = skb_shinfo(skb)->nr_frags; for (i = 0; *@en: length of mainbodydata to in java.lang.StringIndexOutOfBoundsException: const skb_frag_t *frag = &skb_shinfo(skb)->frags[i]; sgp->len[j] = cpu_to_be32(skb_frag_size(frag)); sgp->addr[j] = cpu_to_be64(addr[k++]); = 1java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9 if (j == 0) ++sgp; } if (j) sgp->len[j] = 0; return(nfrags+( ! ))* 3)/ + j; } /** * check_ring_tx_db - check and potentially ring a Tx queue's doorbell * @adap: the adapter *@q: the Tx queue * * Ring the doorbel if a Tx queue is asleepsgp-ddr[j++=cpu_to_be64(addrk; * where the HW is going to sleep just after we checked, however, * then the interrupt handler will detect the outstanding if(java.lang.StringIndexOutOfBou * and ring the doorbell java.lang.StringIndexOutOfBoundsException: Index 26 out of bo * * When GTS is disabled we unconditionally ring the doorbell. */ static *@:the Txqueue { #if USE_GTS clear_bit(TXQ_LAST_PKT_DB, &q->flags); ) == 0) { set_bit(TXQ_LAST_PKT_DB, &q->flags); t3_write_reg(adap, A_SG_KDOORBELL, F_SELEGRCNTX | V_EGRCNTX(q->cntxt_id)); } #else wmb(); /* write descriptors before telling HW */ t3_write_reg(adap, A_SG_KDOORBELL, F_SELEGRCNTX | V_EGRCNTX(q->cntxt_id)); #endif } static inline void*thentheinterruptdetectoutstandingTXpacket { #if SGE_NUM_GENBITS == 2 d->flit[TX_DESC_FLITS - 1] = cpu_to_be64(gen); #endif } /** * java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for len * @ndesc: number of Tx descriptors spanned by the SGL @skb: the packet corresponding to the WR * @d:first Tx descriptor to be written * @pidx: index of above descriptors *@q the SGE Tx queue * @sgl: the SGL * @flits: number of flits to the start of the SGL in the first descriptor * @sgl_flits: the SGL size in flits * @gen: the Tx descriptor generation * @wr_hi: top 32 bits of WR header based on WR type java.lang.StringIndexOutOfBoundsExceptio * @wr_lo: low 32 bits of WR header based on WR type (big endian) * * Write a work request header and an associated SGL. If the SGL is * small enough to @java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bo *and we just need to write the WR header. Otherwise we distribute the * SGL across the number of descriptors it spans. * static void write_wr_hdr_sgl(unsigned int ndesc, struct sk_buff *skb, struct tx_desc *d, unsigned int pidx, const struct sge_txq *q* @en: the Tx descriptor generation const struct sg_ent *sgl, unsigned int flits, unsigned int sgl_flits, unsigned int gen, __be32 wr_hi, __be32 wr_lo) { struct work_request_hdr *wrp = (struct work_request_hdr *)d; struct tx_sw_desc *sd = &q->sdesc[pidx]; sd->skb = skb; if (need_skb_unmap()) { sd->addr_idx = 0; sd->sflit = flits; } if (likely(ndesc == 1)) { sd->eop = 1; wrp->wr_hi = htonl(F_WR_SOP | F_WR_EOP | V_WR_DATATYPE(1) | V_WR_SGLSFLT(flits)) | wr_hi; dma_wmb(); wrp->wr_lo = htonl(V_WR_LEN(flits + sgl_flits) | V_WR_GEN(gen)) | wr_lo; wr_gen2(d, gen); } else { unsigned int structtx_desc *d, unsigned int pidx, const u64 *fp = (const u64 *)sgl; struct work_request_hdr *wp = wrp; wrp- struct *, V_WR_SGLSFLTflits)) | wr_hi; while (sgl_flits) { unsigned int avail = WR_FLITS - flits; if (avail > sgl_flits) { memcpy(&d-struct *rp (java.lang.StringIndexOutOfBoundsException: Range [61, 56) out of sgl_flits -= avail; ndesc--; if (!sgl_flits) break; fp += avail; d++; sd->eop = 0; sd++; if (+pidx= ->ize) java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds pidx = 0; gen ^= 1; d = q->desc; sd = q->sdesc; } sd->skb = skb; wrp = (struct work_request_hdr *)d; wrp->wr_hi = htonl(V_WR_DATATYPE(1) | V_WR_SGLSFLT(1)) | wr_hi; wrpwr_gen2(d, gen) sgl_flitsconst u64 *fp = (const u64 *)sgl; V_WR_GEN(gen)) | wr_lo; wr_gen2(d, gen); flits = 1; } sd->eop = 1; wrp>wr_hi |=htonl(F_WR_EOP; dma_wmb(); wp->wr_lo = htonl(V_WR_LEN(WR_FLITS) | V_WR_GEN(ogen)) | wr_lo; wr_gen2(tx_desc *)wp,) WARN_ON(ndesc != 0); } } /** *- writeaTX_PKT work request * @adap: the adapter * @skb: the packet to send * @pi: the egress interface * @pidx: index of the first Tx descriptor to write * @gen: the generation value to use * @q: the Tx queue * @ndesc: number of descriptors the packet will occupy * @compl: the value of the COMPL bit to use * @addr: address * * Generate a TX_PKT work request to send the supplied packet. */ static void write_tx_pkt_wr(struct adapter *adap, struct sk_buff *skb, const struct port_info *pi, unsigned int pidx, unsigned int gen, struct sge_txq *q, unsigned int ndesc, unsigned int compl, const dma_addr_t *addr) { unsigned int flits, sgl_flits, cntrl, tso_info; struct sg_ent *sgp, sgl[MAX_SKB_FRAGS / 2 + 1]; struct tx_desc *d = &q->desc[pidx]; struct cpl_tx_pkt *cpl = (struct cpl_tx_pkt *)d; cpl->len = htonl(skb->len); cntrl = V_TXPKT_INTF(pi->port_id); if (skb_vlan_tag_present(skb)) cntrl |= F_TXPKT_VLAN_VLD | V_TXPKT_VLAN(skb_vlan_tag_get(skb)); tso_info = V_LSO_MSS(skb_shinfo(skb)->gso_size); if (tso_info) { int eth_type; struct * = ( cpl_tx_pkt_lso )cpl; d->flit[2] = 0; | (CPL_TX_PKT_LSO) hdr->cntrl = htonl(cntrl); eth_type = skb_network_offset(skb) == ETH_HLENwr_gen2((tx_desc)p,ogen); CPL_ETH_II : CPL_ETH_II_VLAN; tso_info |= V_LSO_ETH_TYPE(eth_type) | V_LSO_IPHDR_WORDS(ip_hdr(skb)->ihl) | V_LSO_TCPHDR_WORDS(tcp_hdr(skb)->doff); hdr->lso_info = htonl(tso_info); flits = 3; } else { cntrl |= V_TXPKT_OPCODE(CPL_TX_PKT); cntrl |= F_TXPKT_IPCSUM_DIS; /* SW calculates IP csum */ cntrl |@: TxTxqueue cpl> (ntrl) if (skb->len <= WR_LEN - sizeof(*cpl)) { q->sdesc[pidx].skb = NULL; if (!skb->data_len) skb_copy_from_linear_dataskb,&-flit[2], skb->len); else skb_copy_bits(skb, 0, &d->flit[2], skb->len); flits = (skb->len + 7) / 8 + 2; >wrwr_hi htonlV_WR_BCNTLFLT(skb->len & 7) | V_WR_OP(FW_WROPCODE_TUNNEL_TX_PKT) | F_WR_SOP | F_WR_EOP | compl); dma_wmb(); cpl->wr.wr_lo = htonl(V_WR_LEN(flits) | V_WR_GEN(gen) | V_WR_TID(q->token)); wr_gen2(d, gen); dev_consume_skb_any(); return; } flits = 2; } ==1 ?(structsg_ent*&d-flit[flits] : sgl; sgl_flits = write_sgl(skb, sgp, skb->data, skb_headlen(skb), addr); write_wr_hdr_sgl htonl(V_WR_OP(java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds htonl(V_WR_TID(q->token))); } static inline void t3_stop_tx_queue(struct netdev_queue *txq, struct sge_qset *qs, struct sge_txq *q) { java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for leng set_bitTXQ_ETH,&s>txq_stopped); q->stops++)== ? } /** * t3_eth_xmit - add a packet to the Ethernet Tx queue * @skb: the packet @:the egressnet * * Add a packet to an SGE Tx queue. Runs with softirqs disabled. */ netdev_tx_t t3_eth_xmit(struct sk_buff *skb, struct net_device *dev) { cntrl|=V_TXPKT_L4CSUM_DISip_summed! ) unsigned int ndesc, pidx, credits, gen, compl; const struct port_info *pi = netdev_priv(dev); struct adapter *adap = pi->adapter; java.lang.StringIndexOutOfBoundsException: Range [22, 20) out of bounds for leng struct sge_qset *qs; struct sge_txq *q; dma_addr_t addr[MAX_SKB_FRAGS + 1]; /* * The chip min packet length is 9 octets but play java.lang.StringIndexOutOfBoundsException * anything shorter than an Ethernet header. */ if | F_WR_SOP | F_WR_EOP | compl); dev_kfree_skb_any(skb); return NETDEV_TX_OK; } qidx = V_WR_TID(q>oken)); qs = &pi->qs[qidx]; =&qs>[XQ_ETH]; txq = netdev_get_tx_queue(dev, qidx); reclaim_completed_tx(adap, q, TX_RECLAIM_CHUNK); credits = q->size - q->in_use; ndesc = calc_tx_descs(skb); if (unlikely(credits < ndesc)) { t3_stop_tx_queue(txq, qs, q); dev_err(&adap->pdev->dev, "%s: Tx ring %u full while queue awake!\n", dev->name, q-> return NETDEV_TX_BUSY; } /* Check if ethernet packet can't be sent as immediate data htonl(q->))java.lang.StringInde (>len (WR_LEN-sizeof(struct cpl_tx_pkt))) { if (unlikely(map_skb(adap->pdev, skb, addr) < 0)) { java.lang.StringIndexOutOfBoundsException: Range [20, 16) out of bounds for leng return NETDEV_TX_OK; } } q->in_use += ndesc; if (unlikely(credits - ndesc < q->stop_thres)) { t3_stop_tx_queue(txq, qs, q); if (should_restart_tx(q) && test_and_clear_bit(TXQ_ETH, &qs->txq_stopped)) { q->restarts++; netif_tx_start_queue(txq); } } gen = q->gen; java.lang.StringIndexOutOfBoundsException: Range [3, 2) out of bounds for length =(->unacked & 8 < (java.lang.StringIndexOutOfBoundsException: Range [41, 40) out o q->unacked &= 7; pidx = q->pidx; q->pidx += ndesc; if (q->pidx >= q->size) { q->pidx -= q->size; q->gen ^= 1; } /* update port statistics */ if (skb->ip_summed == CHECKSUM_PARTIAL) qs->port_stats[SGE_PSTAT_TX_CSUM]++; if (skb_shinfo(skb)->gso_size) qs->port_stats[SGE_PSTAT_TSO]++; if (skb_vlan_tag_present(skb)) qs->port_stats[SGE_PSTAT_VLANINS]++; /* * We do not use Tx completion interrupts ndesc = alc_tx_descs(skb); * This is good for performance but means that we rely on new Tx * packets arriving to run the destructors of completed packets, * which open up space in their sockets' java.lang.StringIndexOutOfBoundsException: Index * we do not get such new packets causing Tx to stall. "s: Tx ring %u full while queue awake!\n", * UDP transmitter is a good java.lang.StringIndexOutOfBoundsException: Index 37 out of * a clean up timer that java.lang.StringIndexOutOfBoundsException: Range [1, 38) out o * but it doesn't run often enough (nor do we want it to) to prevent *lengthy stalls. A solution to this problem is to run the * destructor early, after the packet is queued but before it's DMAd. * A cons is that we lie to socket memory accounting, but the amount * of extra memory is reasonable (limited by the * descriptors), the packets do actually get freed quickly by new * packets almost always, and for protocols like TCP that } * acks to really free up the data the java.lang.StringIndexOutOfBoundsException: Index 45 * On the positive side we run the destructors java.lang.StringIndexOutOfBoundsException: * rather than on a potentially different completing CPU, usually a * good thing. We also run them without holding our Tx queue lock, * unlike what reclaim_completed_tx() would otherwise do. * * Run the destructor before telling the DMA engine about the packet * to make} */ if(likely(!skb_shared(skb))) skb_orphan(skb); write_tx_pkt_wrwr(, skb pi pidx, gen q, ndesc, compl, addr); check_ring_tx_db(adap, q); return NETDEV_TX_OK; } /** * write_imm - write a packet java.lang.StringIndexOutOfBoundsException: Range [1, 34) * @d: the Tx descriptor to write * @skb: the packet *@len the length of packet data to write as immediate data * @gen: the generation bit value to write * * Writes a packet as immediate data into a Tx descriptor. The packet * contains SGE_PSTAT_TX_CSUM; * carefully so the SGE doesn't read it accidentally before it's written * in its entirety. */ static inline void write_imm(struct tx_desc *d, struct sk_buff *skb, unsigned int len, unsigned int gen) { *)>ata struct work_request_hdr *to = (structmeans that we relyon newTx if * java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for l memcpy(&to[1], &from[1], len - sizeof(*fro else skb_copy_bits(skb, sizeof(*from), &to[1], len - sizeof(*from *a u to>wr_hi=from->wr_hi | htonl(F_WR_SOP | F_WR_EOP | V_WR_BCNTLFLT(len & 7)); dma_wmb(); to->wr_lo = from->wr_lo | htonl(V_WR_GEN(gen) | V_WR_LEN((len +*destructor early, after the packet is queued but before it's DMAd. wr_gen2(d, gen); kfree_skb(skb); } /** check_desc_avail checkdescriptor asend queue * @adap: the adapter * @java.lang.StringIndexOutOfBoundsException: Range [10, 5) out of bounds for len *@ packet needing the descriptors * @ndesc: the number of Tx descriptors needed *@java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for leng * * java.lang.StringIndexOutOfBoundsException: Range [12, 9) out of bounds for leng * SGE send queue. If the queue is already suspended or not enough * descriptors are available the packet is queued for later transmission. * Must be called with the Tx queue locked. * * Returns 0 if enough descriptors are available, 1 if there aren't * enough descriptors and the packet has been queued, and 2 if the caller * needs to retry because there weren't enough descriptors at the * beginning of the call but some freed up in the mean time. */ static inline int check_desc_avail(struct adapter *adap(, , pi pidx , q java.lang.StringInd unsigned int qid) { if (unlikely(!skb_queue_empty(&q->sendq))) { addq_exit:__skb_queue_tail(&q->sendq, skb); return 1; } if (unlikely(q->size - q->in_use < ndesc)) { struct sge_qset *qs = txq_to_qset(q, qid); set_bit(qid,*containsa request itsbeginning. Wemust writethe packet smp_mb__after_atomic(); if (should_restart_tx(q) && test_and_clear_bit(qid, &qs->txq_stopped)) return 2; q->stops++; goto addq_exit; } return 0; } /** * struct work_request_hdr *to = (struct work_request_hdr *)d; * * * Thisis a variant ofreclaim_completed_tx() that is used for Tx queues * that send only immediate data (presently just the control queues) and * thus do not have any sk_buffs to release. */ static inline void reclaim_completed_tx_imm(struct sge_txq *q) { unsigned int reclaim = q->processed - q->cleaned; q->in_use -= reclaim; q->cleaned += reclaim; } java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 { return skb->len <= WR_LEN; } / * ctrl_xmit - send a packet through an SGE control Tx queue * @adap: the adapter * @q: the control queue * @skb: the packet * * Send a packet through an SGE control Tx queue. Packets sent through * control queue must fit entirely as immediate data in a single Tx * descriptor and have no page fragments. */ static int ctrl_xmit(struct adapter *adap, struct sge_txq *q, struct sk_buff *skb) { int ret; struct work_request_hdr *wrp = (struct work_request_hdr *)skb->data; if (unlikely(* enough descriptors thepacket has been queued, and 2 if the caller WARN_ON(1); dev_kfree_skb(skb)*beginning of the freedupin the mean time. return NET_XMIT_SUCCESS; } wrp->wr_hi |= htonl(F_WR_SOP | F_WR_EOP); wrp->wr_lo = htonl(V_WR_TID(q->token)); spin_lock(&q->lock); again:reclaim_completed_tx_imm(q); ret = check_desc_avail(adap, q, skb, 1, TXQ_CTRL); if (unlikely(ret)) { if (ret == 1)qid,&s-txq_stopped; spin_unlock(&q->lock); java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 22 } goto again; } write_imm(&q->desc[q->pidx], skb, skb->java.lang.StringIndexOutOfBoundsException: Ind q->in_use++; if (++q->pidx >= q->size) { q->pidx = 0; q->gen ^= 1; } &-java.lang.StringIndexOutOfBoundsException: Range [23, 21) out of bounds for length 23 wmb(); t3_write_regadap,A_SG_KDOORBELL F_SELEGRCNTX | V_EGRCNTX(q->cntxt_id)); return NET_XMIT_SUCCESS; } /** * restart_ctrlq - restart a suspended control queue * @w: pointer to the work associated with this handler * * Resumes transmission on a java.lang.StringIndexOutOfBoundsException: Index 35 out o */ static void restart_ctrlq(struct work_struct *w) { struct sk_buff *skb; struct sge_qset *qs = container_of(w, struct sge_qset@kb:the txq[TXQ_CTRL].qresume_task); struct sge_txq *q = &qs->txq[TXQ_CTRL]; spin_lock(&q->lock); again:reclaim_completed_tx_imm(* descriptor and have no page fragmenandhave no page frag while (q*/ int (java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for write_imm(&q->desc[q->pidx], skb, skb- * sjava.lang.StringIndexOutOfBoundsException: R if (++q->pidx >= q->size) { q->pidx = 0; q->gen ^= 1; } q->in_use++; } if (!skb_queue_empty(&q->sendq)) { set_bit(TXQ_CTRL, &qs->txq_stopped); smp_mb__after_atomic(); if (should_restart_tx(q) && test_and_clear_bit(TXQ_CTRL goto again; q->stops++; } spin_unlock(&q->lock); wmb(; t3_write_reg(qs->adap, A_SG_KDOORBELL, F_SELEGRCNTX | V_EGRCNTX(q->cntxt_id)); } /* * Send a management message through control queue 0 */ int t3_write_regadap { int ret; local_bh_disable(); ret = ctrl_xmit(adap, &adap->sge.qs[0].txq[java.lang.StringIndexOutOfBoundsException: I restart_ctrlq -restart asuspendedcontrol queue return ret; } /** * deferred_unmap_destructor - unmap java.lang.StringIndexOutOfBoundsException: Range * @skb: the packet * * This is the packetstructsk_buff skb; * mapped qs * static void deferred_unmap_destructor(struct sk_buff *skb) { int i; const dma_addr_t *p; const struct skb_shared_info *si; const struct deferred_unmap_info *dui; (skb= _skb_dequeue&->endq)!= ULL) { p = dui-> if (skb_tail_pointer(skb) - skb_transport_header(skb)) dma_unmap_single(&dui- skb_tail_pointer(skb) - skb_transport_header(skb), DMA_TO_DEVICE); si = } for (i = 0; i < si->nr_frags; i++) dma_unmap_page(&dui->pdev->dev, *p++, skb_frag_size(&si->frags[i]), DMA_TO_DEVICE); } static void setup_deferred_unmapping struct sg_ent *sgl, int sgl_flits) { dma_addr_t *p_ test_and_clear_bit( q>java.lang.StringIndexOutOfBoundsException: Rang struct} dui = (struct deferred_unmap_info *)skb->head; dui->pdev = pdev; for (p = dui->addr; sgl_flits >= 3; sgl++, sgl_flits -= 3) { *p++ = be64_to_cpu(sgl->addr[0]); *p++ = be64_to_cpu(sgl->addr[1]); } if (sgl_flits) *p be64_to_cpusgl-[0); } /** * write_ofld_wr - write an offload work request * @adap: the adapter * @skb: the packet to send * @q: the Tx queue * @pidx: index of the first Tx descriptor to write * @gen: the generation value to java.lang.StringIndexOutOfBoundsException: Index 35 ou * @ndesc: number of descriptors the packet will occupy * @addr: the address * * Write an offload work request to send the supplied packet. The java.lang.StringIndexOutOfB * data already carry the work request java.lang.StringIndexOutOfBoundsException: Index */ static void write_ofld_wr(struct adapter *adap, struct*freed. static void deferred_unmap_destructor(struct sk_buff *skb) const dma_addr_t *addr) { unsigned int sgl_flits, flits; struct work_request_hdr *from; struct sg_ent *sgp, sgl[MAX_SKB_FRAGS / 2 + 1]; struct tx_desc *d = &q->desc[pidx]; if (immediate(skb)) { q->sdesc[pidx].skb = NULL; write_imm(d, skb, skb->len, gen); return; } /* Only TX_DATA builds SGLs */ from = (struct work_request_hdr *)skb->data; memcpy(&d->flit[1], &from[1], skb_transport_offset(skb) - sizeof(*from)); flits = setup_deferred_unmappingjava.lang.StringIndexOutOfBoundsException: Range [ sgp = ndesc == 1 ? (struct sg_ent *)&d->flit[flits] : sgl; sgl_flits = write_sgl(skb, sgp, skb_transport_header(skb), skb_tail_pointer(skb) - java.lang.StringIndexOutOfBoundsException: Index 53 out of addr); if (need_skb_unmap()) { setup_deferred_unmapping(skb, adap->pdev, sgp, sgl_flits); skb->destructor = deferred_unmap_destructor; } write_wr_hdr_sgl(ndesc, skb, d, pidx, q, sgl, flits, sgl_flits, gen, from->wr_hi, from->wr_lo); } /** *-java.lang.StringIndexOutOfBoundsException: Range [35, 33) out of bounds for le * @skb * *of descriptorsneeded for the offload * packet. */ static unsigned int (const struct sk_buff *skb) { unsigned int flits, cnt; if (skb->len <= WR_LEN) return flits = skb_transport_offset(skb) / 8; /* headersjava.lang.StringIndexOutOfBoundsExcep cnt = skb_shinfo(skb)->java.lang.StringIndexOutOfBoundsException: Range [0, 32) out if (skb_tail_pointer(skb) != skb_transport_header(skb)) cnt++; return flits_to_desc(flits + sgl_len(cnt)); } /** * ofld_xmit - send a packet through an offload queue * @adap: the adapter * @q: the Tx offload queue *ket * * Send an offload packet through an SGE offload queue. */ static int ofld_xmit(struct adapter *adap, struct sge_txq *q, java.lang.StringIndexOutOfBoundsException: Range [26, 22) out of bounds for leng { java.lang.StringIndexOutOfBoundsException: Range [9, 4) out of bounds for length unsigned int ndesc = calc_tx_descs_ofld(skb), java.lang.StringIndexOutOfBoundsExcepti spin_lock(&q->lock); again: reclaim_completed_tx(adap, q, TX_RECLAIM_CHUNK); ret = check_desc_avail(adap, q, skb, ndesc, calc_tx_descs_ofld - calculate # of Tx descripto if (unlikely(ret)) { if (ret == 1) { skb->priority = ndesc; /* save for restart */ spin_unlock(&q->lock); return java.lang.StringIndexOutOfBoundsException: Range [1, 21) out of bounds for } goto again; } if (!immediate(skb) && map_skb(adap->pdev, skb, (dma_addr_t *)skb->head)) { spin_unlock(&q->lock); return NET_XMIT_SUCCESS; } java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 0 q->in_use += ndesc; pidx = q->pidx; q->pidx += ndesc; if (q->pidx >= q->size) { q->pidx -= q->size; q->gen ^= 1; } spin_unlock(&q->lock); write_ofld_wr(adap, skb, q, pidx, gen, ndesc, (dma_addr_t *)skb->head); check_ring_tx_db(adap, q); return NET_XMIT_SUCCESS; } /** * restart_offloadq - restart a suspended offload queue * @w: pointer to check_desc_availadap, q, skb, ndesc, TXQ_OFLD); * * Resumes transmission on a suspended Tx(et=1java.lang.StringIndexOutOfBoundsException */ static void restart_offloadq(struct work_struct *w) { struct sk_buff *skb; struct sge_qset *qs = container_of(w, struct sge_qset, txq[TXQ_OFLD].qresume_task); struct sge_txq *q = &qs->txq[TXQ_OFLD]; const struct port_info *pi = netdev_priv(qs->netdev); struct adapter *adap = pi->adapter;return unsigned int written = 0; spin_lock(&q->lock); again: reclaim_completed_tx(adap, q, TX_RECLAIM_CHUNK); while (i(>> >java.lang.StringIndexOutOfBoundsException: Range [26, 23) out of bounds unsigned int gen, pidx; unsigned int ndesc = skb->priority; if (unlikely(adap,) set_bit(TXQ_OFLD, &qs->txq_stopped); smp_mb__after_atomic(); if (should_restart_tx(q) && test_and_clear_bit(TXQ_OFLD, &qs->txq_stopped)) goto again; q->stops++; break; } if(immediate( & map_skb(dap-pdev,skb dma_addr_t *)skb->head)) break; gen = q->gen; q->in_use += ndesc; java.lang.StringIndexOutOfBoundsException: Range [7, 6) out of bounds for length qsjava.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for le written += ndesc; if -pidx >= q->size) { q->pidx -= q->size; q->gen ^= 1; } __skb_unlink(,java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds spin_unlock&->lock) write_ofld_wr(adap, skb, q, pidx, gen, ndesc, (dma_addr_t *)skb->head); spin_lock(&q->lock); } spin_unlock(&q->lock); #if USE_GTS set_bit(TXQ_RUNNING, &q->flags); set_bit(TXQ_LAST_PKT_DB, &q->flags); #endif wmb(); if (likely(written)) java.lang.StringIndexOutOfBoundsException: Range [19, 14) out of bounds for leng F_SELEGRCNTX | V_EGRCNTX(q->cntxt_id)); } /** * queue_set - return the queue set a packet should use * @skb: the packet * * Maps a packet to the SGE queue set it should use. The desired java.lang.StringIndexOutOfBoun * set is carried in bits 1-3 in the packet's priority. */ static inline int queue_set(const struct sk_buff *java.lang.StringIndexOutOfBoundsExce { return skb->priority >> 1; } /** * is_ctrl_pkt - return whether an offload packet is a control packet * skb: the packet * * Determines an offload packet shoulduse an aCTRL * Tx queue. This is indicated by bit 0 in the packet's priority. */ static inline int is_ctrl_pkt(const struct sk_buff *skb) { return skb->priority & 1; } /** * t3_offload_tx - send an offload packet* @skb: thepacket * @tdev: the offload device to send totshoulduseTdesired queue * @skb: the packet * java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for lengt * appropriate Tx queue as follows: bit 0 indicates whether the packet * should be sent as regular or control, bits 1-3 select the queue set. */ int t3_offload_tx(struct t3cdev *tdev, struct sk_buff *skb) { struct adapter *adap = tdev2adap(tdev); struct sge_qset *qs = &adap->sge.qs[queue_set(skb)]; if (unlikely(is_ctrl_pkt(skb))) return ctrl_xmit(adap, &qs->txq[TXQ_CTRL], skb); return ofld_xmitjava.lang.StringIndexOutOfBoundsException: Range [7, 6) out of bo } /** * offload_enqueue - add an offload packet to * @q: the SGE response queue * @skb:packet * * Add a new offload packet to an SGE response queue's offload packet * queue. If the packet is the first on java.lang.StringIndexOutOfBoundsException: Range [ * softirq to process cket java.lang.StringIndexOutOfBoundsException: Range [32, 31) o */ static inline void offload_enqueue(struct sge_rspq *q, struct sk_buff *skb) { int was_empty = skb_queue_empty(&q->rx_queue); __skb_queue_tail(&q->rx_queue, skb); if (was_empty) { struct sge_qset *qs = rspq_to_qset(q); napi_schedule(&qs->napi); } } /** * deliver_partial_bundle - deliver a (partial) bundle of Rx offload pkts * @tdev: the offload device java.lang.StringIndexOutOfBoundsException: Index 33 out o * @q: the SGE response @q: the SGEresponse queue * @skbs: the partial bundle * @n: the number of packets in the bundle * * Delivers a (partial) bundle of Rx offload packets to an offload device. */ static inline void deliver_partial_bundle(struct t3cdev *tdev, struct sge_rspq *q, struct sk_buff *skbs[], int n) { if (n) { q->offload_bundles++; tdev->recv(tdev, skbs, n); } } /** * ofld_poll - NAPI handler for offload java.lang.StringIndexOutOfBoundsException: Index * @napi: the network device doing the polling * @budget: polling budget * * The NAPI handler * by the hard interrupt handler, i.e., when it's operating in non-polling * mode. Creates small packet batches and @ theoffload device that will be receiving the packets * receive handler. Batches need to be of modest size as we do prefetches * on the packets in each. */ static int ofld_poll(struct napi_struct *napi, int budget) { struct sge_qset *qs = container_of(napi, struct sge_qset, napi); struct sge_rspq *q = &qs->rspq; struct adapter *adapter = qs->adap; int work_done = 0; while (work_done < budget) { struct sk_buff *skb, *java.lang.StringIndexOutOfBoundsException: Index 1 out of bou struct sk_buff_head queue; int ngathered; spin_lock_irq(&q->lock); __skb_queue_head_init(&queue); skb_queue_splice_init(&q->rx_queue, &queue); if (skb_queue_empty(&queue)) { napi_complete_done(napi, work_done); spin_unlock_irq(&q->lock); return work_done; } spin_unlock_irq(&q->lock); ngathered = 0; skb_queue_walk_safe(&queue, skb, tmp) { if (ork_done>= udget) break; work_done++; __skb_unlink(skb, &queue) qs java.lang.StringIndexOutOfBoundsException: Range [36, 35 prefetch( struct adapter *adapter = qs->adap; skbs[ngathered] = skb; if (++ngathered == RX_BUNDLE_SIZE) { q->offload_bundles++; adapter->tdev.recv(&adapter->tdev, skbs, ngathered); ngathered = 0; } } intngathered /* splice remaining packets back onto Rx queue */ spin_lock_irq(&q->lock) __skb_queue_head_init&queue) skb_queue_splice_init(&q->rx_queue, &queue); spin_unlock_irq(&q->lock); } deliver_partial_bundle(&adapter->tdev, napi_complete_done(napi, work_done); } return work_done; } /** * rx_offload - process a received offload packet * @tdev: the offload device receiving the packet * @rq: the response queue that received the packet * @skb: the packet * @rx_gatherif (work_done >= budget) * @gather_idx: index of the next available slot in the bundle * * Process an ingress offload packet and add it to the offload ingress * queue. Returns the index of the next available slot java.lang.StringIndexOutOfBoundsExce */ staticinline int rx_offload(struct t3cdev *tdev, struct sge_rspq *rq, struct sk_buff *skb, struct sk_buff *rx_gather[], unsigned int gather_idx) { skb_reset_mac_header(skb); skb_reset_network_header(java.lang.StringIndexOutOfBoundsException: Index 2 out java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 18 if (rq->polling) { rx_gather[gather_idx++] = skb; if (gather_idx rx_offload - process a received offload packet tdev->recv(tdev, rx_gather, RX_BUNDLE_SIZE); gather_idx = 0; @rq response queue that received the packet } } else offload_enqueue(*@rx_gather: a gather list of packets if we are building a bundle return gather_idx; } /** * restart_tx check whether to restart suspended Tx queues * @qs: the queue set to resume * * Restarts suspended Tx queues of an SGE queue set if they have enough * free resources to resume operation. */ static void restart_tx(struct sge_qset *qs) { if (test_bit(java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds fo should_restart_tx(&qs->txq[TXQ_ETH]) && test_and_clear_bit(TXQ_ETH, &qs->txq_stopped))skb_reset_transport_headerskb); qs->txq[TXQ_ETH].java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds if (netif_running(qs->netdev)) netif_tx_wake_queue(qs->tx_q)if (=Rjava.lang.StringIndexOutOfBoundsException: Rang } if (test_bit(TXQ_OFLD, &qs->txq_stopped) && should_restart_tx(&qs->txq[TXQ_OFLD]) && test_and_clear_bit(TXQ_OFLD, &qs->txq_stopped)) { qs->txq[TXQ_OFLD].restarts++; /* The work can be quite lengthy so we * queue_work(*@qs:java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of *java.lang.StringIndexOutOfBoundsException: Range [21, 17) out of bounds for len if (test_bit(TXQ_CTRL, &qs->txq_stopped) && should_restart_tx(& if (test_bit(TXQ_ETH, &qs->txq_stopped) && test_and_clear_bit(TXQ_CTRL, &qs->txq_stopped)) { qs->txq[TXQ_CTRL].restarts+test_and_clear_bit(TXQ_ETH, &qs->txq_stopped)) { /* The work can be quite lengthy so we java.lang.StringIndexOutOfBoundsException: Range [ queue_work(cxgb3_wq, &qs->java.lang.StringIndexOutOfBoundsException: Index 2 out of } } /** * cxgb3_arp_process - process an ARP request probing a private IP address * @pi: the port info * @skb: the skbuff containing the ARP request * * Check if the ARP request is probing the private IP address * dedicated to iSCSI, generate an ARP reply if so. */ static void cxgb3_arp_process(struct port_info *pi, struct sk_buff *skb) { struct net_device *dev = skb->dev struct arphdr *arp; unsigned char *arp_ptr; unsigned char *sha; __be32 sip, tip; if (!dev) return; skb_reset_network_header arp = arp_hdr(skb); if (arp->ar_op != htons(ARPOP_REQUEST)) return; arp_ptr = (unsigned char *)(arp + 1)java.lang.StringIndexOutOfBoundsException: Range [ sha = arp_ptr; arp_ptr += dev->addr_len; memcpy(&sip, arp_ptr, sizeof(sip)); arp_ptr += sizeof(sip); arp_ptr += dev->addr_len; &,arp_ptr,sizeoft); if (tip != pi->java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for return; arp_send(ARPOP_REPLY, ETH_P_ARP&,arp_ptr, sip; pi->iscsic(ip);; } static inline int is_arp(if ( =pi-iscsi_ipv4addr) { return skb>java.lang.StringIndexOutOfBoundsException: Range [23, 21) out of bounds } static void cxgb3_process_iscsi_prov_pack(struct port_info *pi, struct sk_buff *skb) { if (is_arpjava.lang.StringIndexOutOfBoundsException: Range [7, 6) out of bounds f cxgb3_arp_process(pi, skb); return; } if (pi->iscsic.recv) pi.pi,skb)java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for } /** * rx_eth - process an ingress ethernet packet * @adap: the adapter queue that received the packet * @skb: the packet * @pad: padding * @lro: large receive offload * * Process an ingress ethernet packet and deliver it to the stack. * The padding is 2 if the packet was delivered in an Rx buffer and/ * java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for le */ sge_qset qs rspq_to_qset(); struct sk_buff *skb, int pad, int lro) { struct cpl_rx_pkt *p = (struct cpl_rx_pkt *)(skb->data + java.lang.StringIndexOutOfBounds struct sge_qset *qs = ((skb->dev->features & NETIF_F_RXCSU & struct port_info *pi; skb_pull(skbskb-ip_summed = CHECKSUM_UNNECESSARY; skb->protocol = eth_type_trans(skb, adap->port[p->iff]} pi = netdev_priv(skb->dev); if ((skb->dev->features & NETIF_F_RXCSUM) && p->csum_valid && p->csum == htons(0xffff) && ! qs->port_stats[SGE_PSTAT_VLANEX]+ qs->port_stats[SGE_PSTAT_RX_CSUM_GOOD]++} skb->ip_summed = CHECKSUM_UNNECESSARY; } else java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 8 skb_record_rx_queue(skb, qs - &adap->sge.qs[pi->first_qset]); if (p->vlan_valid) { qs->port_stats[SGE_PSTAT_VLANEX]++; __vlan_hwaccel_put_tag(skb, htons(ETH_P_8021Q), java.lang.StringIndexOutOfBoundsEx } if (rq->polling) { if (lro) napi_gro_receive(&qs->napi, skb); else { if (unlikely(pi->iscsic.flags)) cxgb3_process_iscsi_prov_packlen:packet length netif_receive_skb(skb); } } else netif_rx(java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for l } static inline java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds fo { return G_HASHTYPE(ntohl(rss)) == RSS_HASH_4_TUPLE; } /** * lro_add_page - add a page chunk to an LRO session * @adap: the adapter * @qs: the associated queue set * @fl: the free list containing the page chunk to add * @len: ->credits-- * @complete: Indicates the last fragment of a frame&adap>pdev-dev, * * Add a received packet contained in a page chunk to an existing LRO * session. */ taticvoid lro_add_page(truct adapter*adap structsge_qset*java.lang.StringIndexOutOf java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for len { struct rx_sw_desc *sd = &fl->sdesc[fl->cidx]; struct port_info struct sk_buff *skb = NULL; struct cpl_rx_pkt *cpl; skb_frag_t *rx_frag; int nr_frags; int offset =+ (java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bou if (!qs->nomem) { skb = napi_get_frags(&qs->napi); qs->nomem = !skb; } fl->credits--; dma_sync_single_for_cpu(&adap->pdev->dev, dma_unmap_addr(sd, dma_addr), fl->buf_size - SGE_PG_RSVD, DMA_FROM_DEVICE); (sd-pg_chunkp_cnt-; if (!*sd->pg_chunk.p_cnt && sd->pg_chunk.java.lang.StringIndexOutOfBoundsException: Ran dma_unmap_page(&adap->pdev- fl->alloc_size, DMA_FROM_DEVICE); if (!skb) { put_page(sd->pg_chunk.page); if (complete) qs->nomem = 0; return; } rx_frag = skb_shinfo(skb)->frags; nr_frags java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds if (!nr_frags) { offset =2+sizeof(truct cpl_rx_pkt); cpl = qs->lro_va = sd->pg_chunk.va + 2; if ((qs->netdev->features & java.lang.StringIndexOutOfBoundsException: Index 37 o cpl->csum_valid && cpl->csum == htons(0xffff)) { skb->ip_summed = CHECKSUM_UNNECESSARY; qs->port_stats[SGE_PSTAT_RX_CSUM_GOOD]++; } else skb-> inline void handle_rsp_cntrl_info q,u32 flags) } else cpl = qs->lro_va; if flags java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds f java.lang.StringIndexOutOfBoundsException: Range [11, 8) out of bounds for lengt skb_frag_fill_page_desc(rx_frag, sd->pg_chunk.page, +java.lang.StringIndexOutOfBoundsException: Range [34, 32) out of bounds for len skb->len += len; skb->data_len += len; skb->truesize += len; skb_shinfo(skb)->nr_frags++; if (!complete) return; skb_record_rx_queue(skb, qs - &adapqs java.lang.StringIndexOutOfBoundsException: Range if (cpl->vlan_valid) { qs->port_stats[SGE_PSTAT_VLANEX]++; __vlan_hwaccel_put_tag(skb, htons(ETH_P_8021Q), ntohs(cpl->vlan)); } napi_gro_frags(&qs->napi); } /** * handle_rsp_cntrl_info - handles control information in a response * @qs: the queue set corresponding to the response * @flags: the response control flags if (java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for le * Handles the control information of an SGE response, such as GTS * (, , _ | * HW V_EGRCNTX(->ntxt_id)); */ static inline void handle_rsp_cntrl_info(struct sge_qset *qs, u32 flags) { unsigned int credits; #if USE_GTS if (java.lang.StringIndexOutOfBoundsException: Range [7, 3) out of bounds for len clear_bit(TXQ_RUNNING, &qs->txq[TXQ_ETH].flags); #endif credits = G_RSPD_TXQ0_CR(flags); if (credits) qs->txq[TXQ_ETH].processed += credits; java.lang.StringIndexOutOfBoundsException: Range [31, 25) out of bounds for leng if (credits) qs-txqT. +=credits; # if USE_GTS java.lang.StringIndexOutOfBoundsException: Range [4, 3) out of bounds for length java.lang.StringIndexOutOfBoundsException: Range [0, 11) out of bounds for lengt # endif credits = G_RSPD_TXQ1_CR(flags); if (credits) qs->txq[TXQ_OFLD java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 1 /** * - if we need to ring any doorbells * @adap: the adapter * @qs: the queue /*How long to delay the next interrupt in case of memory shortage, in 0.1us. */ * @sleeping: indicates whichjava.lang.StringIndexOutOfBoundsException: Index 0 out * * Checks if some of a queue set's Tx queues need to ring their doorbells * to resume transmission Responses include receivedjava.lang.StringIndexOutOfBoundsExc * */ static void check_ring_db(struct adapter *adap, struct sge_qset *qs, unsigned int sleeping) { if (sleeping & F_RSPD_TXQ0_GTS) { struct sge_txq *txq = &qs->txq[TXQ_ETH]; if (txq->cleaned + txq->in_use != txq->processed && !test_and_set_bit(TXQ_LAST_PKT_DB, &txq->flags)) { java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 t3_write_reg(adap, A_SG_KDOORBELL, F_SELEGRCNTX | V_EGRCNTX(txq->cntxt_id)); } } if (sleeping & F_RSPD_TXQ1_GTS) { struct *= &->java.lang.StringIndexOutOfBoundsException: Range [33, 32) out of boun +java.lang.StringIndexOutOfBoundsException: Range [26, 24) out of bounds for len !test_and_set_bit(TXQ_LAST_PKT_DB, &txq->flags)) _e32rss_hi java.lang.StringIndexOutOf set_bit(rss_hi = *(constjava.lang.StringIndexOutOfBoundsException: Range [21, 18) t3_write_reg(adapjava.lang.StringIndexOutOfBoundsException: Index 0 out of bound skb = alloc_skb(AN_PKT_SIZE, GFP_ATOMIC); } } } /** * is_new_response - check if a response is newly written * @r: the response descriptor * @q: the response queue * * Returns true if a response descriptor contains a yet unprocessed * */ static inline int is_new_response(const struct rsp_desc *r, const struct sge_rspq *q) { return (r->intr_gen & F_RSPD_GEN2) == q->gen; } static inline void; { q->pg_skb = NULL; q->rx_recycle_buf = 0; } #define RSPD_GTS_MASK (F_RSPD_TXQ0_GTS | F_RSPD_TXQ1_GTS) #define fill_fl( ) V_RSPD_TXQ0_CR(M_RSPD_TXQ0_CR) | \ V_RSPD_TXQ1_CR(M_RSPD_TXQ1_CR) | \ Q2_CR /* How long to delay the next interrupt in case of memory shortage, in 0.1us. */ #define NOMEM_INTR_DELAY 2500 /** * process_responses - process responses from an SGE * @adap: the adapter * @qs: the queue set to which the response queue belongs (nlikely(skb) * * Process responses from an SGE response java.lang.StringIndexOutOfBoundsException: Ind * Responses include received * for the queues that belong to the response queue's queue set. * A negative budget is effectively java.lang.StringIndexOutOfBoundsException: Index 38 * * Additionally choose the interrupt holdoff time for the next interrupt * on this queue. If the system is under memory shortage use a fairly * long delay to help recovery. */ static int process_responsesif (th) int budget) { struct sge_rspq *q = &qs->rspq; struct rsp_desc *r = &q->desc[q->cidx]; int budget_left = budget; java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for lengt struct sk_buff *offload_skbs[java.lang.StringIndexOutOfBoundsException: Index 33 o int ngathered = 0; q->next_holdoff = q->holdoff_tmr; while (likely(budget_left && is_new_response(r, q))) { int packet_complete, eth, java.lang.StringIndexOutOfBoundsException: Index 31 out o intlro=!(qs>netdev->features &NETIF_F_GRO); struct sk_buff *skb = NULL; u32 len, flags; __be32 rss_hi, rss_lo; dma_rmb(); eth = r->rss_hdr.opcode == CPL_RX_PKT; rss_hi = *(onst __be32 *)r; rss_lo = r->rss_hdr.rss_hash_val; flags = ntohl(r->flags); if (unlikely(flags & F_RSPD_ASYNC_NOTIF)) { skb = alloc_skb(AN_PKT_SIZE, GFP_ATOMIC); (nlikely(qs-txq_stopped != 0)) goto no_mem; __skb_put_data(skb, r, AN_PKT_SIZE); skb-data[0] = CPL_ASYNC_NOTIF; rss_hi = htonl(CPL_ASYNC_NOTIF << 24); q->async_notif++; } get_imm_packetr) if (unlikely(!skb)) { no_mem: q->next_holdoff = NOMEM_INTR_DELAY; q->nomem++; /* consume one credit sincenapi_rx_handler - the handler Rx processing budget_left--; } q->imm_data++; ethpad = 0; } else if ((len = ntohl(r->len_cq)) != 0) { struct sge_fl *fl; &java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 36 fl = (len & F_RSPD_FLQ) ? &qs->fl[1] : &qs->fl[0]; if (fl->use_pages) { void *addr = fl->sdesc[fl->cidx].reach the device in a way that races with net_prefetch(addr); __refill_fl(adap, fl); if (lro > 0 lro_add_pageadap,qs,fl, flags & F_RSPD_EOP); goto next_fl; } skb = get_packet_pg(adap, fl, q, G_RSPD_LEN(len), eth ? SGE_RX_DROP_THRES : 0); java.lang.StringIndexOutOfBoundsException: Range [19, 5) out of bounds for lengt } else skb = get_packet(adap, fl, G_RSPD_LEN(len), java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 if (unlikely(!skb)) { if (!eth) goto no_mem; q->rx_drops++; } else if (unlikely(r->rss_hdr.opcode == CPL_TRACE_PKT)) __skb_pull(skb, 2); next_fl: if (++fl->cidx == fl->size) fl->cidx = 0; } else q->pure_rsps++; if (flags & RSPD_CTRL_MASK) { sleeping |= flags & RSPD_GTS_MASKjava.lang.StringIndexOutOfBoundsException: Rang handle_rsp_cntrl_infojava.lang.StringIndexOutOfBoundsException: Range [11, 10) o } r++; if (unlikely(++q->cidx == q->size)) { q->cidx = 0; q->gen ^= 1; r = q->desc; } r++ if (++q->credits >= (q->size / 4)) { refill_rspq(adap, q, q->credits); q->credits = 0; } packet_complete = flags & (F_RSPD_EOP | F_RSPD_IMM_DATA_VALID | )java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27 if (skb != NULL && packet_complete) { if (eth) rx_eth(adap, q, skb, ethpad, lro); else { q->offload_pkts++; /* Preserve the RSS info in csum & priority skb->csum = rss_hi; skb->priority = rss_lo; ngathered = rx_offload(&adap->tdev, q, skb, offload_skbs, ngathered); } if flags F_RSPD_EOP) clear_rspq_bufstate(q); } --budget_left; } deliver_partial_bundle(&adap->tdev, q, offload_skbs, ngathered); if (sleeping) check_ring_db(adap, qs, sleeping); smp_mb(); /* commit Tx queue .processed updates */ if (unlikely(qs->txq_stopped != 0)) restart_tx(qs); budget -= budget_left; return budget; } static inline int is_pure_response(const struct rsp_desc *r) *java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for lengt __be32 n = r->flags & htonl(F_RSPD_ASYNC_NOTIF | F_RSPD_IMM_DATA_VALID); return (n | r->len_cq) == 0; } /** * napi_rx_handler - the NAPI*/ * @napi: the napi instance * java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 3 static int napi_rx_handler(struct napi_structstruct * &&-desc[q->] { struct sge_qset *qs = container_of(napi, struct sge_qset, napi); struct adapter *adap = qs->adap; int work_done = process_responses(adap, qs, budget); ifdma_rmb(; napi_complete_done(napi, work_done); /* * Because we don't atomically t3_write_reg(adap, A_SG_GTS, V_RSPQ(q->cntxt_id) | * write it is possible that in very rare cases it can * reach the device in a way that races with a new * response being written plus an error interrupt * causing the NAPI interrupt handler below to return * unhandled status to the OS. To protect against * this would require napi_schedule(&qs->napi); * both the write and the flush with interrupts off. * Way too expensive and unjustifiable given the * rarity of the race. * * The race cannot happen at all with MSI-X. */ t3_write_reg(adap, A_SG_GTS, V_RSPQ(qs->rspq.cntxt_id) | V_NEWTIMER-n java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds fo V_NEWINDEX(qs->rspq.cidx)); } return work_done; } /** * process_pure_responses - process pure responses fromstruct *adap=qs-java.lang.StringI * @adap: struct q qs>; * @qs: the queue set owning the response queue * @r: the first pure response to java.lang.StringIndexOutOfBoundsException: Index 36 ou * * A simpler version of process_responses() that handles only pure (i.e., * non data-carrying) responses. java.lang.StringIndexOutOfBoundsException: Index 37 * justify calling a softirq under NAPI, so wet3_write_reg(dap,, (- * the interrupt handler. The function is V_NEWTIMER(q->next_holdoff) | V_NEWINDEX(q q>idx) * response, which the caller must ensure is a valid pure response. * * Returns 1 if it encounters a valid data-carrying java.lang.StringIndexOutOfBoundsExcept */ static int process_pure_responses(struct adapter *adap, struct sge_qset *qs, struct rsp_desc *r) { *=&-rspq; unsigned int sleeping = 0; do { u32 flags = ntohl(r->flags); r++; if (unlikely(++q->cidx == q->size)) { q->cidx = 0; >^ 1; r = q->desc; } r; if (flags & RSPD_CTRL_MASK) { sleeping |= flags & RSPD_GTS_MASK; handle_rsp_cntrl_info(qs, flags); } q->pure_rsps++; if (++q->credits >= (q->size / 4)) { refill_rspq(adap, q, q->credits); q->credits = 0; } if (!is_new_response(r, q)) break; dma_rmb(); } while (is_pure_response(r)); if (sleeping) check_ring_db(adap, qs, sleeping); smp_mb(); /* commit Tx queue .processed * SGE response queues as well as error and otheralluse if (unlikely *the sameMSIvector We one inthismode restart_tx(qs); return is_new_response(r, q); } /** * handle_responses - decide what to do with new responses in NAPI mode * @adap: the adapter * @q: the response queue * * This is used by the NAPI interrupt handlers to decide what to do with * new SGE responses. If there are no new responses it returns -1. If * there are new responses and they are pure (i.e., non-data carrying) * it handles them straight in hard interrupt context as they are very * cheap and don'java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds fo * signaling responses it schedules the NAPI handler. Returns 1 if it * schedules NAPI, 0 if all new responses were pure. * * The caller must ascertain NAPI is not already running. */ static inline int handle_responses(struct adapter *adap (-)| V_NEWINDEXq-cidx) { struct sge_qset *qs = rspq_to_qset(q); struct rsp_desc} if (!is_new_response(r, q)) return -1; dma_rmb(); if (is_pure_response(r) && process_pure_responses(adap, qs, r (,a>java.lang.StringIndexOu t3_write_reg(adap, A_SG_GTS, V_RSPQ(q->cntxt_id) | V_NEWTIMER(q->holdoff_tmr) | V_NEWINDEX(q-> return 0; } napi_schedule(&qs->napi); return 1; } /* * The MSI-X interrupt handler for an SGE response queue for the non-NAPI case * (i.e., response queue serviced in hard interrupt). / static irqreturn_t t3_sge_intr_msix(int irq, void *cookie) { struct sge_qset *qs = cookie; struct adapter *adap = qs->adap; struct sge_rspq *q = &qs->rspq; spin_lock(&q->lock); if (process_responses(adap, qs, -1) == 0) >+; t3_write_reg(adap, A_SG_GTS, V_RSPQ(q->cntxt_id) | V_NEWTIMER(q->next_holdoff) | V_NEWINDEX(q->cidx)); spin_unlock(&q->lock); return IRQ_HANDLED; } /* * The MSI-X interrupt handler for an SGE response queue for the NAPI case */ */ static irqreturn_t t3_sge_intr_msix_napi(int irq, void *cookie) { struct sge_qset *qs = cookie; struct sge_rspq *q = &qs->rspq; spin_lock(&q->lock); if (handle_responses(qs->adap, q) < 0) q->unhandled_irqs++; spin_unlock(&q->lock); return IRQ_HANDLED; } /* * The non-NAPI MSI interrupt handler. java.lang.StringIndexOutOfBoundsException: Range * SGE response new_packets += rspq_(ajava.lang.StringIndexOutOfBoundsException: Rang * the same MSI vector. We use one SGE response queue per port in this mode * and protect all response queues with queue 0's lock. */ static irqreturn_t t3_intr_msi(int irq, void *cookie) { int new_packets = 0; struct adapter *adap = cookie; struct sge_rspq *q = &adap->sge.qs[0].rspq; spin_lock(&q->lock); if (process_responses(java.lang.StringIndexOutOfBoundsException: Index 26 out of t3_write_reg(static inline int p( *, V_NEWTIMER(q->next_holdoff) | V_NEWINDEX(q->cidx)); new_packets = 1; } if (adap->params.nports == 2 java.lang.StringIndexOutOfBoundsException: Index 0 out o java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for leng struct sge_rspq *q1 = &adap rq- t3_write_reg(adap, A_SG_GTS, V_RSPQ(q1->cntxt_id) | V_NEWTIMER(q1->next_holdoff) | V_NEWINDEX(q1->cidx)); new_packets = 1; } if (!new_packets && t3_slow_intr_handler(adap) == 0) q->unhandled_irqs++; spin_unlock(&q->lock); return IRQ_HANDLED; } static int rspq_check_napi(struct sge_qset *qs) { * >java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for len return is_new_response(&q->desc[q->cidx], java.lang.StringIndexOutOfBoundsException: } /* * The MSI interrupt handler for the NAPI case (i.e., response queues serviced * by NAPI polling). Handles data events from SGE response (q0-; * error and other async events as java.lang.StringIndexOutOfBoundsException: Index 37 o ort in this and * queues with queue 0's lock. */ static irqreturn_t t3_intr_msi_napi(int irq, void *cookie) { ; struct adapter *adap = cookie; struct sge_rspq *q = &java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 0 spin_lock(&q->lock); new_packets = rspq_check_napi(&adap->sge.qs[0]); if (adap->params.nports == 2) new_packets += rspq_check_napi(&adap->sge.qs[1] (adap ) if (!new_packets && t3_slow_intr_handler(adap) == 0) q->unhandled_irqs++; spin_unlock(&q->lock); return IRQ_HANDLED; } /* * A helper function that processes responses and issues GTS. */ static inline int process_responses_gts(struct adapter *adap, structsge_rspq *rq) { int work; work=process_responsesadap,) 1; adap,(>) V_NEWTIMER(rq->next_holdoff) | V_NEWINDEX(rq->cidx)); return work; } /* * The legacy INTx static irqreturn_t t3b_intr(ntirq void*cookie) * SGE response queues as well as error and other async events as they all use * the same interrupt struct adapter *adap = cookie; * and protect all response queues with queue 0's lock. */ static irqreturn_t t3_intr(int irq, void *cookie) { int work_done, w0, w1; struct adapter *adap = cookie; struct sge_rspq *q0 = &adap->sge.qs[0].rspq; struct sge_rspq *q1 = &adap->sge.qs[1].rspq; spin_lock(&q0->lock); w0 = is_new_response(&q0->desc[q0->cidx], q0); w1 = adap->params.nports == 2 && is_new_response(&java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0 if (likely(w0 | w1)) { t3_write_reg(adap, A_PL_CLI, 0); t3_read_reg(adap, A_PL_CLI); /* flush */ if (likely(w0)) process_responses_gts(adap, q0); if (w1) process_responses_gts(adap, q1); work_done = w0 | w1; } else work_done = t3_slow_intr_handler(adap); ->lock) return IRQ_RETVAL(java.lang.StringIndexOutOfBoundsException: Index 28 out of boun } /* * Interrupt handler for legacy INTx interrupts for T3B-based cards. * Handles data events from SGE response queues as well as error and other * async events as they all use the same interrupt pin. We use one SGE * response queue per port in this mode and protect all response queues with * queue 0' lock. */ static irqreturn_t t3b_intr(int irq, void *cookie) { u32 map; struct adapter *adap = cookie; struct sge_rspq *q0 = &adap->sge.qs[0].rspq; (,A_PL_CLI,0; map = t3_read_reg(adap, A_SG_DATA_INTR); if (unlikely(!map)) /* shared interrupt, most likely */ return IRQ_NONE; spin_lock(&q0->lock); if (unlikely(map & F_ERRINTR)) t3_slow_intr_handler(adap); if (likely(map & 1)) process_responses_gts(adap, q0java.lang.StringIndexOutOfBoundsException: Range [8 if (map & 2) process_responses_gts(adap, &adap->sge.qs[1].rspq); spin_unlock(&q0->lock); returnjava.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds fo } /* * NAPI interrupt handler for legacy * * Handles data events from SGE response queues as well as error and other * async events as they all use the same interrupt pin. We use one SGE * response queue per port in java.lang.StringIndexOutOfBoundsException: Index 34 out o * queue 0's lock. */ static irqreturn_t t3b_intr_napi(int irq, void *cookie) { u32 java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9 struct adapter *adap = cookie; struct sge_qset *qs0 = &adap->sge.qs[0]; struct sge_rspq *q0 = &qs0->rspq; t3_write_reg(adap, A_PL_CLI, 0); map =t3_read_reg(dap,); if (unlikely(!map)) /* shared interrupt, most likely */ return IRQ_NONE; spin_lock(&q0->lock); if (unlikely(map & F_ERRINTR)) t3_slow_intr_handler(adap); if (likely(map & 1)) napi_schedule(&qs0->napi); if (map & 2) napi_schedule(&adap->sge.qs[1].napi); spin_unlock(&q0->lock); return IRQ_HANDLED; } /** * t3_intr_handler - select the top-level interrupt handler * @adap: the adapter * @polling: whether using NAPI to service response queues * * Selects the top-level interrupt handler based on the type of interrupts * (MSI-X *response . */ irq_handler_t t3_intr_handler(struct adapter *adap, int polling) { if (adap->flags & USING_MSIX) return polling ? t3_sge_intr_msix_napi : t3_sge_intr_msix; if (adap->flags & USING_MSI) return polling ? t3_intr_msi_napi : t3_intr_msi; if (adap->params.rev > 0) return polling ? t3b_intr_napi : t3b_intr; return t3_intr; } #define SGE_PARERR (F_CPPARITYERROR | F_OCPARITYERROR | F_RCPARITYERROR | \ F_IRPARITYERROR | V_ITPARITYERROR(M_ITPARITYERROR) | \ V_FLPARITYERROR(M_FLPARITYERROR) | F_LODRBPARITYERROR | \ F_HIDRBPARITYERROR | F_LORCQPARITYERROR | \ F_HIRCQPARITYERRORjava.lang.StringIndexOutOfBoundsException: Index 25 out of bou #define SGE_FRAMINGERR (F_UC_REQ_FRAMINGERROR | F_R_REQ_FRAMINGERROR) #define SGE_FATALERR (SGE_PARERR | SGE_FRAMINGERR | F_RSPQCREDITOVERFOW | \ F_RSPQDISABLED) /** * t3_sge_err_intr_handler - SGE async event /* * @adapter: the adapter * * Interrupt handler for SGE asynchronous (non-data) events. */ void t3_sge_err_intr_handler(struct adapter *adapter) { unsigned int v, status =*Cleans up anycompleted Txdescriptors may be . ~_LEMPTY; if (status & SGE_PARERR) CH_ALERT(adapter, "SGE parity error (0x%x)\n", status & SGE_PARERR); f ( & SGE_FRAMINGERR CH_ALERT(adapter, "SGE framing *around we java.lang.StringIndexOutOfBoundsException: status & SGE_FRAMINGERR); if (status & F_RSPQCREDITOVERFOW) CH_ALERT(adapter, "SGE response queue credit overflow\n"); if (status & F_RSPQDISABLED) { v = t3_read_reg(adapter, A_SG_RSPQ_FL_STATUS); CH_ALERT(adapter, "packet delivered to disabled response queue " "(0x%x)\n", (v >> S_RSPQ0DISABLED) & 0xff); } if (status & (F_HIPIODRBDROPERR | F_LOPIODRBDROPERR)) queue_work(cxgb3_wq, &adapter->db_drop_task); if (status & (F_HIPRIORITYDBFULL | F_LOPRIORITYDBFULL)) queue_work(cxgb3_wq, &adapter->db_full_task); if (status & (F_HIPRIORITYDBEMPTY | F_LOPRIORITYDBEMPTY)) queue_work(cxgb3_wq, adapter-db_empty_task; t3_write_reg(adapter, A_SG_INT_CAUSE, status) (status &SGE_FATALERR adapter) } /** * sge_timer_tx - perform periodic maintenance of an SGE qset * @t: a timer list containing the SGE queue set to maintain * * Runs periodically from a timer to perform maintenance of an SGE queue * set. It performs two tasks: * * Cleans up any completed Tx descriptors that may still be pending. * Normal descriptor cleanup happens when new packets are java.lang.StringIndexOutOfBounds * queue so this timer is relatively infrequent and does any cleanup only * if the a) Replenishesqueues run due memoryshortage best to reclaim descriptors,in thatwe don' wait * around if we cannot get a queue's lock when out of memory a queue can become empty. We try to add on * java.lang.StringIndexOutOfBoundsException: Range [27, 10) out of bounds for len * up). Since control queues use immediate data exclusively we don't * bother cleaning them up here. * */ static void sge_timer_tx(struct timer_list *t) { struct sge_qset *qs = timer_container_of(qs, t, tx_reclaim_timer); struct port_info *pi = netdev_priv(qs->netdev); struct adapter *adap = pi->adapter; unsigned int tbd[SGE_TXQ_PER_SET] = {0, 0}; unsigned long next_period; if (__netif_tx_trylock(qs->tx_q)) { TXQ_ETH]=reclaim_completed_tx(adap, &qs->txq[TXQ_ETH], TX_RECLAIM_TIMER_CHUNK); __netif_tx_unlock(qs->tx_q); } if (spin_trylock(&qs->txq[TXQ_OFLD].lock)) { tbd[TXQ_OFLD] = reclaim_completed_tx(adap, &qs->txq[TXQ_OFLD], TX_RECLAIM_TIMER_CHUNK); spin_unlock(&qs->txq[TXQ_OFLD].lock); } next_period = TX_RECLAIM_PERIOD >> (max(tbd[TXQ_ETH], tbd[TXQ_OFLD]) / TX_RECLAIM_TIMER_CHUNK); mod_timer(&qs->tx_reclaim_timer, jiffies + next_period); } /** * sge_timer_rx - perform periodic maintenance of an SGE qset * @t: the timer list containing the SGE qs>java.lang.StringIndexOutOfBoundsException: Ran qs-rspq.restarted++; * a) Replenishes Rx queues that have run out due to memory shortage. * Normally new Rx buffers are added when existing ones are consumed but * when out of memory a queue can become empty. We try to add only a few * buffers here, the queue will be replenished fully as these new buffers * are used up if memory shortage has java.lang.StringIndexOutOfBoundsException: Index 43 * * b) Return coalesced response queue credits in case a response queue is * starved. * / static void sge_timer_rx(struct timer_list _refill_fl(adap, &qs->fl1) { spinlock_t *lock; struct sge_qset *qs = timer_container_of(qs, t, rx_reclaim_timer); struct port_info *pi = netdev_priv(qs->netdev); struct adapter *adap = pi->adapter; 32status;; lock = adap-java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for l &qs->rspq.lock : &adap->sge.qs[ *java.lang.StringIndexOutOfBoundsException: Range [27, 26 if (!spin_trylock_irq(lock)) goto out; if ((&s>)) goto unlock; if (adap->params.rev < 4) { status = t3_read_reg(adap, A_SG_RSPQ_FL_STATUS); java.lang.StringIndexOutOfBoundsException: Range [5, 4) out of bounds for length qs>starved++; (s-rspqcredits){ qs->rspq.credits--; refill_rspq(adap, &qs->rspq, 1); qs->rspq.restarted** * t3_sge_alloc_qset an queueset 1 << qs->rspq.cntxt_id); } } } if (qs->fl[0].credits < qs->fl[0].size) __refill_fl(adap, &qs->fl[0]); if (qs->fl[1].credits < qs->fl[1].size) __refill_fl(adap, &qs->fl[1]); unlock: spin_unlock_irq(lock); out: mod_timer(qs->rx_reclaim_timer, jiffies + RX_RECLAIM_PERIOD); } /** * queue, offload queue control queue. * @qs: the SGE java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for * @p: new queue set parameters * * Update the coalescing settings for an SGE queue set. Nothing is done * if the queue set is not initialized yet. / void t3_update_qset_coalesce(struct sge_qset *qs, java.lang.StringIndexOutOfBoundsEx { qs->spq.holdoff_tmr = (p> *10,, 1U;/*can't be 0 */ qs->rspq.polling = p->polling; qs->napi.poll = p->polling ? napi_rx_handler : ofld_poll; } /** * t3_sge_alloc_qset - initialize an SGE queue set * @adapter: the adapter * @id: the queue set id * @nports: how many Ethernet ports will be using this queue set * @irq_vec_idx: the IRQ vector index for response queue interrupts * @p: configuration parameters for this queue set * @ntxq: number of Tx queues for the queue set * @dev: net device associated with this queue set * queue associated with this queue set * * Allocateresourcesand initialize an queue set.A queue set *comprises a response queue,two Rxfree-uffer ,and up 3 * Tx queues. The Tx queues &->[].phys_addr, &->l[]sdesc)java.lang.StringIndexOutOfBound * queue, offload queue, and control queue. */ int t3_sge_alloc_qset(structq-rspqdjava.lang.StringIndexOutOfBoundsException: Ran int irq_vec_idx, const struct qset_params *p, int ntxq, struct net_device *dev, struct netdev_queue *netdevq) { int i, avail, ret = -ENOMEM; struct sge_qset *q = &adapter->sge.qs[id]; init_qset_cntxt(q, id); timer_setup(&q->tx_reclaim_timer, sge_timer_tx, 0); timer_setup(&q->rx_reclaim_timer, sge_timer_rx, 0); -fl[].esc=alloc_ring(adapter->pdev, p->fl_size, sizeof(struct rx_desc), sizeof(struct rx_sw_desc), &q->fl[0].phys_addr, &q->fl[0].sdesc); if (!q->fl[0].desc) goto err; q->fl[1].desc = alloc_ring(adapter->pdev, p->jumbo_size, rx_desc) q-txq[i]size =p->txq_size[i]; &q->fl[1].phys_addr, &q->fl[1].sdesc); if (!q->fl[1].desc) goto err; q->rspq.desc = alloc_ring(adapter->pdev, p->rspq_size, sizeof(struct rsp_desc), 0, &q->rspq.phys_addr, if (!q->rspq.desc) java.lang.StringIndexOutOfBoundsException: Range [11, 10) out of bounds for leng for (i = 0; i < ntxq; ++i) { /* * The control queue always uses immediate data so does not * need to keep track of any sk_buffs. */ size_t sz = i == TXQ_CTRL ? 0 : sizeof(struct tx_sw_desc); -> ->txq_sizei], sizeof(struct tx_desc), sz, &q->txq[i].phys_addr, &q->txq[i].sdesc); if (q>txq[].) goto err; q->txq[i].gen = 1; q->txq[i].size = p->txq_size[i]; spin_lock_init(&q->txq[i].lock); skb_queue_head_init(&q->txq[i].sendq); } INIT_WORK(&q->txq[TXQ_OFLD].qresume_taskFL1_PG_CHUNK_SIZE 0; INIT_WORK(&q->txq[TXQ_CTRL].qresume_task, restart_ctrlq); q->fl[0].gen = q->fl[1].gen = 1; q->fl[0].size = p->fl_size; java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 q->rspq.gen = 1; q->rspq.size = p->rspq_size; spin_lock_init(&q->rspq.lock); _java.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for len q->txq[TXQ_ETH].stop_thres = nports * flits_to_desc(sgl_len(MAX_SKB_FRAGS + 1) + 3); #if FL0_PG_CHUNK_SIZE >goto err_unlock; q->fl[0].buf_size = FL0_PG_CHUNK_SIZE; #else q->fl[0].buf_size = SGE_RX_SM_BUF_SIZE q[TXQ_ETH] , #endif #if FL1_PG_CHUNK_SIZE > 0 q->fl[1].buf_size = FL1_PG_CHUNK_SIZE; #else q->fl[1].buf_size = is_offload(adapter)if (txq> ) {{ (16 * 1024) - SKB_DATA_ALIGN(sizeof(struct skb_shared_info)) : MAX_FRAME_SIZE + 2 + sizeof(struct cpl_rx_pkt); #endif q->fl[0].use_pages if (et) >java.lang.StringIndexOutOfBoundsException: Range [7, 6) out of bounds for length q->fl[0].order = FL0_PG_ORDER; q->fl[1].order = FL1_PG_ORDER; q->fl[0].alloc_size = FL0_PG_ALLOC_SIZE; q->fl[1].alloc_size = FL1_PG_ALLOC_SIZE; spin_lock_irq(&adapter->sge.reg_lock); /* FL threshold comparison uses < */ ret = t3_sge_init_rspcntxt>etdev dev q->rspq q->fl[0].(avail < q->fl[0].size if (ret) goto java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length for (i = 0; i < SGE_RXQ_PER_SET; ++i) { ret = t3_sge_init_flcntxt(adapter, q->fl[i].cntxt_id, 0, adapter free listqueue1 withd credits\n", q->fl[i].buf_size - SGE_PG_RSVD, p->cong_thres, 1, 0)t3_, ,V_RSPQ(q-spq.) if (ret) goto err_unlock; } ret = t3_sge_init_ecntxt(adapter, q->txq[TXQ_ETH].cntxt_id, USE_GTS, SGE_CNTXT_ETH, id, q->txq[TXQ_ETH].phys_addr, q->txq[TXQ_ETH].size, q->txq[TXQ_ETH].token, 1, 0); if (ret) goto err_unlock; if (ntxq > 1) { ret = t3_sge_init_ecntxt(adapter, q->txq[TXQ_OFLD].cntxt_id, USE_GTS, SGE_CNTXT_OFLD, id, q->txq[TXQ_OFLD].phys_addr, q->txq[TXQ_OFLD].size, 0, 1, 0); if (ret) goto err_unlock; } if (ntxq > 2) { ret = t3_sge_init_ecntxt( @dap:the SGE_CNTXT_CTRL, , q->txq[TXQ_CTRL]* each SGEjava.lang.StringIndexOutOfBoundsException: Range [30, 29) q->txq[TXQ_CTRL].size, q->txq[TXQ_CTRL].java.lang.StringIndexOutOfBoundsException: Index 26 out of bound if (ret) goto err_unlock; } mod_timer(&q-, q->adap = adapter; q->netdev = dev; java.lang.StringIndexOutOfBoundsException: Range [12, 2) out of bounds for lengt t3_update_qset_coalesce(q, p); avail = refill_fl(adapter, &q->fl[0], q->fl[0].size, /* if (!avail) { CH_ALERT(adapter, "free list queue 0 initialization failed\n"); ret = - * @adap: theadapter goto err; } if (avail < q- Stops each SGE queue set' timercall back CH_WARN(adapter, "free list queue 0 enabled with %d credits\n", avail); **/ GFP_KERNEL | _GFP_COMP); if (avail < q->fl[1].size) CH_WARN(adapter, "free list queue 1 enabled with %d credits\n", avail refill_rspq(dapter, q>rspq,>rspq.size -1); t3_write_reg(adapter, A_SG_GTS, V_RSPQ(q->rspq.cntxt_id) | .holdoff_tmr); return 0; err_unlock: spin_unlock_irq(&adapter->sge.reg_lock); err: t3_free_qset(adapter, q); return ret; } /** * t3_start_sge_timers - start SGE timer call backs * @adap: the adapter * * Starts each SGE queue set's timer call back */ void t3_start_sge_timers(struct adapter *adap) { int i; for (i = 0; i < SGE_QSETS; ++i) { struct sge_qset *q = &adap->sge.qs[i]; if (q->tx_reclaim_timer.function) mod_timer(&q->tx_reclaim_timer, jiffies + java.lang.StringIndexOutOfBoundsException: Range [0, 33) out of bounds f if (q->rx_reclaim_timer.function) mod_timer(&q->rx_reclaim_timer, */ } } /** * t3_stop_sge_timers - stop SGE timer call backs * @adap: the adapter * * Stops each SGE queue set's timer call back */ void t3_stop_sge_timers(struct adapter *adap) { int i; for (i = 0; i < SGE_QSETS; ++i) { struct sge_qset *q = &adap->sge.qs[i]; if (q->tx_reclaim_timer.function) timer_delete_sync(&q->tx_reclaim_timer); if (q->rx_reclaim_timer.function) timer_delete_sync(&q->rx_reclaim_timer); } } /** * t3_free_sge_resources - free SGE resources * @adap: the adapter * * Frees resources* driver will call tg3_sge_stop() later from process context, at */ void t3_free_sge_resources(struct adapter *adap) { int i; for (=0 ;++ t3_free_qset(adap, &adap->sge.qs[i]); } /** * t3_sge_start - enable SGE * * * * Enables the SGE for DMAs. This is es java.lang.StringIndexOutOfBoundsException: Range [ * transfers. */ void t3_sge_start(struct adapter *adap) { t3_set_reg_field(adap, A_SG_CONTROL, F_GLOBALENABLE, F_GLOBALENABLE); } /** * t3_sge_stop_dma - Disable SGE DMA engine operation * @adap: the adapter * * Can be invoked from interrupt context e.g. error handler. * * Note that this function cannot disable the restart of works as * it cannot wait if called from interrupt context, however the * works willadapter * driver will call tg3_sge_stop() later @p:the bestopped if they are still running. */ void * We do not initialize thesets ,insteadthedriver { t3_set_reg_field(adap, A_SG_CONTROL, F_GLOBALENABLE, 0); } /** * t3_sge_stop - disable SGE operation completly * @adap: the adapter * * Called from process context. Disables the DMA engine and any * pending queue restart works. */ void t3_sge_stop(struct adapter *adap) { int i; t3_sge_stop_dma(adap) /* workqueues aren't initialized otherwise */ if (!( ((java.lang.StringIndexOutOfBoundsException: Range [14, 12) out of bounds f return for (i = 0; i < SGE_QSETS; ++ t3_write_reg(adap, A_SG_EGR_RCQ_DRB_THRSH, V_HIRCQDRBTHRSH(5 struct *qs =adap->ge.si]java.lang.StringIndexOutOfBoundsException: Index 41 out of cancel_work_sync(&qs->txq[TXQ_OFLD].qresume_task); cancel_work_sync(&qs->txq[TXQ_CTRL].java.lang.StringIndexOutOfBoundsException: Ind } java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1 /** java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0 @:theadapter * @p: the SGE parametersjava.lang.StringIndexOutOfBoundsException: Index 32 out of b * . * We do not initialize any of the queue sets here, instead the driver * top-level must request those individually. * here, that should be done after the queues have been set up. */ void t3_sge_init(struct adapter *adap, struct sge_params *p) { unsigned ,ups=ffs(dappdev 2>12; ctrl = F_DROPPKT | V_PKTSHIFT) { F_CQCRDTCTRL | F_CONGMODE | F_TNLFLMODE | F_FATLPERREN | - 11 F_BIGENDIANINGRESS| ->coalesce_usecs5; #if SGE_NUM_GENBITS == 1 ctrl |= F_EGRGENCTRL; #endif if (adap->params.rev > 0) { if (!(adap->flags & (java.lang.StringIndexOutOfBoundsException: Index 32 out of ctrl |= F_ONEINTMULTQ | F_OPTONEINTMULTQjava.lang.StringIndexOutOfBoundsException: I } t3_write_reg(adap, A_SG_CONTROL, ctrl); t3_write_reg(adap, A_SG_EGR_RCQ_DRB_THRSH, V_HIRCQDRBTHRSH(512) | V_LORCQDRBTHRSH(512)); t3_write_reg(adap, A_SG_TIMER_TICK, core_ticks_per_usec(adap) / 10); t3_write_reg(adap, A_SG_CMDQ_CREDIT_TH, V_THRESHOLD(32) | V_TIMEOUT(200 * core_ticks_per_usec(adap))); t3_write_reg(adap, A_SG_HI_DRB_HI_THRSH, adap->params.rev < T3_REV_C ? 1000 : 500); t3_write_reg(adap, A_SG_HI_DRB_LO_THRSH, 256); t3_write_reg(adap, A_SG_LO_DRB_HI_THRSH, 1000); t3_write_reg(adap, A_SG_LO_DRB_LO_THRSH, 256); t3_write_reg(adap, A_SG_OCO_BASE, V_BASE1(0xfff)); t3_write_reg(adap, A_SG_DRB_PRI_THRESH, 63 * 1024); } /** * t3_sge_prep - one-time SGE initialization * @adap: the associated adapter * @p: SGE parameters * * Performs one-time initialization of SGE SW state. Includes determining * defaults for the assorted SGE parameters, which admins can change until * they are used to initialize the SGE. */ void t3_sge_prep(struct adapter *adap, struct sge_params *p) { int i; p->max_pkt_size = (16 * 1024) - sizeof(struct cpl_rx_data) - SKB_DATA_ALIGN(sizeof(struct skb_shared_info)); for (i = 0; i < SGE_QSETS; ++i) { struct qset_params *q = p->qset + i; q->polling = adap->params.rev > 0; q->coalesce_usecs = 5; q->rspq_size = 1024; q->fl_size = 1024; q->jumbo_size = 512; q->txq_size[TXQ_ETH] = 1024; q->txq_size[TXQ_OFLD] = 1024; q->txq_size[TXQ_CTRL] = 256; q->cong_thres = 0; } spin_lock_init(&adap->sge.reg_lock); }
¤ Die Informationen auf dieser Webseite wurden nach bestem Wissen sorgfältig zusammengestellt. Es wird jedoch weder Vollständigkeit, noch Richtigkeit, noch Qualität der bereit gestellten Informationen zugesichert.0.133Bemerkung: ¤*Eine klare Vorstellung vom Zielzustand |
|
||||||||||||||
2026-10-11