bnx2x_cmn.c 102.6 KB
Newer Older
D
Dmitry Kravkov 已提交
1 2
/* bnx2x_cmn.c: Broadcom Everest network driver.
 *
3
 * Copyright (c) 2007-2012 Broadcom Corporation
D
Dmitry Kravkov 已提交
4 5 6 7 8 9 10 11 12 13 14 15 16 17
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation.
 *
 * Maintained by: Eilon Greenstein <eilong@broadcom.com>
 * Written by: Eliezer Tamir
 * Based on code from Michael Chan's bnx2 driver
 * UDP CSUM errata workaround by Arik Gendelman
 * Slowpath and fastpath rework by Vladislav Zolotarov
 * Statistics and Link management by Yitchak Gertner
 *
 */

18 19
#define pr_fmt(fmt) KBUILD_MODNAME ": " fmt

D
Dmitry Kravkov 已提交
20
#include <linux/etherdevice.h>
21
#include <linux/if_vlan.h>
22
#include <linux/interrupt.h>
D
Dmitry Kravkov 已提交
23
#include <linux/ip.h>
D
Dmitry Kravkov 已提交
24
#include <net/ipv6.h>
25
#include <net/ip6_checksum.h>
26
#include <linux/prefetch.h>
D
Dmitry Kravkov 已提交
27
#include "bnx2x_cmn.h"
28
#include "bnx2x_init.h"
V
Vladislav Zolotarov 已提交
29
#include "bnx2x_sp.h"
30

31

D
Dmitry Kravkov 已提交
32

33 34 35 36 37 38 39 40
/**
 * bnx2x_move_fp - move content of the fastpath structure.
 *
 * @bp:		driver handle
 * @from:	source FP index
 * @to:		destination FP index
 *
 * Makes sure the contents of the bp->fp[to].napi is kept
41 42 43
 * intact. This is done by first copying the napi struct from
 * the target to the source, and then mem copying the entire
 * source onto the target
44 45 46 47 48
 */
static inline void bnx2x_move_fp(struct bnx2x *bp, int from, int to)
{
	struct bnx2x_fastpath *from_fp = &bp->fp[from];
	struct bnx2x_fastpath *to_fp = &bp->fp[to];
49 50 51 52

	/* Copy the NAPI object as it has been already initialized */
	from_fp->napi = to_fp->napi;

53 54 55 56 57
	/* Move bnx2x_fastpath contents */
	memcpy(to_fp, from_fp, sizeof(*to_fp));
	to_fp->index = to;
}

58 59
int load_count[2][3] = { {0} }; /* per-path: 0-common, 1-port0, 2-port1 */

D
Dmitry Kravkov 已提交
60 61 62
/* free skb in the packet ring at pos idx
 * return idx of last bd freed
 */
63
static u16 bnx2x_free_tx_pkt(struct bnx2x *bp, struct bnx2x_fp_txdata *txdata,
T
Tom Herbert 已提交
64 65
			     u16 idx, unsigned int *pkts_compl,
			     unsigned int *bytes_compl)
D
Dmitry Kravkov 已提交
66
{
67
	struct sw_tx_bd *tx_buf = &txdata->tx_buf_ring[idx];
D
Dmitry Kravkov 已提交
68 69 70 71 72 73 74 75 76
	struct eth_tx_start_bd *tx_start_bd;
	struct eth_tx_bd *tx_data_bd;
	struct sk_buff *skb = tx_buf->skb;
	u16 bd_idx = TX_BD(tx_buf->first_bd), new_cons;
	int nbd;

	/* prefetch skb end pointer to speedup dev_kfree_skb() */
	prefetch(&skb->end);

M
Merav Sicron 已提交
77
	DP(NETIF_MSG_TX_DONE, "fp[%d]: pkt_idx %d  buff @(%p)->skb %p\n",
78
	   txdata->txq_index, idx, tx_buf, skb);
D
Dmitry Kravkov 已提交
79 80

	/* unmap first bd */
81
	tx_start_bd = &txdata->tx_desc_ring[bd_idx].start_bd;
D
Dmitry Kravkov 已提交
82
	dma_unmap_single(&bp->pdev->dev, BD_UNMAP_ADDR(tx_start_bd),
83
			 BD_UNMAP_LEN(tx_start_bd), DMA_TO_DEVICE);
D
Dmitry Kravkov 已提交
84

85

D
Dmitry Kravkov 已提交
86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110
	nbd = le16_to_cpu(tx_start_bd->nbd) - 1;
#ifdef BNX2X_STOP_ON_ERROR
	if ((nbd - 1) > (MAX_SKB_FRAGS + 2)) {
		BNX2X_ERR("BAD nbd!\n");
		bnx2x_panic();
	}
#endif
	new_cons = nbd + tx_buf->first_bd;

	/* Get the next bd */
	bd_idx = TX_BD(NEXT_TX_IDX(bd_idx));

	/* Skip a parse bd... */
	--nbd;
	bd_idx = TX_BD(NEXT_TX_IDX(bd_idx));

	/* ...and the TSO split header bd since they have no mapping */
	if (tx_buf->flags & BNX2X_TSO_SPLIT_BD) {
		--nbd;
		bd_idx = TX_BD(NEXT_TX_IDX(bd_idx));
	}

	/* now free frags */
	while (nbd > 0) {

111
		tx_data_bd = &txdata->tx_desc_ring[bd_idx].reg_bd;
D
Dmitry Kravkov 已提交
112 113 114 115 116 117 118 119
		dma_unmap_page(&bp->pdev->dev, BD_UNMAP_ADDR(tx_data_bd),
			       BD_UNMAP_LEN(tx_data_bd), DMA_TO_DEVICE);
		if (--nbd)
			bd_idx = TX_BD(NEXT_TX_IDX(bd_idx));
	}

	/* release skb */
	WARN_ON(!skb);
120
	if (likely(skb)) {
T
Tom Herbert 已提交
121 122 123
		(*pkts_compl)++;
		(*bytes_compl) += skb->len;
	}
124

125
	dev_kfree_skb_any(skb);
D
Dmitry Kravkov 已提交
126 127 128 129 130 131
	tx_buf->first_bd = 0;
	tx_buf->skb = NULL;

	return new_cons;
}

132
int bnx2x_tx_int(struct bnx2x *bp, struct bnx2x_fp_txdata *txdata)
D
Dmitry Kravkov 已提交
133 134
{
	struct netdev_queue *txq;
135
	u16 hw_cons, sw_cons, bd_cons = txdata->tx_bd_cons;
T
Tom Herbert 已提交
136
	unsigned int pkts_compl = 0, bytes_compl = 0;
D
Dmitry Kravkov 已提交
137 138 139 140 141 142

#ifdef BNX2X_STOP_ON_ERROR
	if (unlikely(bp->panic))
		return -1;
#endif

143 144 145
	txq = netdev_get_tx_queue(bp->dev, txdata->txq_index);
	hw_cons = le16_to_cpu(*txdata->tx_cons_sb);
	sw_cons = txdata->tx_pkt_cons;
D
Dmitry Kravkov 已提交
146 147 148 149 150 151

	while (sw_cons != hw_cons) {
		u16 pkt_cons;

		pkt_cons = TX_BD(sw_cons);

M
Merav Sicron 已提交
152 153
		DP(NETIF_MSG_TX_DONE,
		   "queue[%d]: hw_cons %u  sw_cons %u  pkt_cons %u\n",
154
		   txdata->txq_index, hw_cons, sw_cons, pkt_cons);
D
Dmitry Kravkov 已提交
155

T
Tom Herbert 已提交
156 157 158
		bd_cons = bnx2x_free_tx_pkt(bp, txdata, pkt_cons,
		    &pkts_compl, &bytes_compl);

D
Dmitry Kravkov 已提交
159 160 161
		sw_cons++;
	}

T
Tom Herbert 已提交
162 163
	netdev_tx_completed_queue(txq, pkts_compl, bytes_compl);

164 165
	txdata->tx_pkt_cons = sw_cons;
	txdata->tx_bd_cons = bd_cons;
D
Dmitry Kravkov 已提交
166 167 168 169 170 171

	/* Need to make the tx_bd_cons update visible to start_xmit()
	 * before checking for netif_tx_queue_stopped().  Without the
	 * memory barrier, there is a small possibility that
	 * start_xmit() will miss it and cause the queue to be stopped
	 * forever.
172 173 174
	 * On the other hand we need an rmb() here to ensure the proper
	 * ordering of bit testing in the following
	 * netif_tx_queue_stopped(txq) call.
D
Dmitry Kravkov 已提交
175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192
	 */
	smp_mb();

	if (unlikely(netif_tx_queue_stopped(txq))) {
		/* Taking tx_lock() is needed to prevent reenabling the queue
		 * while it's empty. This could have happen if rx_action() gets
		 * suspended in bnx2x_tx_int() after the condition before
		 * netif_tx_wake_queue(), while tx_action (bnx2x_start_xmit()):
		 *
		 * stops the queue->sees fresh tx_bd_cons->releases the queue->
		 * sends some packets consuming the whole queue again->
		 * stops the queue
		 */

		__netif_tx_lock(txq, smp_processor_id());

		if ((netif_tx_queue_stopped(txq)) &&
		    (bp->state == BNX2X_STATE_OPEN) &&
193
		    (bnx2x_tx_avail(bp, txdata) >= MAX_SKB_FRAGS + 4))
D
Dmitry Kravkov 已提交
194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209
			netif_tx_wake_queue(txq);

		__netif_tx_unlock(txq);
	}
	return 0;
}

static inline void bnx2x_update_last_max_sge(struct bnx2x_fastpath *fp,
					     u16 idx)
{
	u16 last_max = fp->last_max_sge;

	if (SUB_S16(idx, last_max) > 0)
		fp->last_max_sge = idx;
}

D
Dmitry Kravkov 已提交
210 211 212
static inline void bnx2x_update_sge_prod(struct bnx2x_fastpath *fp,
					 u16 sge_len,
					 struct eth_end_agg_rx_cqe *cqe)
D
Dmitry Kravkov 已提交
213 214 215 216 217 218 219 220 221 222 223
{
	struct bnx2x *bp = fp->bp;
	u16 last_max, last_elem, first_elem;
	u16 delta = 0;
	u16 i;

	if (!sge_len)
		return;

	/* First mark all used pages */
	for (i = 0; i < sge_len; i++)
224
		BIT_VEC64_CLEAR_BIT(fp->sge_mask,
D
Dmitry Kravkov 已提交
225
			RX_SGE(le16_to_cpu(cqe->sgl_or_raw_data.sgl[i])));
D
Dmitry Kravkov 已提交
226 227

	DP(NETIF_MSG_RX_STATUS, "fp_cqe->sgl[%d] = %d\n",
D
Dmitry Kravkov 已提交
228
	   sge_len - 1, le16_to_cpu(cqe->sgl_or_raw_data.sgl[sge_len - 1]));
D
Dmitry Kravkov 已提交
229 230 231

	/* Here we assume that the last SGE index is the biggest */
	prefetch((void *)(fp->sge_mask));
232
	bnx2x_update_last_max_sge(fp,
D
Dmitry Kravkov 已提交
233
		le16_to_cpu(cqe->sgl_or_raw_data.sgl[sge_len - 1]));
D
Dmitry Kravkov 已提交
234 235

	last_max = RX_SGE(fp->last_max_sge);
236 237
	last_elem = last_max >> BIT_VEC64_ELEM_SHIFT;
	first_elem = RX_SGE(fp->rx_sge_prod) >> BIT_VEC64_ELEM_SHIFT;
D
Dmitry Kravkov 已提交
238 239 240 241 242 243 244 245 246 247

	/* If ring is not full */
	if (last_elem + 1 != first_elem)
		last_elem++;

	/* Now update the prod */
	for (i = first_elem; i != last_elem; i = NEXT_SGE_MASK_ELEM(i)) {
		if (likely(fp->sge_mask[i]))
			break;

248 249
		fp->sge_mask[i] = BIT_VEC64_ELEM_ONE_MASK;
		delta += BIT_VEC64_ELEM_SZ;
D
Dmitry Kravkov 已提交
250 251 252 253 254 255 256 257 258 259 260 261 262
	}

	if (delta > 0) {
		fp->rx_sge_prod += delta;
		/* clear page-end entries */
		bnx2x_clear_sge_mask_next_elems(fp);
	}

	DP(NETIF_MSG_RX_STATUS,
	   "fp->last_max_sge = %d  fp->rx_sge_prod = %d\n",
	   fp->last_max_sge, fp->rx_sge_prod);
}

263 264 265 266 267 268 269 270 271 272 273 274 275
/* Set Toeplitz hash value in the skb using the value from the
 * CQE (calculated by HW).
 */
static u32 bnx2x_get_rxhash(const struct bnx2x *bp,
			    const struct eth_fast_path_rx_cqe *cqe)
{
	/* Set Toeplitz hash from CQE */
	if ((bp->dev->features & NETIF_F_RXHASH) &&
	    (cqe->status_flags & ETH_FAST_PATH_RX_CQE_RSS_HASH_FLG))
		return le32_to_cpu(cqe->rss_hash_result);
	return 0;
}

D
Dmitry Kravkov 已提交
276
static void bnx2x_tpa_start(struct bnx2x_fastpath *fp, u16 queue,
277
			    u16 cons, u16 prod,
278
			    struct eth_fast_path_rx_cqe *cqe)
D
Dmitry Kravkov 已提交
279 280 281 282 283 284
{
	struct bnx2x *bp = fp->bp;
	struct sw_rx_bd *cons_rx_buf = &fp->rx_buf_ring[cons];
	struct sw_rx_bd *prod_rx_buf = &fp->rx_buf_ring[prod];
	struct eth_rx_bd *prod_bd = &fp->rx_desc_ring[prod];
	dma_addr_t mapping;
285 286
	struct bnx2x_agg_info *tpa_info = &fp->tpa_info[queue];
	struct sw_rx_bd *first_buf = &tpa_info->first_buf;
D
Dmitry Kravkov 已提交
287

288 289
	/* print error if current state != stop */
	if (tpa_info->tpa_state != BNX2X_TPA_STOP)
D
Dmitry Kravkov 已提交
290 291
		BNX2X_ERR("start of bin not in stop [%d]\n", queue);

292
	/* Try to map an empty data buffer from the aggregation info  */
293
	mapping = dma_map_single(&bp->pdev->dev,
294
				 first_buf->data + NET_SKB_PAD,
295 296 297 298 299 300 301 302 303
				 fp->rx_buf_size, DMA_FROM_DEVICE);
	/*
	 *  ...if it fails - move the skb from the consumer to the producer
	 *  and set the current aggregation state as ERROR to drop it
	 *  when TPA_STOP arrives.
	 */

	if (unlikely(dma_mapping_error(&bp->pdev->dev, mapping))) {
		/* Move the BD from the consumer to the producer */
304
		bnx2x_reuse_rx_data(fp, cons, prod);
305 306 307
		tpa_info->tpa_state = BNX2X_TPA_ERROR;
		return;
	}
D
Dmitry Kravkov 已提交
308

309 310
	/* move empty data from pool to prod */
	prod_rx_buf->data = first_buf->data;
311
	dma_unmap_addr_set(prod_rx_buf, mapping, mapping);
312
	/* point prod_bd to new data */
D
Dmitry Kravkov 已提交
313 314 315
	prod_bd->addr_hi = cpu_to_le32(U64_HI(mapping));
	prod_bd->addr_lo = cpu_to_le32(U64_LO(mapping));

316 317 318 319 320 321 322 323 324 325
	/* move partial skb from cons to pool (don't unmap yet) */
	*first_buf = *cons_rx_buf;

	/* mark bin state as START */
	tpa_info->parsing_flags =
		le16_to_cpu(cqe->pars_flags.flags);
	tpa_info->vlan_tag = le16_to_cpu(cqe->vlan_tag);
	tpa_info->tpa_state = BNX2X_TPA_START;
	tpa_info->len_on_bd = le16_to_cpu(cqe->len_on_bd);
	tpa_info->placement_offset = cqe->placement_offset;
326
	tpa_info->rxhash = bnx2x_get_rxhash(bp, cqe);
D
Dmitry Kravkov 已提交
327 328 329 330 331 332
	if (fp->mode == TPA_MODE_GRO) {
		u16 gro_size = le16_to_cpu(cqe->pkt_len_or_gro_seg_len);
		tpa_info->full_page =
			SGE_PAGE_SIZE * PAGES_PER_SGE / gro_size * gro_size;
		tpa_info->gro_size = gro_size;
	}
333

D
Dmitry Kravkov 已提交
334 335 336 337 338 339 340 341 342 343 344
#ifdef BNX2X_STOP_ON_ERROR
	fp->tpa_queue_used |= (1 << queue);
#ifdef _ASM_GENERIC_INT_L64_H
	DP(NETIF_MSG_RX_STATUS, "fp->tpa_queue_used = 0x%lx\n",
#else
	DP(NETIF_MSG_RX_STATUS, "fp->tpa_queue_used = 0x%llx\n",
#endif
	   fp->tpa_queue_used);
#endif
}

345 346 347 348 349 350
/* Timestamp option length allowed for TPA aggregation:
 *
 *		nop nop kind length echo val
 */
#define TPA_TSTAMP_OPT_LEN	12
/**
351
 * bnx2x_set_lro_mss - calculate the approximate value of the MSS
352
 *
353 354 355 356 357 358 359
 * @bp:			driver handle
 * @parsing_flags:	parsing flags from the START CQE
 * @len_on_bd:		total length of the first packet for the
 *			aggregation.
 *
 * Approximate value of the MSS for this aggregation calculated using
 * the first packet of it.
360
 */
E
Eric Dumazet 已提交
361 362
static u16 bnx2x_set_lro_mss(struct bnx2x *bp, u16 parsing_flags,
			     u16 len_on_bd)
363
{
364 365 366
	/*
	 * TPA arrgregation won't have either IP options or TCP options
	 * other than timestamp or IPv6 extension headers.
367
	 */
368 369 370 371 372 373 374
	u16 hdrs_len = ETH_HLEN + sizeof(struct tcphdr);

	if (GET_FLAG(parsing_flags, PARSING_FLAGS_OVER_ETHERNET_PROTOCOL) ==
	    PRS_FLAG_OVERETH_IPV6)
		hdrs_len += sizeof(struct ipv6hdr);
	else /* IPv4 */
		hdrs_len += sizeof(struct iphdr);
375 376 377 378 379 380 381 382 383 384 385 386 387


	/* Check if there was a TCP timestamp, if there is it's will
	 * always be 12 bytes length: nop nop kind length echo val.
	 *
	 * Otherwise FW would close the aggregation.
	 */
	if (parsing_flags & PARSING_FLAGS_TIME_STAMP_EXIST_FLAG)
		hdrs_len += TPA_TSTAMP_OPT_LEN;

	return len_on_bd - hdrs_len;
}

E
Eric Dumazet 已提交
388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417
static int bnx2x_alloc_rx_sge(struct bnx2x *bp,
			      struct bnx2x_fastpath *fp, u16 index)
{
	struct page *page = alloc_pages(GFP_ATOMIC, PAGES_PER_SGE_SHIFT);
	struct sw_rx_page *sw_buf = &fp->rx_page_ring[index];
	struct eth_rx_sge *sge = &fp->rx_sge_ring[index];
	dma_addr_t mapping;

	if (unlikely(page == NULL)) {
		BNX2X_ERR("Can't alloc sge\n");
		return -ENOMEM;
	}

	mapping = dma_map_page(&bp->pdev->dev, page, 0,
			       SGE_PAGE_SIZE*PAGES_PER_SGE, DMA_FROM_DEVICE);
	if (unlikely(dma_mapping_error(&bp->pdev->dev, mapping))) {
		__free_pages(page, PAGES_PER_SGE_SHIFT);
		BNX2X_ERR("Can't map sge\n");
		return -ENOMEM;
	}

	sw_buf->page = page;
	dma_unmap_addr_set(sw_buf, mapping, mapping);

	sge->addr_hi = cpu_to_le32(U64_HI(mapping));
	sge->addr_lo = cpu_to_le32(U64_LO(mapping));

	return 0;
}

D
Dmitry Kravkov 已提交
418
static int bnx2x_fill_frag_skb(struct bnx2x *bp, struct bnx2x_fastpath *fp,
D
Dmitry Kravkov 已提交
419 420 421
			       struct bnx2x_agg_info *tpa_info,
			       u16 pages,
			       struct sk_buff *skb,
422 423
			       struct eth_end_agg_rx_cqe *cqe,
			       u16 cqe_idx)
D
Dmitry Kravkov 已提交
424 425
{
	struct sw_rx_page *rx_pg, old_rx_pg;
D
Dmitry Kravkov 已提交
426 427
	u32 i, frag_len, frag_size;
	int err, j, frag_id = 0;
428
	u16 len_on_bd = tpa_info->len_on_bd;
D
Dmitry Kravkov 已提交
429
	u16 full_page = 0, gro_size = 0;
D
Dmitry Kravkov 已提交
430

431
	frag_size = le16_to_cpu(cqe->pkt_len) - len_on_bd;
D
Dmitry Kravkov 已提交
432 433 434 435 436

	if (fp->mode == TPA_MODE_GRO) {
		gro_size = tpa_info->gro_size;
		full_page = tpa_info->full_page;
	}
D
Dmitry Kravkov 已提交
437 438

	/* This is needed in order to enable forwarding support */
D
Dmitry Kravkov 已提交
439
	if (frag_size) {
440 441
		skb_shinfo(skb)->gso_size = bnx2x_set_lro_mss(bp,
					tpa_info->parsing_flags, len_on_bd);
D
Dmitry Kravkov 已提交
442

D
Dmitry Kravkov 已提交
443 444 445 446 447 448 449 450 451 452
		/* set for GRO */
		if (fp->mode == TPA_MODE_GRO)
			skb_shinfo(skb)->gso_type =
			    (GET_FLAG(tpa_info->parsing_flags,
				      PARSING_FLAGS_OVER_ETHERNET_PROTOCOL) ==
						PRS_FLAG_OVERETH_IPV6) ?
				SKB_GSO_TCPV6 : SKB_GSO_TCPV4;
	}


D
Dmitry Kravkov 已提交
453 454 455 456
#ifdef BNX2X_STOP_ON_ERROR
	if (pages > min_t(u32, 8, MAX_SKB_FRAGS)*SGE_PAGE_SIZE*PAGES_PER_SGE) {
		BNX2X_ERR("SGL length is too long: %d. CQE index is %d\n",
			  pages, cqe_idx);
457
		BNX2X_ERR("cqe->pkt_len = %d\n", cqe->pkt_len);
D
Dmitry Kravkov 已提交
458 459 460 461 462 463 464
		bnx2x_panic();
		return -EINVAL;
	}
#endif

	/* Run through the SGL and compose the fragmented skb */
	for (i = 0, j = 0; i < pages; i += PAGES_PER_SGE, j++) {
465
		u16 sge_idx = RX_SGE(le16_to_cpu(cqe->sgl_or_raw_data.sgl[j]));
D
Dmitry Kravkov 已提交
466 467 468

		/* FW gives the indices of the SGE as if the ring is an array
		   (meaning that "next" element will consume 2 indices) */
D
Dmitry Kravkov 已提交
469 470 471 472 473 474
		if (fp->mode == TPA_MODE_GRO)
			frag_len = min_t(u32, frag_size, (u32)full_page);
		else /* LRO */
			frag_len = min_t(u32, frag_size,
					 (u32)(SGE_PAGE_SIZE * PAGES_PER_SGE));

D
Dmitry Kravkov 已提交
475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490
		rx_pg = &fp->rx_page_ring[sge_idx];
		old_rx_pg = *rx_pg;

		/* If we fail to allocate a substitute page, we simply stop
		   where we are and drop the whole packet */
		err = bnx2x_alloc_rx_sge(bp, fp, sge_idx);
		if (unlikely(err)) {
			fp->eth_q_stats.rx_skb_alloc_failed++;
			return err;
		}

		/* Unmap the page as we r going to pass it to the stack */
		dma_unmap_page(&bp->pdev->dev,
			       dma_unmap_addr(&old_rx_pg, mapping),
			       SGE_PAGE_SIZE*PAGES_PER_SGE, DMA_FROM_DEVICE);
		/* Add one frag and update the appropriate fields in the skb */
D
Dmitry Kravkov 已提交
491 492 493 494 495 496 497 498 499 500 501 502 503 504
		if (fp->mode == TPA_MODE_LRO)
			skb_fill_page_desc(skb, j, old_rx_pg.page, 0, frag_len);
		else { /* GRO */
			int rem;
			int offset = 0;
			for (rem = frag_len; rem > 0; rem -= gro_size) {
				int len = rem > gro_size ? gro_size : rem;
				skb_fill_page_desc(skb, frag_id++,
						   old_rx_pg.page, offset, len);
				if (offset)
					get_page(old_rx_pg.page);
				offset += len;
			}
		}
D
Dmitry Kravkov 已提交
505 506

		skb->data_len += frag_len;
507
		skb->truesize += SGE_PAGE_SIZE * PAGES_PER_SGE;
D
Dmitry Kravkov 已提交
508 509 510 511 512 513 514 515
		skb->len += frag_len;

		frag_size -= frag_len;
	}

	return 0;
}

E
Eric Dumazet 已提交
516 517 518 519 520
static void bnx2x_tpa_stop(struct bnx2x *bp, struct bnx2x_fastpath *fp,
			   struct bnx2x_agg_info *tpa_info,
			   u16 pages,
			   struct eth_end_agg_rx_cqe *cqe,
			   u16 cqe_idx)
D
Dmitry Kravkov 已提交
521
{
522
	struct sw_rx_bd *rx_buf = &tpa_info->first_buf;
D
Dmitry Kravkov 已提交
523
	u8 pad = tpa_info->placement_offset;
524
	u16 len = tpa_info->len_on_bd;
525
	struct sk_buff *skb = NULL;
D
Dmitry Kravkov 已提交
526
	u8 *new_data, *data = rx_buf->data;
527 528 529 530 531 532 533 534 535 536
	u8 old_tpa_state = tpa_info->tpa_state;

	tpa_info->tpa_state = BNX2X_TPA_STOP;

	/* If we there was an error during the handling of the TPA_START -
	 * drop this aggregation.
	 */
	if (old_tpa_state == BNX2X_TPA_ERROR)
		goto drop;

537 538
	/* Try to allocate the new data */
	new_data = kmalloc(fp->rx_buf_size + NET_SKB_PAD, GFP_ATOMIC);
D
Dmitry Kravkov 已提交
539 540 541 542 543

	/* Unmap skb in the pool anyway, as we are going to change
	   pool entry status to BNX2X_TPA_STOP even if new skb allocation
	   fails. */
	dma_unmap_single(&bp->pdev->dev, dma_unmap_addr(rx_buf, mapping),
544
			 fp->rx_buf_size, DMA_FROM_DEVICE);
545
	if (likely(new_data))
546
		skb = build_skb(data, 0);
D
Dmitry Kravkov 已提交
547

548
	if (likely(skb)) {
D
Dmitry Kravkov 已提交
549
#ifdef BNX2X_STOP_ON_ERROR
550
		if (pad + len > fp->rx_buf_size) {
M
Merav Sicron 已提交
551
			BNX2X_ERR("skb_put is about to fail...  pad %d  len %d  rx_buf_size %d\n",
552
				  pad, len, fp->rx_buf_size);
D
Dmitry Kravkov 已提交
553 554 555 556 557
			bnx2x_panic();
			return;
		}
#endif

558
		skb_reserve(skb, pad + NET_SKB_PAD);
D
Dmitry Kravkov 已提交
559
		skb_put(skb, len);
560
		skb->rxhash = tpa_info->rxhash;
D
Dmitry Kravkov 已提交
561 562 563 564

		skb->protocol = eth_type_trans(skb, bp->dev);
		skb->ip_summed = CHECKSUM_UNNECESSARY;

D
Dmitry Kravkov 已提交
565 566
		if (!bnx2x_fill_frag_skb(bp, fp, tpa_info, pages,
					 skb, cqe, cqe_idx)) {
567 568
			if (tpa_info->parsing_flags & PARSING_FLAGS_VLAN)
				__vlan_hwaccel_put_tag(skb, tpa_info->vlan_tag);
569
			napi_gro_receive(&fp->napi, skb);
D
Dmitry Kravkov 已提交
570
		} else {
M
Merav Sicron 已提交
571 572
			DP(NETIF_MSG_RX_STATUS,
			   "Failed to allocate new pages - dropping packet!\n");
573
			dev_kfree_skb_any(skb);
D
Dmitry Kravkov 已提交
574 575 576
		}


577 578
		/* put new data in bin */
		rx_buf->data = new_data;
D
Dmitry Kravkov 已提交
579

580
		return;
D
Dmitry Kravkov 已提交
581
	}
582
	kfree(new_data);
583 584 585 586 587
drop:
	/* drop the packet and keep the buffer in the bin */
	DP(NETIF_MSG_RX_STATUS,
	   "Failed to allocate or map a new skb - dropping packet!\n");
	fp->eth_q_stats.rx_skb_alloc_failed++;
D
Dmitry Kravkov 已提交
588 589
}

E
Eric Dumazet 已提交
590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619
static int bnx2x_alloc_rx_data(struct bnx2x *bp,
			       struct bnx2x_fastpath *fp, u16 index)
{
	u8 *data;
	struct sw_rx_bd *rx_buf = &fp->rx_buf_ring[index];
	struct eth_rx_bd *rx_bd = &fp->rx_desc_ring[index];
	dma_addr_t mapping;

	data = kmalloc(fp->rx_buf_size + NET_SKB_PAD, GFP_ATOMIC);
	if (unlikely(data == NULL))
		return -ENOMEM;

	mapping = dma_map_single(&bp->pdev->dev, data + NET_SKB_PAD,
				 fp->rx_buf_size,
				 DMA_FROM_DEVICE);
	if (unlikely(dma_mapping_error(&bp->pdev->dev, mapping))) {
		kfree(data);
		BNX2X_ERR("Can't map rx data\n");
		return -ENOMEM;
	}

	rx_buf->data = data;
	dma_unmap_addr_set(rx_buf, mapping, mapping);

	rx_bd->addr_hi = cpu_to_le32(U64_HI(mapping));
	rx_bd->addr_lo = cpu_to_le32(U64_LO(mapping));

	return 0;
}

E
Eric Dumazet 已提交
620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638
static void bnx2x_csum_validate(struct sk_buff *skb, union eth_rx_cqe *cqe,
				struct bnx2x_fastpath *fp)
{
	/* Do nothing if no IP/L4 csum validation was done */

	if (cqe->fast_path_cqe.status_flags &
	    (ETH_FAST_PATH_RX_CQE_IP_XSUM_NO_VALIDATION_FLG |
	     ETH_FAST_PATH_RX_CQE_L4_XSUM_NO_VALIDATION_FLG))
		return;

	/* If both IP/L4 validation were done, check if an error was found. */

	if (cqe->fast_path_cqe.type_error_flags &
	    (ETH_FAST_PATH_RX_CQE_IP_BAD_XSUM_FLG |
	     ETH_FAST_PATH_RX_CQE_L4_BAD_XSUM_FLG))
		fp->eth_q_stats.hw_csum_err++;
	else
		skb->ip_summed = CHECKSUM_UNNECESSARY;
}
D
Dmitry Kravkov 已提交
639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676

int bnx2x_rx_int(struct bnx2x_fastpath *fp, int budget)
{
	struct bnx2x *bp = fp->bp;
	u16 bd_cons, bd_prod, bd_prod_fw, comp_ring_cons;
	u16 hw_comp_cons, sw_comp_cons, sw_comp_prod;
	int rx_pkt = 0;

#ifdef BNX2X_STOP_ON_ERROR
	if (unlikely(bp->panic))
		return 0;
#endif

	/* CQ "next element" is of the size of the regular element,
	   that's why it's ok here */
	hw_comp_cons = le16_to_cpu(*fp->rx_cons_sb);
	if ((hw_comp_cons & MAX_RCQ_DESC_CNT) == MAX_RCQ_DESC_CNT)
		hw_comp_cons++;

	bd_cons = fp->rx_bd_cons;
	bd_prod = fp->rx_bd_prod;
	bd_prod_fw = bd_prod;
	sw_comp_cons = fp->rx_comp_cons;
	sw_comp_prod = fp->rx_comp_prod;

	/* Memory barrier necessary as speculative reads of the rx
	 * buffer can be ahead of the index in the status block
	 */
	rmb();

	DP(NETIF_MSG_RX_STATUS,
	   "queue[%d]:  hw_comp_cons %u  sw_comp_cons %u\n",
	   fp->index, hw_comp_cons, sw_comp_cons);

	while (sw_comp_cons != hw_comp_cons) {
		struct sw_rx_bd *rx_buf = NULL;
		struct sk_buff *skb;
		union eth_rx_cqe *cqe;
677
		struct eth_fast_path_rx_cqe *cqe_fp;
D
Dmitry Kravkov 已提交
678
		u8 cqe_fp_flags;
679
		enum eth_rx_cqe_type cqe_fp_type;
D
Dmitry Kravkov 已提交
680
		u16 len, pad, queue;
681
		u8 *data;
D
Dmitry Kravkov 已提交
682

683 684 685 686 687
#ifdef BNX2X_STOP_ON_ERROR
		if (unlikely(bp->panic))
			return 0;
#endif

D
Dmitry Kravkov 已提交
688 689 690 691 692
		comp_ring_cons = RCQ_BD(sw_comp_cons);
		bd_prod = RX_BD(bd_prod);
		bd_cons = RX_BD(bd_cons);

		cqe = &fp->rx_comp_ring[comp_ring_cons];
693 694 695
		cqe_fp = &cqe->fast_path_cqe;
		cqe_fp_flags = cqe_fp->type_error_flags;
		cqe_fp_type = cqe_fp_flags & ETH_FAST_PATH_RX_CQE_TYPE;
D
Dmitry Kravkov 已提交
696

M
Merav Sicron 已提交
697 698 699
		DP(NETIF_MSG_RX_STATUS,
		   "CQE type %x  err %x  status %x  queue %x  vlan %x  len %u\n",
		   CQE_TYPE(cqe_fp_flags),
700 701
		   cqe_fp_flags, cqe_fp->status_flags,
		   le32_to_cpu(cqe_fp->rss_hash_result),
D
Dmitry Kravkov 已提交
702 703
		   le16_to_cpu(cqe_fp->vlan_tag),
		   le16_to_cpu(cqe_fp->pkt_len_or_gro_seg_len));
D
Dmitry Kravkov 已提交
704 705

		/* is this a slowpath msg? */
706
		if (unlikely(CQE_TYPE_SLOW(cqe_fp_type))) {
D
Dmitry Kravkov 已提交
707 708
			bnx2x_sp_event(fp, cqe);
			goto next_cqe;
709
		}
D
Dmitry Kravkov 已提交
710

711 712
		rx_buf = &fp->rx_buf_ring[bd_cons];
		data = rx_buf->data;
D
Dmitry Kravkov 已提交
713

714
		if (!CQE_TYPE_FAST(cqe_fp_type)) {
D
Dmitry Kravkov 已提交
715 716
			struct bnx2x_agg_info *tpa_info;
			u16 frag_size, pages;
717
#ifdef BNX2X_STOP_ON_ERROR
718 719 720 721
			/* sanity check */
			if (fp->disable_tpa &&
			    (CQE_TYPE_START(cqe_fp_type) ||
			     CQE_TYPE_STOP(cqe_fp_type)))
M
Merav Sicron 已提交
722
				BNX2X_ERR("START/STOP packet while disable_tpa type %x\n",
723
					  CQE_TYPE(cqe_fp_type));
724
#endif
D
Dmitry Kravkov 已提交
725

726 727 728 729 730
			if (CQE_TYPE_START(cqe_fp_type)) {
				u16 queue = cqe_fp->queue_index;
				DP(NETIF_MSG_RX_STATUS,
				   "calling tpa_start on queue %d\n",
				   queue);
D
Dmitry Kravkov 已提交
731

732 733 734
				bnx2x_tpa_start(fp, queue,
						bd_cons, bd_prod,
						cqe_fp);
D
Dmitry Kravkov 已提交
735

736 737
				goto next_rx;

D
Dmitry Kravkov 已提交
738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756
			}
			queue = cqe->end_agg_cqe.queue_index;
			tpa_info = &fp->tpa_info[queue];
			DP(NETIF_MSG_RX_STATUS,
			   "calling tpa_stop on queue %d\n",
			   queue);

			frag_size = le16_to_cpu(cqe->end_agg_cqe.pkt_len) -
				    tpa_info->len_on_bd;

			if (fp->mode == TPA_MODE_GRO)
				pages = (frag_size + tpa_info->full_page - 1) /
					 tpa_info->full_page;
			else
				pages = SGE_PAGE_ALIGN(frag_size) >>
					SGE_PAGE_SHIFT;

			bnx2x_tpa_stop(bp, fp, tpa_info, pages,
				       &cqe->end_agg_cqe, comp_ring_cons);
D
Dmitry Kravkov 已提交
757
#ifdef BNX2X_STOP_ON_ERROR
D
Dmitry Kravkov 已提交
758 759
			if (bp->panic)
				return 0;
D
Dmitry Kravkov 已提交
760 761
#endif

D
Dmitry Kravkov 已提交
762 763
			bnx2x_update_sge_prod(fp, pages, &cqe->end_agg_cqe);
			goto next_cqe;
764 765
		}
		/* non TPA */
D
Dmitry Kravkov 已提交
766
		len = le16_to_cpu(cqe_fp->pkt_len_or_gro_seg_len);
767 768
		pad = cqe_fp->placement_offset;
		dma_sync_single_for_cpu(&bp->pdev->dev,
D
Dmitry Kravkov 已提交
769
					dma_unmap_addr(rx_buf, mapping),
770 771 772 773 774 775
					pad + RX_COPY_THRESH,
					DMA_FROM_DEVICE);
		pad += NET_SKB_PAD;
		prefetch(data + pad); /* speedup eth_type_trans() */
		/* is this an error packet? */
		if (unlikely(cqe_fp_flags & ETH_RX_ERROR_FALGS)) {
M
Merav Sicron 已提交
776
			DP(NETIF_MSG_RX_ERR | NETIF_MSG_RX_STATUS,
777 778 779 780 781
			   "ERROR  flags %x  rx packet %u\n",
			   cqe_fp_flags, sw_comp_cons);
			fp->eth_q_stats.rx_err_discard_pkt++;
			goto reuse_rx;
		}
D
Dmitry Kravkov 已提交
782

783 784 785 786 787 788 789
		/* Since we don't have a jumbo ring
		 * copy small packets if mtu > 1500
		 */
		if ((bp->dev->mtu > ETH_MAX_PACKET_SIZE) &&
		    (len <= RX_COPY_THRESH)) {
			skb = netdev_alloc_skb_ip_align(bp->dev, len);
			if (skb == NULL) {
M
Merav Sicron 已提交
790
				DP(NETIF_MSG_RX_ERR | NETIF_MSG_RX_STATUS,
791 792
				   "ERROR  packet dropped because of alloc failure\n");
				fp->eth_q_stats.rx_skb_alloc_failed++;
D
Dmitry Kravkov 已提交
793 794
				goto reuse_rx;
			}
795 796 797 798
			memcpy(skb->data, data + pad, len);
			bnx2x_reuse_rx_data(fp, bd_cons, bd_prod);
		} else {
			if (likely(bnx2x_alloc_rx_data(bp, fp, bd_prod) == 0)) {
D
Dmitry Kravkov 已提交
799
				dma_unmap_single(&bp->pdev->dev,
800
						 dma_unmap_addr(rx_buf, mapping),
801
						 fp->rx_buf_size,
D
Dmitry Kravkov 已提交
802
						 DMA_FROM_DEVICE);
803
				skb = build_skb(data, 0);
804 805 806 807 808
				if (unlikely(!skb)) {
					kfree(data);
					fp->eth_q_stats.rx_skb_alloc_failed++;
					goto next_rx;
				}
D
Dmitry Kravkov 已提交
809 810
				skb_reserve(skb, pad);
			} else {
M
Merav Sicron 已提交
811 812
				DP(NETIF_MSG_RX_ERR | NETIF_MSG_RX_STATUS,
				   "ERROR  packet dropped because of alloc failure\n");
D
Dmitry Kravkov 已提交
813 814
				fp->eth_q_stats.rx_skb_alloc_failed++;
reuse_rx:
815
				bnx2x_reuse_rx_data(fp, bd_cons, bd_prod);
D
Dmitry Kravkov 已提交
816 817
				goto next_rx;
			}
818
		}
D
Dmitry Kravkov 已提交
819

820 821
		skb_put(skb, len);
		skb->protocol = eth_type_trans(skb, bp->dev);
D
Dmitry Kravkov 已提交
822

823 824
		/* Set Toeplitz hash for a none-LRO skb */
		skb->rxhash = bnx2x_get_rxhash(bp, cqe_fp);
D
Dmitry Kravkov 已提交
825

826
		skb_checksum_none_assert(skb);
D
Dmitry Kravkov 已提交
827

E
Eric Dumazet 已提交
828 829
		if (bp->dev->features & NETIF_F_RXCSUM)
			bnx2x_csum_validate(skb, cqe, fp);
830

D
Dmitry Kravkov 已提交
831

832
		skb_record_rx_queue(skb, fp->rx_queue);
D
Dmitry Kravkov 已提交
833

834 835
		if (le16_to_cpu(cqe_fp->pars_flags.flags) &
		    PARSING_FLAGS_VLAN)
836
			__vlan_hwaccel_put_tag(skb,
837
					       le16_to_cpu(cqe_fp->vlan_tag));
838
		napi_gro_receive(&fp->napi, skb);
D
Dmitry Kravkov 已提交
839 840 841


next_rx:
842
		rx_buf->data = NULL;
D
Dmitry Kravkov 已提交
843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874

		bd_cons = NEXT_RX_IDX(bd_cons);
		bd_prod = NEXT_RX_IDX(bd_prod);
		bd_prod_fw = NEXT_RX_IDX(bd_prod_fw);
		rx_pkt++;
next_cqe:
		sw_comp_prod = NEXT_RCQ_IDX(sw_comp_prod);
		sw_comp_cons = NEXT_RCQ_IDX(sw_comp_cons);

		if (rx_pkt == budget)
			break;
	} /* while */

	fp->rx_bd_cons = bd_cons;
	fp->rx_bd_prod = bd_prod_fw;
	fp->rx_comp_cons = sw_comp_cons;
	fp->rx_comp_prod = sw_comp_prod;

	/* Update producers */
	bnx2x_update_rx_prod(bp, fp, bd_prod_fw, sw_comp_prod,
			     fp->rx_sge_prod);

	fp->rx_pkt += rx_pkt;
	fp->rx_calls++;

	return rx_pkt;
}

static irqreturn_t bnx2x_msix_fp_int(int irq, void *fp_cookie)
{
	struct bnx2x_fastpath *fp = fp_cookie;
	struct bnx2x *bp = fp->bp;
875
	u8 cos;
D
Dmitry Kravkov 已提交
876

M
Merav Sicron 已提交
877 878
	DP(NETIF_MSG_INTR,
	   "got an MSI-X interrupt on IDX:SB [fp %d fw_sd %d igusb %d]\n",
879 880
	   fp->index, fp->fw_sb_id, fp->igu_sb_id);
	bnx2x_ack_sb(bp, fp->igu_sb_id, USTORM_ID, 0, IGU_INT_DISABLE, 0);
D
Dmitry Kravkov 已提交
881 882 883 884 885 886 887 888

#ifdef BNX2X_STOP_ON_ERROR
	if (unlikely(bp->panic))
		return IRQ_HANDLED;
#endif

	/* Handle Rx and Tx according to MSI-X vector */
	prefetch(fp->rx_cons_sb);
889 890 891 892

	for_each_cos_in_tx_queue(fp, cos)
		prefetch(fp->txdata[cos].tx_cons_sb);

893
	prefetch(&fp->sb_running_index[SM_RX_ID]);
D
Dmitry Kravkov 已提交
894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915
	napi_schedule(&bnx2x_fp(bp, fp->index, napi));

	return IRQ_HANDLED;
}

/* HW Lock for shared dual port PHYs */
void bnx2x_acquire_phy_lock(struct bnx2x *bp)
{
	mutex_lock(&bp->port.phy_mutex);

	if (bp->port.need_hw_lock)
		bnx2x_acquire_hw_lock(bp, HW_LOCK_RESOURCE_MDIO);
}

void bnx2x_release_phy_lock(struct bnx2x *bp)
{
	if (bp->port.need_hw_lock)
		bnx2x_release_hw_lock(bp, HW_LOCK_RESOURCE_MDIO);

	mutex_unlock(&bp->port.phy_mutex);
}

916 917 918 919 920
/* calculates MF speed according to current linespeed and MF configuration */
u16 bnx2x_get_mf_speed(struct bnx2x *bp)
{
	u16 line_speed = bp->link_vars.line_speed;
	if (IS_MF(bp)) {
921 922 923 924 925
		u16 maxCfg = bnx2x_extract_max_cfg(bp,
						   bp->mf_config[BP_VN(bp)]);

		/* Calculate the current MAX line speed limit for the MF
		 * devices
926
		 */
927 928 929
		if (IS_MF_SI(bp))
			line_speed = (line_speed * maxCfg) / 100;
		else { /* SD mode */
930 931 932 933
			u16 vn_max_rate = maxCfg * 100;

			if (vn_max_rate < line_speed)
				line_speed = vn_max_rate;
934
		}
935 936 937 938 939
	}

	return line_speed;
}

940 941 942 943 944 945 946 947
/**
 * bnx2x_fill_report_data - fill link report data to report
 *
 * @bp:		driver handle
 * @data:	link state to update
 *
 * It uses a none-atomic bit operations because is called under the mutex.
 */
E
Eric Dumazet 已提交
948 949
static void bnx2x_fill_report_data(struct bnx2x *bp,
				   struct bnx2x_link_report_data *data)
950 951 952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985
{
	u16 line_speed = bnx2x_get_mf_speed(bp);

	memset(data, 0, sizeof(*data));

	/* Fill the report data: efective line speed */
	data->line_speed = line_speed;

	/* Link is down */
	if (!bp->link_vars.link_up || (bp->flags & MF_FUNC_DIS))
		__set_bit(BNX2X_LINK_REPORT_LINK_DOWN,
			  &data->link_report_flags);

	/* Full DUPLEX */
	if (bp->link_vars.duplex == DUPLEX_FULL)
		__set_bit(BNX2X_LINK_REPORT_FD, &data->link_report_flags);

	/* Rx Flow Control is ON */
	if (bp->link_vars.flow_ctrl & BNX2X_FLOW_CTRL_RX)
		__set_bit(BNX2X_LINK_REPORT_RX_FC_ON, &data->link_report_flags);

	/* Tx Flow Control is ON */
	if (bp->link_vars.flow_ctrl & BNX2X_FLOW_CTRL_TX)
		__set_bit(BNX2X_LINK_REPORT_TX_FC_ON, &data->link_report_flags);
}

/**
 * bnx2x_link_report - report link status to OS.
 *
 * @bp:		driver handle
 *
 * Calls the __bnx2x_link_report() under the same locking scheme
 * as a link/PHY state managing code to ensure a consistent link
 * reporting.
 */

D
Dmitry Kravkov 已提交
986 987
void bnx2x_link_report(struct bnx2x *bp)
{
988 989 990 991
	bnx2x_acquire_phy_lock(bp);
	__bnx2x_link_report(bp);
	bnx2x_release_phy_lock(bp);
}
D
Dmitry Kravkov 已提交
992

993 994 995 996 997 998 999 1000 1001 1002 1003
/**
 * __bnx2x_link_report - report link status to OS.
 *
 * @bp:		driver handle
 *
 * None atomic inmlementation.
 * Should be called under the phy_lock.
 */
void __bnx2x_link_report(struct bnx2x *bp)
{
	struct bnx2x_link_report_data cur_data;
D
Dmitry Kravkov 已提交
1004

1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020
	/* reread mf_cfg */
	if (!CHIP_IS_E1(bp))
		bnx2x_read_mf_cfg(bp);

	/* Read the current link report info */
	bnx2x_fill_report_data(bp, &cur_data);

	/* Don't report link down or exactly the same link status twice */
	if (!memcmp(&cur_data, &bp->last_reported_link, sizeof(cur_data)) ||
	    (test_bit(BNX2X_LINK_REPORT_LINK_DOWN,
		      &bp->last_reported_link.link_report_flags) &&
	     test_bit(BNX2X_LINK_REPORT_LINK_DOWN,
		      &cur_data.link_report_flags)))
		return;

	bp->link_cnt++;
D
Dmitry Kravkov 已提交
1021

1022 1023 1024 1025
	/* We are going to report a new link parameters now -
	 * remember the current data for the next time.
	 */
	memcpy(&bp->last_reported_link, &cur_data, sizeof(cur_data));
D
Dmitry Kravkov 已提交
1026

1027 1028 1029 1030 1031 1032
	if (test_bit(BNX2X_LINK_REPORT_LINK_DOWN,
		     &cur_data.link_report_flags)) {
		netif_carrier_off(bp->dev);
		netdev_err(bp->dev, "NIC Link is Down\n");
		return;
	} else {
1033 1034 1035
		const char *duplex;
		const char *flow;

1036
		netif_carrier_on(bp->dev);
D
Dmitry Kravkov 已提交
1037

1038 1039
		if (test_and_clear_bit(BNX2X_LINK_REPORT_FD,
				       &cur_data.link_report_flags))
1040
			duplex = "full";
D
Dmitry Kravkov 已提交
1041
		else
1042
			duplex = "half";
D
Dmitry Kravkov 已提交
1043

1044 1045 1046 1047 1048 1049 1050 1051 1052
		/* Handle the FC at the end so that only these flags would be
		 * possibly set. This way we may easily check if there is no FC
		 * enabled.
		 */
		if (cur_data.link_report_flags) {
			if (test_bit(BNX2X_LINK_REPORT_RX_FC_ON,
				     &cur_data.link_report_flags)) {
				if (test_bit(BNX2X_LINK_REPORT_TX_FC_ON,
				     &cur_data.link_report_flags))
1053 1054 1055
					flow = "ON - receive & transmit";
				else
					flow = "ON - receive";
D
Dmitry Kravkov 已提交
1056
			} else {
1057
				flow = "ON - transmit";
D
Dmitry Kravkov 已提交
1058
			}
1059 1060
		} else {
			flow = "none";
D
Dmitry Kravkov 已提交
1061
		}
1062 1063
		netdev_info(bp->dev, "NIC Link is Up, %d Mbps %s duplex, Flow control: %s\n",
			    cur_data.line_speed, duplex, flow);
D
Dmitry Kravkov 已提交
1064 1065 1066
	}
}

E
Eric Dumazet 已提交
1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 1106 1107
static void bnx2x_set_next_page_sgl(struct bnx2x_fastpath *fp)
{
	int i;

	for (i = 1; i <= NUM_RX_SGE_PAGES; i++) {
		struct eth_rx_sge *sge;

		sge = &fp->rx_sge_ring[RX_SGE_CNT * i - 2];
		sge->addr_hi =
			cpu_to_le32(U64_HI(fp->rx_sge_mapping +
			BCM_PAGE_SIZE*(i % NUM_RX_SGE_PAGES)));

		sge->addr_lo =
			cpu_to_le32(U64_LO(fp->rx_sge_mapping +
			BCM_PAGE_SIZE*(i % NUM_RX_SGE_PAGES)));
	}
}

static void bnx2x_free_tpa_pool(struct bnx2x *bp,
				struct bnx2x_fastpath *fp, int last)
{
	int i;

	for (i = 0; i < last; i++) {
		struct bnx2x_agg_info *tpa_info = &fp->tpa_info[i];
		struct sw_rx_bd *first_buf = &tpa_info->first_buf;
		u8 *data = first_buf->data;

		if (data == NULL) {
			DP(NETIF_MSG_IFDOWN, "tpa bin %d empty on free\n", i);
			continue;
		}
		if (tpa_info->tpa_state == BNX2X_TPA_START)
			dma_unmap_single(&bp->pdev->dev,
					 dma_unmap_addr(first_buf, mapping),
					 fp->rx_buf_size, DMA_FROM_DEVICE);
		kfree(data);
		first_buf->data = NULL;
	}
}

D
Dmitry Kravkov 已提交
1108 1109 1110
void bnx2x_init_rx_rings(struct bnx2x *bp)
{
	int func = BP_FUNC(bp);
1111
	u16 ring_prod;
D
Dmitry Kravkov 已提交
1112
	int i, j;
1113

1114
	/* Allocate TPA resources */
V
Vladislav Zolotarov 已提交
1115
	for_each_rx_queue(bp, j) {
1116
		struct bnx2x_fastpath *fp = &bp->fp[j];
D
Dmitry Kravkov 已提交
1117

1118 1119 1120
		DP(NETIF_MSG_IFUP,
		   "mtu %d  rx_buf_size %d\n", bp->dev->mtu, fp->rx_buf_size);

1121
		if (!fp->disable_tpa) {
1122
			/* Fill the per-aggregtion pool */
1123
			for (i = 0; i < MAX_AGG_QS(bp); i++) {
1124 1125 1126 1127 1128
				struct bnx2x_agg_info *tpa_info =
					&fp->tpa_info[i];
				struct sw_rx_bd *first_buf =
					&tpa_info->first_buf;

1129 1130 1131
				first_buf->data = kmalloc(fp->rx_buf_size + NET_SKB_PAD,
							  GFP_ATOMIC);
				if (!first_buf->data) {
M
Merav Sicron 已提交
1132 1133
					BNX2X_ERR("Failed to allocate TPA skb pool for queue[%d] - disabling TPA on this queue!\n",
						  j);
D
Dmitry Kravkov 已提交
1134 1135 1136 1137
					bnx2x_free_tpa_pool(bp, fp, i);
					fp->disable_tpa = 1;
					break;
				}
1138 1139
				dma_unmap_addr_set(first_buf, mapping, 0);
				tpa_info->tpa_state = BNX2X_TPA_STOP;
D
Dmitry Kravkov 已提交
1140
			}
1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152

			/* "next page" elements initialization */
			bnx2x_set_next_page_sgl(fp);

			/* set SGEs bit mask */
			bnx2x_init_sge_ring_bit_mask(fp);

			/* Allocate SGEs and initialize the ring elements */
			for (i = 0, ring_prod = 0;
			     i < MAX_RX_SGE_CNT*NUM_RX_SGE_PAGES; i++) {

				if (bnx2x_alloc_rx_sge(bp, fp, ring_prod) < 0) {
M
Merav Sicron 已提交
1153 1154 1155 1156
					BNX2X_ERR("was only able to allocate %d rx sges\n",
						  i);
					BNX2X_ERR("disabling TPA for queue[%d]\n",
						  j);
1157
					/* Cleanup already allocated elements */
1158 1159 1160
					bnx2x_free_rx_sge_range(bp, fp,
								ring_prod);
					bnx2x_free_tpa_pool(bp, fp,
1161
							    MAX_AGG_QS(bp));
1162 1163 1164 1165 1166 1167 1168 1169
					fp->disable_tpa = 1;
					ring_prod = 0;
					break;
				}
				ring_prod = NEXT_SGE_IDX(ring_prod);
			}

			fp->rx_sge_prod = ring_prod;
D
Dmitry Kravkov 已提交
1170 1171 1172
		}
	}

V
Vladislav Zolotarov 已提交
1173
	for_each_rx_queue(bp, j) {
D
Dmitry Kravkov 已提交
1174 1175 1176 1177
		struct bnx2x_fastpath *fp = &bp->fp[j];

		fp->rx_bd_cons = 0;

1178 1179 1180 1181 1182 1183 1184
		/* Activate BD ring */
		/* Warning!
		 * this will generate an interrupt (to the TSTORM)
		 * must only be done after chip is initialized
		 */
		bnx2x_update_rx_prod(bp, fp, fp->rx_bd_prod, fp->rx_comp_prod,
				     fp->rx_sge_prod);
D
Dmitry Kravkov 已提交
1185 1186 1187 1188

		if (j != 0)
			continue;

1189
		if (CHIP_IS_E1(bp)) {
D
Dmitry Kravkov 已提交
1190 1191 1192 1193 1194 1195 1196
			REG_WR(bp, BAR_USTRORM_INTMEM +
			       USTORM_MEM_WORKAROUND_ADDRESS_OFFSET(func),
			       U64_LO(fp->rx_comp_mapping));
			REG_WR(bp, BAR_USTRORM_INTMEM +
			       USTORM_MEM_WORKAROUND_ADDRESS_OFFSET(func) + 4,
			       U64_HI(fp->rx_comp_mapping));
		}
D
Dmitry Kravkov 已提交
1197 1198
	}
}
D
Dmitry Kravkov 已提交
1199

D
Dmitry Kravkov 已提交
1200 1201 1202
static void bnx2x_free_tx_skbs(struct bnx2x *bp)
{
	int i;
1203
	u8 cos;
D
Dmitry Kravkov 已提交
1204

V
Vladislav Zolotarov 已提交
1205
	for_each_tx_queue(bp, i) {
D
Dmitry Kravkov 已提交
1206
		struct bnx2x_fastpath *fp = &bp->fp[i];
1207 1208
		for_each_cos_in_tx_queue(fp, cos) {
			struct bnx2x_fp_txdata *txdata = &fp->txdata[cos];
T
Tom Herbert 已提交
1209
			unsigned pkts_compl = 0, bytes_compl = 0;
D
Dmitry Kravkov 已提交
1210

1211 1212
			u16 sw_prod = txdata->tx_pkt_prod;
			u16 sw_cons = txdata->tx_pkt_cons;
D
Dmitry Kravkov 已提交
1213

1214
			while (sw_cons != sw_prod) {
T
Tom Herbert 已提交
1215 1216
				bnx2x_free_tx_pkt(bp, txdata, TX_BD(sw_cons),
				    &pkts_compl, &bytes_compl);
1217 1218
				sw_cons++;
			}
T
Tom Herbert 已提交
1219 1220
			netdev_tx_reset_queue(
			    netdev_get_tx_queue(bp->dev, txdata->txq_index));
D
Dmitry Kravkov 已提交
1221 1222 1223 1224
		}
	}
}

1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235
static void bnx2x_free_rx_bds(struct bnx2x_fastpath *fp)
{
	struct bnx2x *bp = fp->bp;
	int i;

	/* ring wasn't allocated */
	if (fp->rx_buf_ring == NULL)
		return;

	for (i = 0; i < NUM_RX_BD; i++) {
		struct sw_rx_bd *rx_buf = &fp->rx_buf_ring[i];
1236
		u8 *data = rx_buf->data;
1237

1238
		if (data == NULL)
1239 1240 1241 1242 1243
			continue;
		dma_unmap_single(&bp->pdev->dev,
				 dma_unmap_addr(rx_buf, mapping),
				 fp->rx_buf_size, DMA_FROM_DEVICE);

1244 1245
		rx_buf->data = NULL;
		kfree(data);
1246 1247 1248
	}
}

D
Dmitry Kravkov 已提交
1249 1250
static void bnx2x_free_rx_skbs(struct bnx2x *bp)
{
1251
	int j;
D
Dmitry Kravkov 已提交
1252

V
Vladislav Zolotarov 已提交
1253
	for_each_rx_queue(bp, j) {
D
Dmitry Kravkov 已提交
1254 1255
		struct bnx2x_fastpath *fp = &bp->fp[j];

1256
		bnx2x_free_rx_bds(fp);
D
Dmitry Kravkov 已提交
1257 1258

		if (!fp->disable_tpa)
1259
			bnx2x_free_tpa_pool(bp, fp, MAX_AGG_QS(bp));
D
Dmitry Kravkov 已提交
1260 1261 1262 1263 1264 1265 1266 1267 1268
	}
}

void bnx2x_free_skbs(struct bnx2x *bp)
{
	bnx2x_free_tx_skbs(bp);
	bnx2x_free_rx_skbs(bp);
}

1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285
void bnx2x_update_max_mf_config(struct bnx2x *bp, u32 value)
{
	/* load old values */
	u32 mf_cfg = bp->mf_config[BP_VN(bp)];

	if (value != bnx2x_extract_max_cfg(bp, mf_cfg)) {
		/* leave all but MAX value */
		mf_cfg &= ~FUNC_MF_CFG_MAX_BW_MASK;

		/* set new MAX value */
		mf_cfg |= (value << FUNC_MF_CFG_MAX_BW_SHIFT)
				& FUNC_MF_CFG_MAX_BW_MASK;

		bnx2x_fw_command(bp, DRV_MSG_CODE_SET_MF_BW, mf_cfg);
	}
}

1286 1287 1288 1289 1290 1291 1292
/**
 * bnx2x_free_msix_irqs - free previously requested MSI-X IRQ vectors
 *
 * @bp:		driver handle
 * @nvecs:	number of vectors to be released
 */
static void bnx2x_free_msix_irqs(struct bnx2x *bp, int nvecs)
D
Dmitry Kravkov 已提交
1293
{
1294
	int i, offset = 0;
D
Dmitry Kravkov 已提交
1295

1296 1297 1298
	if (nvecs == offset)
		return;
	free_irq(bp->msix_table[offset].vector, bp->dev);
D
Dmitry Kravkov 已提交
1299
	DP(NETIF_MSG_IFDOWN, "released sp irq (%d)\n",
1300 1301
	   bp->msix_table[offset].vector);
	offset++;
D
Dmitry Kravkov 已提交
1302
#ifdef BCM_CNIC
1303 1304
	if (nvecs == offset)
		return;
D
Dmitry Kravkov 已提交
1305 1306
	offset++;
#endif
1307

V
Vladislav Zolotarov 已提交
1308
	for_each_eth_queue(bp, i) {
1309 1310
		if (nvecs == offset)
			return;
M
Merav Sicron 已提交
1311 1312
		DP(NETIF_MSG_IFDOWN, "about to release fp #%d->%d irq\n",
		   i, bp->msix_table[offset].vector);
D
Dmitry Kravkov 已提交
1313

1314
		free_irq(bp->msix_table[offset++].vector, &bp->fp[i]);
D
Dmitry Kravkov 已提交
1315 1316 1317
	}
}

1318
void bnx2x_free_irq(struct bnx2x *bp)
D
Dmitry Kravkov 已提交
1319
{
1320 1321
	if (bp->flags & USING_MSIX_FLAG &&
	    !(bp->flags & USING_SINGLE_MSIX_FLAG))
1322
		bnx2x_free_msix_irqs(bp, BNX2X_NUM_ETH_QUEUES(bp) +
1323
				     CNIC_PRESENT + 1);
1324
	else
1325
		free_irq(bp->dev->irq, bp->dev);
D
Dmitry Kravkov 已提交
1326 1327
}

1328
int __devinit bnx2x_enable_msix(struct bnx2x *bp)
D
Dmitry Kravkov 已提交
1329
{
1330
	int msix_vec = 0, i, rc, req_cnt;
D
Dmitry Kravkov 已提交
1331

1332
	bp->msix_table[msix_vec].entry = msix_vec;
M
Merav Sicron 已提交
1333
	BNX2X_DEV_INFO("msix_table[0].entry = %d (slowpath)\n",
1334 1335
	   bp->msix_table[0].entry);
	msix_vec++;
D
Dmitry Kravkov 已提交
1336 1337

#ifdef BCM_CNIC
1338
	bp->msix_table[msix_vec].entry = msix_vec;
M
Merav Sicron 已提交
1339
	BNX2X_DEV_INFO("msix_table[%d].entry = %d (CNIC)\n",
1340 1341
	   bp->msix_table[msix_vec].entry, bp->msix_table[msix_vec].entry);
	msix_vec++;
D
Dmitry Kravkov 已提交
1342
#endif
1343
	/* We need separate vectors for ETH queues only (not FCoE) */
V
Vladislav Zolotarov 已提交
1344
	for_each_eth_queue(bp, i) {
1345
		bp->msix_table[msix_vec].entry = msix_vec;
M
Merav Sicron 已提交
1346 1347
		BNX2X_DEV_INFO("msix_table[%d].entry = %d (fastpath #%u)\n",
			       msix_vec, msix_vec, i);
1348
		msix_vec++;
D
Dmitry Kravkov 已提交
1349 1350
	}

1351
	req_cnt = BNX2X_NUM_ETH_QUEUES(bp) + CNIC_PRESENT + 1;
1352 1353

	rc = pci_enable_msix(bp->pdev, &bp->msix_table[0], req_cnt);
D
Dmitry Kravkov 已提交
1354 1355 1356 1357 1358 1359

	/*
	 * reconfigure number of tx/rx queues according to available
	 * MSI-X vectors
	 */
	if (rc >= BNX2X_MIN_MSIX_VEC_CNT) {
1360 1361
		/* how less vectors we will have? */
		int diff = req_cnt - rc;
D
Dmitry Kravkov 已提交
1362

M
Merav Sicron 已提交
1363
		BNX2X_DEV_INFO("Trying to use less MSI-X vectors: %d\n", rc);
D
Dmitry Kravkov 已提交
1364 1365 1366 1367

		rc = pci_enable_msix(bp->pdev, &bp->msix_table[0], rc);

		if (rc) {
1368 1369
			BNX2X_DEV_INFO("MSI-X is not attainable rc %d\n", rc);
			goto no_msix;
D
Dmitry Kravkov 已提交
1370
		}
1371 1372 1373 1374
		/*
		 * decrease number of queues by number of unallocated entries
		 */
		bp->num_queues -= diff;
D
Dmitry Kravkov 已提交
1375

M
Merav Sicron 已提交
1376
		BNX2X_DEV_INFO("New queue configuration set: %d\n",
1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390
			       bp->num_queues);
	} else if (rc > 0) {
		/* Get by with single vector */
		rc = pci_enable_msix(bp->pdev, &bp->msix_table[0], 1);
		if (rc) {
			BNX2X_DEV_INFO("Single MSI-X is not attainable rc %d\n",
				       rc);
			goto no_msix;
		}

		BNX2X_DEV_INFO("Using single MSI-X vector\n");
		bp->flags |= USING_SINGLE_MSIX_FLAG;

	} else if (rc < 0) {
M
Merav Sicron 已提交
1391
		BNX2X_DEV_INFO("MSI-X is not attainable  rc %d\n", rc);
1392
		goto no_msix;
D
Dmitry Kravkov 已提交
1393 1394 1395 1396 1397
	}

	bp->flags |= USING_MSIX_FLAG;

	return 0;
1398 1399 1400 1401 1402 1403 1404

no_msix:
	/* fall to INTx if not enough memory */
	if (rc == -ENOMEM)
		bp->flags |= DISABLE_MSI_FLAG;

	return rc;
D
Dmitry Kravkov 已提交
1405 1406 1407 1408
}

static int bnx2x_req_msix_irqs(struct bnx2x *bp)
{
1409
	int i, rc, offset = 0;
D
Dmitry Kravkov 已提交
1410

1411 1412
	rc = request_irq(bp->msix_table[offset++].vector,
			 bnx2x_msix_sp_int, 0,
D
Dmitry Kravkov 已提交
1413 1414 1415 1416 1417 1418 1419 1420 1421
			 bp->dev->name, bp->dev);
	if (rc) {
		BNX2X_ERR("request sp irq failed\n");
		return -EBUSY;
	}

#ifdef BCM_CNIC
	offset++;
#endif
V
Vladislav Zolotarov 已提交
1422
	for_each_eth_queue(bp, i) {
D
Dmitry Kravkov 已提交
1423 1424 1425 1426
		struct bnx2x_fastpath *fp = &bp->fp[i];
		snprintf(fp->name, sizeof(fp->name), "%s-fp-%d",
			 bp->dev->name, i);

1427
		rc = request_irq(bp->msix_table[offset].vector,
D
Dmitry Kravkov 已提交
1428 1429
				 bnx2x_msix_fp_int, 0, fp->name, fp);
		if (rc) {
1430 1431 1432
			BNX2X_ERR("request fp #%d irq (%d) failed  rc %d\n", i,
			      bp->msix_table[offset].vector, rc);
			bnx2x_free_msix_irqs(bp, offset);
D
Dmitry Kravkov 已提交
1433 1434 1435
			return -EBUSY;
		}

1436
		offset++;
D
Dmitry Kravkov 已提交
1437 1438
	}

V
Vladislav Zolotarov 已提交
1439
	i = BNX2X_NUM_ETH_QUEUES(bp);
1440
	offset = 1 + CNIC_PRESENT;
M
Merav Sicron 已提交
1441
	netdev_info(bp->dev, "using MSI-X  IRQs: sp %d  fp[%d] %d ... fp[%d] %d\n",
D
Dmitry Kravkov 已提交
1442 1443 1444 1445 1446 1447 1448
	       bp->msix_table[0].vector,
	       0, bp->msix_table[offset].vector,
	       i - 1, bp->msix_table[offset + i - 1].vector);

	return 0;
}

1449
int bnx2x_enable_msi(struct bnx2x *bp)
D
Dmitry Kravkov 已提交
1450 1451 1452 1453 1454
{
	int rc;

	rc = pci_enable_msi(bp->pdev);
	if (rc) {
M
Merav Sicron 已提交
1455
		BNX2X_DEV_INFO("MSI is not attainable\n");
D
Dmitry Kravkov 已提交
1456 1457 1458 1459 1460 1461 1462 1463 1464 1465
		return -1;
	}
	bp->flags |= USING_MSI_FLAG;

	return 0;
}

static int bnx2x_req_irq(struct bnx2x *bp)
{
	unsigned long flags;
1466
	unsigned int irq;
D
Dmitry Kravkov 已提交
1467

1468
	if (bp->flags & (USING_MSI_FLAG | USING_MSIX_FLAG))
D
Dmitry Kravkov 已提交
1469 1470 1471 1472
		flags = 0;
	else
		flags = IRQF_SHARED;

1473 1474 1475 1476 1477 1478
	if (bp->flags & USING_MSIX_FLAG)
		irq = bp->msix_table[0].vector;
	else
		irq = bp->pdev->irq;

	return request_irq(irq, bnx2x_interrupt, flags, bp->dev->name, bp->dev);
D
Dmitry Kravkov 已提交
1479 1480
}

E
Eric Dumazet 已提交
1481
static int bnx2x_setup_irqs(struct bnx2x *bp)
1482 1483
{
	int rc = 0;
1484 1485
	if (bp->flags & USING_MSIX_FLAG &&
	    !(bp->flags & USING_SINGLE_MSIX_FLAG)) {
1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496 1497
		rc = bnx2x_req_msix_irqs(bp);
		if (rc)
			return rc;
	} else {
		bnx2x_ack_int(bp);
		rc = bnx2x_req_irq(bp);
		if (rc) {
			BNX2X_ERR("IRQ request failed  rc %d, aborting\n", rc);
			return rc;
		}
		if (bp->flags & USING_MSI_FLAG) {
			bp->dev->irq = bp->pdev->irq;
1498 1499 1500 1501 1502 1503 1504
			netdev_info(bp->dev, "using MSI IRQ %d\n",
				    bp->dev->irq);
		}
		if (bp->flags & USING_MSIX_FLAG) {
			bp->dev->irq = bp->msix_table[0].vector;
			netdev_info(bp->dev, "using MSIX IRQ %d\n",
				    bp->dev->irq);
1505 1506 1507 1508 1509 1510
		}
	}

	return 0;
}

E
Eric Dumazet 已提交
1511
static void bnx2x_napi_enable(struct bnx2x *bp)
D
Dmitry Kravkov 已提交
1512 1513 1514
{
	int i;

1515
	for_each_rx_queue(bp, i)
D
Dmitry Kravkov 已提交
1516 1517 1518
		napi_enable(&bnx2x_fp(bp, i, napi));
}

E
Eric Dumazet 已提交
1519
static void bnx2x_napi_disable(struct bnx2x *bp)
D
Dmitry Kravkov 已提交
1520 1521 1522
{
	int i;

1523
	for_each_rx_queue(bp, i)
D
Dmitry Kravkov 已提交
1524 1525 1526 1527 1528
		napi_disable(&bnx2x_fp(bp, i, napi));
}

void bnx2x_netif_start(struct bnx2x *bp)
{
1529 1530 1531 1532 1533
	if (netif_running(bp->dev)) {
		bnx2x_napi_enable(bp);
		bnx2x_int_enable(bp);
		if (bp->state == BNX2X_STATE_OPEN)
			netif_tx_wake_all_queues(bp->dev);
D
Dmitry Kravkov 已提交
1534 1535 1536 1537 1538 1539 1540 1541 1542
	}
}

void bnx2x_netif_stop(struct bnx2x *bp, int disable_hw)
{
	bnx2x_int_disable_sync(bp, disable_hw);
	bnx2x_napi_disable(bp);
}

1543 1544 1545
u16 bnx2x_select_queue(struct net_device *dev, struct sk_buff *skb)
{
	struct bnx2x *bp = netdev_priv(dev);
1546

1547
#ifdef BCM_CNIC
1548
	if (!NO_FCOE(bp)) {
1549 1550 1551 1552 1553 1554 1555 1556 1557 1558 1559 1560 1561
		struct ethhdr *hdr = (struct ethhdr *)skb->data;
		u16 ether_type = ntohs(hdr->h_proto);

		/* Skip VLAN tag if present */
		if (ether_type == ETH_P_8021Q) {
			struct vlan_ethhdr *vhdr =
				(struct vlan_ethhdr *)skb->data;

			ether_type = ntohs(vhdr->h_vlan_encapsulated_proto);
		}

		/* If ethertype is FCoE or FIP - use FCoE ring */
		if ((ether_type == ETH_P_FCOE) || (ether_type == ETH_P_FIP))
1562
			return bnx2x_fcoe_tx(bp, txq_index);
1563 1564
	}
#endif
1565
	/* select a non-FCoE queue */
1566
	return __skb_tx_hash(dev, skb, BNX2X_NUM_ETH_QUEUES(bp));
1567 1568
}

D
Dmitry Kravkov 已提交
1569

1570 1571
void bnx2x_set_num_queues(struct bnx2x *bp)
{
D
Dmitry Kravkov 已提交
1572 1573
	/* RSS queues */
	bp->num_queues = bnx2x_calc_num_queues(bp);
V
Vladislav Zolotarov 已提交
1574

D
Dmitry Kravkov 已提交
1575
#ifdef BCM_CNIC
B
Barak Witkowski 已提交
1576 1577
	/* override in STORAGE SD modes */
	if (IS_MF_STORAGE_SD(bp) || IS_MF_FCOE_AFEX(bp))
D
Dmitry Kravkov 已提交
1578 1579
		bp->num_queues = 1;
#endif
V
Vladislav Zolotarov 已提交
1580
	/* Add special queues */
1581
	bp->num_queues += NON_ETH_CONTEXT_USE;
V
Vladislav Zolotarov 已提交
1582 1583
}

1584 1585 1586 1587 1588 1589 1590 1591 1592 1593 1594 1595 1596 1597 1598 1599 1600 1601 1602 1603 1604 1605
/**
 * bnx2x_set_real_num_queues - configure netdev->real_num_[tx,rx]_queues
 *
 * @bp:		Driver handle
 *
 * We currently support for at most 16 Tx queues for each CoS thus we will
 * allocate a multiple of 16 for ETH L2 rings according to the value of the
 * bp->max_cos.
 *
 * If there is an FCoE L2 queue the appropriate Tx queue will have the next
 * index after all ETH L2 indices.
 *
 * If the actual number of Tx queues (for each CoS) is less than 16 then there
 * will be the holes at the end of each group of 16 ETh L2 indices (0..15,
 * 16..31,...) with indicies that are not coupled with any real Tx queue.
 *
 * The proper configuration of skb->queue_mapping is handled by
 * bnx2x_select_queue() and __skb_tx_hash().
 *
 * bnx2x_setup_tc() takes care of the proper TC mappings so that __skb_tx_hash()
 * will return a proper Tx index if TC is enabled (netdev->num_tc > 0).
 */
E
Eric Dumazet 已提交
1606
static int bnx2x_set_real_num_queues(struct bnx2x *bp)
V
Vladislav Zolotarov 已提交
1607
{
1608
	int rc, tx, rx;
V
Vladislav Zolotarov 已提交
1609

1610 1611
	tx = MAX_TXQS_PER_COS * bp->max_cos;
	rx = BNX2X_NUM_ETH_QUEUES(bp);
V
Vladislav Zolotarov 已提交
1612

1613 1614 1615 1616 1617 1618
/* account for fcoe queue */
#ifdef BCM_CNIC
	if (!NO_FCOE(bp)) {
		rx += FCOE_PRESENT;
		tx += FCOE_PRESENT;
	}
V
Vladislav Zolotarov 已提交
1619
#endif
1620 1621 1622 1623 1624 1625 1626 1627 1628 1629 1630 1631

	rc = netif_set_real_num_tx_queues(bp->dev, tx);
	if (rc) {
		BNX2X_ERR("Failed to set real number of Tx queues: %d\n", rc);
		return rc;
	}
	rc = netif_set_real_num_rx_queues(bp->dev, rx);
	if (rc) {
		BNX2X_ERR("Failed to set real number of Rx queues: %d\n", rc);
		return rc;
	}

M
Merav Sicron 已提交
1632
	DP(NETIF_MSG_IFUP, "Setting real num queues to (tx, rx) (%d, %d)\n",
1633 1634
			  tx, rx);

V
Vladislav Zolotarov 已提交
1635 1636 1637
	return rc;
}

E
Eric Dumazet 已提交
1638
static void bnx2x_set_rx_buf_size(struct bnx2x *bp)
1639 1640 1641 1642 1643
{
	int i;

	for_each_queue(bp, i) {
		struct bnx2x_fastpath *fp = &bp->fp[i];
1644
		u32 mtu;
1645 1646 1647 1648 1649 1650 1651 1652 1653

		/* Always use a mini-jumbo MTU for the FCoE L2 ring */
		if (IS_FCOE_IDX(i))
			/*
			 * Although there are no IP frames expected to arrive to
			 * this ring we still want to add an
			 * IP_HEADER_ALIGNMENT_PADDING to prevent a buffer
			 * overrun attack.
			 */
1654
			mtu = BNX2X_FCOE_MINI_JUMBO_MTU;
1655
		else
1656 1657 1658 1659 1660 1661 1662
			mtu = bp->dev->mtu;
		fp->rx_buf_size = BNX2X_FW_RX_ALIGN_START +
				  IP_HEADER_ALIGNMENT_PADDING +
				  ETH_OVREHEAD +
				  mtu +
				  BNX2X_FW_RX_ALIGN_END;
		/* Note : rx_buf_size doesnt take into account NET_SKB_PAD */
1663 1664 1665
	}
}

E
Eric Dumazet 已提交
1666
static int bnx2x_init_rss_pf(struct bnx2x *bp)
1667 1668 1669 1670 1671
{
	int i;
	u8 ind_table[T_ETH_INDIRECTION_TABLE_SIZE] = {0};
	u8 num_eth_queues = BNX2X_NUM_ETH_QUEUES(bp);

D
Dmitry Kravkov 已提交
1672
	/* Prepare the initial contents fo the indirection table if RSS is
1673 1674
	 * enabled
	 */
D
Dmitry Kravkov 已提交
1675 1676 1677 1678
	for (i = 0; i < sizeof(ind_table); i++)
		ind_table[i] =
			bp->fp->cl_id +
			ethtool_rxfh_indir_default(i, num_eth_queues);
1679 1680 1681 1682 1683 1684 1685 1686 1687

	/*
	 * For 57710 and 57711 SEARCHER configuration (rss_keys) is
	 * per-port, so if explicit configuration is needed , do it only
	 * for a PMF.
	 *
	 * For 57712 and newer on the other hand it's a per-function
	 * configuration.
	 */
D
Dmitry Kravkov 已提交
1688 1689
	return bnx2x_config_rss_eth(bp, ind_table,
				    bp->port.pmf || !CHIP_IS_E1x(bp));
1690 1691
}

D
Dmitry Kravkov 已提交
1692 1693
int bnx2x_config_rss_pf(struct bnx2x *bp, struct bnx2x_rss_config_obj *rss_obj,
			u8 *ind_table, bool config_hash)
1694
{
Y
Yuval Mintz 已提交
1695
	struct bnx2x_config_rss_params params = {NULL};
1696 1697 1698 1699 1700 1701 1702 1703 1704
	int i;

	/* Although RSS is meaningless when there is a single HW queue we
	 * still need it enabled in order to have HW Rx hash generated.
	 *
	 * if (!is_eth_multi(bp))
	 *      bp->multi_mode = ETH_RSS_MODE_DISABLED;
	 */

D
Dmitry Kravkov 已提交
1705
	params.rss_obj = rss_obj;
1706 1707 1708

	__set_bit(RAMROD_COMP_WAIT, &params.ramrod_flags);

D
Dmitry Kravkov 已提交
1709
	__set_bit(BNX2X_RSS_MODE_REGULAR, &params.rss_flags);
1710

D
Dmitry Kravkov 已提交
1711 1712 1713 1714 1715
	/* RSS configuration */
	__set_bit(BNX2X_RSS_IPV4, &params.rss_flags);
	__set_bit(BNX2X_RSS_IPV4_TCP, &params.rss_flags);
	__set_bit(BNX2X_RSS_IPV6, &params.rss_flags);
	__set_bit(BNX2X_RSS_IPV6_TCP, &params.rss_flags);
1716

D
Dmitry Kravkov 已提交
1717 1718
	/* Hash bits */
	params.rss_result_mask = MULTI_MASK;
1719

D
Dmitry Kravkov 已提交
1720
	memcpy(params.ind_table, ind_table, sizeof(params.ind_table));
1721

D
Dmitry Kravkov 已提交
1722 1723 1724 1725
	if (config_hash) {
		/* RSS keys */
		for (i = 0; i < sizeof(params.rss_key) / 4; i++)
			params.rss_key[i] = random32();
1726

D
Dmitry Kravkov 已提交
1727
		__set_bit(BNX2X_RSS_SET_SRCH, &params.rss_flags);
1728 1729 1730 1731 1732
	}

	return bnx2x_config_rss(bp, &params);
}

E
Eric Dumazet 已提交
1733
static int bnx2x_init_hw(struct bnx2x *bp, u32 load_code)
1734
{
Y
Yuval Mintz 已提交
1735
	struct bnx2x_func_state_params func_params = {NULL};
1736 1737 1738 1739 1740 1741 1742 1743 1744 1745 1746 1747 1748 1749 1750 1751 1752 1753 1754 1755

	/* Prepare parameters for function state transitions */
	__set_bit(RAMROD_COMP_WAIT, &func_params.ramrod_flags);

	func_params.f_obj = &bp->func_obj;
	func_params.cmd = BNX2X_F_CMD_HW_INIT;

	func_params.params.hw_init.load_phase = load_code;

	return bnx2x_func_state_change(bp, &func_params);
}

/*
 * Cleans the object that have internal lists without sending
 * ramrods. Should be run when interrutps are disabled.
 */
static void bnx2x_squeeze_objects(struct bnx2x *bp)
{
	int rc;
	unsigned long ramrod_flags = 0, vlan_mac_flags = 0;
Y
Yuval Mintz 已提交
1756
	struct bnx2x_mcast_ramrod_params rparam = {NULL};
1757 1758 1759 1760 1761 1762 1763 1764 1765 1766 1767 1768 1769 1770 1771 1772 1773 1774 1775 1776 1777 1778 1779 1780 1781 1782 1783 1784 1785 1786 1787
	struct bnx2x_vlan_mac_obj *mac_obj = &bp->fp->mac_obj;

	/***************** Cleanup MACs' object first *************************/

	/* Wait for completion of requested */
	__set_bit(RAMROD_COMP_WAIT, &ramrod_flags);
	/* Perform a dry cleanup */
	__set_bit(RAMROD_DRV_CLR_ONLY, &ramrod_flags);

	/* Clean ETH primary MAC */
	__set_bit(BNX2X_ETH_MAC, &vlan_mac_flags);
	rc = mac_obj->delete_all(bp, &bp->fp->mac_obj, &vlan_mac_flags,
				 &ramrod_flags);
	if (rc != 0)
		BNX2X_ERR("Failed to clean ETH MACs: %d\n", rc);

	/* Cleanup UC list */
	vlan_mac_flags = 0;
	__set_bit(BNX2X_UC_LIST_MAC, &vlan_mac_flags);
	rc = mac_obj->delete_all(bp, mac_obj, &vlan_mac_flags,
				 &ramrod_flags);
	if (rc != 0)
		BNX2X_ERR("Failed to clean UC list MACs: %d\n", rc);

	/***************** Now clean mcast object *****************************/
	rparam.mcast_obj = &bp->mcast_obj;
	__set_bit(RAMROD_DRV_CLR_ONLY, &rparam.ramrod_flags);

	/* Add a DEL command... */
	rc = bnx2x_config_mcast(bp, &rparam, BNX2X_MCAST_CMD_DEL);
	if (rc < 0)
M
Merav Sicron 已提交
1788 1789
		BNX2X_ERR("Failed to add a new DEL command to a multi-cast object: %d\n",
			  rc);
1790 1791 1792 1793 1794 1795 1796 1797 1798 1799 1800 1801 1802 1803 1804 1805 1806 1807 1808 1809 1810 1811 1812 1813 1814 1815 1816 1817 1818

	/* ...and wait until all pending commands are cleared */
	rc = bnx2x_config_mcast(bp, &rparam, BNX2X_MCAST_CMD_CONT);
	while (rc != 0) {
		if (rc < 0) {
			BNX2X_ERR("Failed to clean multi-cast object: %d\n",
				  rc);
			return;
		}

		rc = bnx2x_config_mcast(bp, &rparam, BNX2X_MCAST_CMD_CONT);
	}
}

#ifndef BNX2X_STOP_ON_ERROR
#define LOAD_ERROR_EXIT(bp, label) \
	do { \
		(bp)->state = BNX2X_STATE_ERROR; \
		goto label; \
	} while (0)
#else
#define LOAD_ERROR_EXIT(bp, label) \
	do { \
		(bp)->state = BNX2X_STATE_ERROR; \
		(bp)->panic = 1; \
		return -EBUSY; \
	} while (0)
#endif

1819 1820 1821 1822 1823 1824 1825 1826 1827 1828 1829 1830 1831 1832 1833 1834 1835 1836 1837 1838 1839 1840 1841
bool bnx2x_test_firmware_version(struct bnx2x *bp, bool is_err)
{
	/* build FW version dword */
	u32 my_fw = (BCM_5710_FW_MAJOR_VERSION) +
		    (BCM_5710_FW_MINOR_VERSION << 8) +
		    (BCM_5710_FW_REVISION_VERSION << 16) +
		    (BCM_5710_FW_ENGINEERING_VERSION << 24);

	/* read loaded FW from chip */
	u32 loaded_fw = REG_RD(bp, XSEM_REG_PRAM);

	DP(NETIF_MSG_IFUP, "loaded fw %x, my fw %x\n", loaded_fw, my_fw);

	if (loaded_fw != my_fw) {
		if (is_err)
			BNX2X_ERR("bnx2x with FW %x was already loaded, which mismatches my %x FW. aborting\n",
				  loaded_fw, my_fw);
		return false;
	}

	return true;
}

E
Eric Dumazet 已提交
1842 1843 1844 1845 1846 1847 1848 1849 1850 1851 1852 1853 1854 1855 1856 1857 1858 1859 1860 1861 1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872 1873 1874 1875 1876 1877 1878 1879 1880 1881 1882 1883 1884 1885 1886 1887 1888 1889 1890 1891 1892 1893 1894 1895 1896 1897 1898 1899 1900 1901 1902 1903 1904 1905 1906 1907 1908 1909 1910 1911 1912 1913 1914 1915 1916 1917 1918 1919 1920 1921 1922
/**
 * bnx2x_bz_fp - zero content of the fastpath structure.
 *
 * @bp:		driver handle
 * @index:	fastpath index to be zeroed
 *
 * Makes sure the contents of the bp->fp[index].napi is kept
 * intact.
 */
static void bnx2x_bz_fp(struct bnx2x *bp, int index)
{
	struct bnx2x_fastpath *fp = &bp->fp[index];
	struct napi_struct orig_napi = fp->napi;
	/* bzero bnx2x_fastpath contents */
	if (bp->stats_init)
		memset(fp, 0, sizeof(*fp));
	else {
		/* Keep Queue statistics */
		struct bnx2x_eth_q_stats *tmp_eth_q_stats;
		struct bnx2x_eth_q_stats_old *tmp_eth_q_stats_old;

		tmp_eth_q_stats = kzalloc(sizeof(struct bnx2x_eth_q_stats),
					  GFP_KERNEL);
		if (tmp_eth_q_stats)
			memcpy(tmp_eth_q_stats, &fp->eth_q_stats,
			       sizeof(struct bnx2x_eth_q_stats));

		tmp_eth_q_stats_old =
			kzalloc(sizeof(struct bnx2x_eth_q_stats_old),
				GFP_KERNEL);
		if (tmp_eth_q_stats_old)
			memcpy(tmp_eth_q_stats_old, &fp->eth_q_stats_old,
			       sizeof(struct bnx2x_eth_q_stats_old));

		memset(fp, 0, sizeof(*fp));

		if (tmp_eth_q_stats) {
			memcpy(&fp->eth_q_stats, tmp_eth_q_stats,
				   sizeof(struct bnx2x_eth_q_stats));
			kfree(tmp_eth_q_stats);
		}

		if (tmp_eth_q_stats_old) {
			memcpy(&fp->eth_q_stats_old, tmp_eth_q_stats_old,
			       sizeof(struct bnx2x_eth_q_stats_old));
			kfree(tmp_eth_q_stats_old);
		}

	}

	/* Restore the NAPI object as it has been already initialized */
	fp->napi = orig_napi;

	fp->bp = bp;
	fp->index = index;
	if (IS_ETH_FP(fp))
		fp->max_cos = bp->max_cos;
	else
		/* Special queues support only one CoS */
		fp->max_cos = 1;

	/*
	 * set the tpa flag for each queue. The tpa flag determines the queue
	 * minimal size so it must be set prior to queue memory allocation
	 */
	fp->disable_tpa = !(bp->flags & TPA_ENABLE_FLAG ||
				  (bp->flags & GRO_ENABLE_FLAG &&
				   bnx2x_mtu_allows_gro(bp->dev->mtu)));
	if (bp->flags & TPA_ENABLE_FLAG)
		fp->mode = TPA_MODE_LRO;
	else if (bp->flags & GRO_ENABLE_FLAG)
		fp->mode = TPA_MODE_GRO;

#ifdef BCM_CNIC
	/* We don't want TPA on an FCoE L2 ring */
	if (IS_FCOE_FP(fp))
		fp->disable_tpa = 1;
#endif
}


D
Dmitry Kravkov 已提交
1923 1924 1925
/* must be called with rtnl_lock */
int bnx2x_nic_load(struct bnx2x *bp, int load_mode)
{
1926
	int port = BP_PORT(bp);
D
Dmitry Kravkov 已提交
1927 1928 1929 1930
	u32 load_code;
	int i, rc;

#ifdef BNX2X_STOP_ON_ERROR
M
Merav Sicron 已提交
1931 1932
	if (unlikely(bp->panic)) {
		BNX2X_ERR("Can't load NIC when there is panic\n");
D
Dmitry Kravkov 已提交
1933
		return -EPERM;
M
Merav Sicron 已提交
1934
	}
D
Dmitry Kravkov 已提交
1935 1936 1937 1938
#endif

	bp->state = BNX2X_STATE_OPENING_WAIT4_LOAD;

1939 1940 1941 1942 1943 1944 1945
	/* Set the initial link reported state to link down */
	bnx2x_acquire_phy_lock(bp);
	memset(&bp->last_reported_link, 0, sizeof(bp->last_reported_link));
	__set_bit(BNX2X_LINK_REPORT_LINK_DOWN,
		&bp->last_reported_link.link_report_flags);
	bnx2x_release_phy_lock(bp);

1946 1947 1948
	/* must be called before memory allocation and HW init */
	bnx2x_ilt_set_info(bp);

1949 1950 1951 1952
	/*
	 * Zero fastpath structures preserving invariants like napi, which are
	 * allocated only once, fp index, max_cos, bp pointer.
	 * Also set fp->disable_tpa.
1953
	 */
M
Merav Sicron 已提交
1954
	DP(NETIF_MSG_IFUP, "num queues: %d", bp->num_queues);
1955 1956 1957
	for_each_queue(bp, i)
		bnx2x_bz_fp(bp, i);

1958

1959 1960 1961
	/* Set the receive queues buffer size */
	bnx2x_set_rx_buf_size(bp);

1962
	if (bnx2x_alloc_mem(bp))
D
Dmitry Kravkov 已提交
1963
		return -ENOMEM;
1964

1965 1966 1967 1968
	/* As long as bnx2x_alloc_mem() may possibly update
	 * bp->num_queues, bnx2x_set_real_num_queues() should always
	 * come after it.
	 */
V
Vladislav Zolotarov 已提交
1969
	rc = bnx2x_set_real_num_queues(bp);
1970
	if (rc) {
V
Vladislav Zolotarov 已提交
1971
		BNX2X_ERR("Unable to set real_num_queues\n");
1972
		LOAD_ERROR_EXIT(bp, load_error0);
D
Dmitry Kravkov 已提交
1973 1974
	}

1975 1976 1977 1978 1979 1980
	/* configure multi cos mappings in kernel.
	 * this configuration may be overriden by a multi class queue discipline
	 * or by a dcbx negotiation result.
	 */
	bnx2x_setup_tc(bp->dev, bp->max_cos);

D
Dmitry Kravkov 已提交
1981 1982
	bnx2x_napi_enable(bp);

1983 1984 1985
	/* set pf load just before approaching the MCP */
	bnx2x_set_pf_load(bp);

D
Dmitry Kravkov 已提交
1986
	/* Send LOAD_REQUEST command to MCP
1987 1988 1989 1990
	 * Returns the type of LOAD command:
	 * if it is the first port to be initialized
	 * common blocks should be initialized, otherwise - not
	 */
D
Dmitry Kravkov 已提交
1991
	if (!BP_NOMCP(bp)) {
A
Ariel Elior 已提交
1992 1993 1994 1995 1996 1997 1998 1999 2000 2001 2002 2003
		/* init fw_seq */
		bp->fw_seq =
			(SHMEM_RD(bp, func_mb[BP_FW_MB_IDX(bp)].drv_mb_header) &
			 DRV_MSG_SEQ_NUMBER_MASK);
		BNX2X_DEV_INFO("fw_seq 0x%08x\n", bp->fw_seq);

		/* Get current FW pulse sequence */
		bp->fw_drv_pulse_wr_seq =
			(SHMEM_RD(bp, func_mb[BP_FW_MB_IDX(bp)].drv_pulse_mb) &
			 DRV_PULSE_SEQ_MASK);
		BNX2X_DEV_INFO("drv_pulse 0x%x\n", bp->fw_drv_pulse_wr_seq);

Y
Yaniv Rosner 已提交
2004
		load_code = bnx2x_fw_command(bp, DRV_MSG_CODE_LOAD_REQ, 0);
D
Dmitry Kravkov 已提交
2005 2006 2007
		if (!load_code) {
			BNX2X_ERR("MCP response failure, aborting\n");
			rc = -EBUSY;
2008
			LOAD_ERROR_EXIT(bp, load_error1);
D
Dmitry Kravkov 已提交
2009 2010
		}
		if (load_code == FW_MSG_CODE_DRV_LOAD_REFUSED) {
M
Merav Sicron 已提交
2011
			BNX2X_ERR("Driver load refused\n");
D
Dmitry Kravkov 已提交
2012
			rc = -EBUSY; /* other port in diagnostic mode */
2013
			LOAD_ERROR_EXIT(bp, load_error1);
D
Dmitry Kravkov 已提交
2014
		}
2015 2016 2017
		if (load_code != FW_MSG_CODE_DRV_LOAD_COMMON_CHIP &&
		    load_code != FW_MSG_CODE_DRV_LOAD_COMMON) {
			/* abort nic load if version mismatch */
2018
			if (!bnx2x_test_firmware_version(bp, true)) {
2019 2020 2021 2022
				rc = -EBUSY;
				LOAD_ERROR_EXIT(bp, load_error2);
			}
		}
D
Dmitry Kravkov 已提交
2023 2024

	} else {
D
Dmitry Kravkov 已提交
2025
		int path = BP_PATH(bp);
D
Dmitry Kravkov 已提交
2026

D
Dmitry Kravkov 已提交
2027 2028 2029 2030 2031 2032 2033 2034 2035
		DP(NETIF_MSG_IFUP, "NO MCP - load counts[%d]      %d, %d, %d\n",
		   path, load_count[path][0], load_count[path][1],
		   load_count[path][2]);
		load_count[path][0]++;
		load_count[path][1 + port]++;
		DP(NETIF_MSG_IFUP, "NO MCP - new load counts[%d]  %d, %d, %d\n",
		   path, load_count[path][0], load_count[path][1],
		   load_count[path][2]);
		if (load_count[path][0] == 1)
D
Dmitry Kravkov 已提交
2036
			load_code = FW_MSG_CODE_DRV_LOAD_COMMON;
D
Dmitry Kravkov 已提交
2037
		else if (load_count[path][1 + port] == 1)
D
Dmitry Kravkov 已提交
2038 2039 2040 2041 2042 2043
			load_code = FW_MSG_CODE_DRV_LOAD_PORT;
		else
			load_code = FW_MSG_CODE_DRV_LOAD_FUNCTION;
	}

	if ((load_code == FW_MSG_CODE_DRV_LOAD_COMMON) ||
D
Dmitry Kravkov 已提交
2044
	    (load_code == FW_MSG_CODE_DRV_LOAD_COMMON_CHIP) ||
2045
	    (load_code == FW_MSG_CODE_DRV_LOAD_PORT)) {
D
Dmitry Kravkov 已提交
2046
		bp->port.pmf = 1;
2047 2048 2049 2050 2051 2052 2053
		/*
		 * We need the barrier to ensure the ordering between the
		 * writing to bp->port.pmf here and reading it from the
		 * bnx2x_periodic_task().
		 */
		smp_mb();
	} else
D
Dmitry Kravkov 已提交
2054
		bp->port.pmf = 0;
2055

M
Merav Sicron 已提交
2056
	DP(NETIF_MSG_IFUP, "pmf %d\n", bp->port.pmf);
D
Dmitry Kravkov 已提交
2057

2058 2059 2060
	/* Init Function state controlling object */
	bnx2x__init_func_obj(bp);

D
Dmitry Kravkov 已提交
2061 2062 2063 2064
	/* Initialize HW */
	rc = bnx2x_init_hw(bp, load_code);
	if (rc) {
		BNX2X_ERR("HW init failed, aborting\n");
Y
Yaniv Rosner 已提交
2065
		bnx2x_fw_command(bp, DRV_MSG_CODE_LOAD_DONE, 0);
2066
		LOAD_ERROR_EXIT(bp, load_error2);
D
Dmitry Kravkov 已提交
2067 2068
	}

2069 2070
	/* Connect to IRQs */
	rc = bnx2x_setup_irqs(bp);
2071
	if (rc) {
M
Merav Sicron 已提交
2072
		BNX2X_ERR("IRQs setup failed\n");
2073
		bnx2x_fw_command(bp, DRV_MSG_CODE_LOAD_DONE, 0);
2074
		LOAD_ERROR_EXIT(bp, load_error2);
2075 2076
	}

D
Dmitry Kravkov 已提交
2077 2078 2079
	/* Setup NIC internals and enable interrupts */
	bnx2x_nic_init(bp, load_code);

2080 2081 2082
	/* Init per-function objects */
	bnx2x_init_bp_objs(bp);

D
Dmitry Kravkov 已提交
2083 2084
	if (((load_code == FW_MSG_CODE_DRV_LOAD_COMMON) ||
	    (load_code == FW_MSG_CODE_DRV_LOAD_COMMON_CHIP)) &&
2085 2086 2087 2088 2089
	    (bp->common.shmem2_base)) {
		if (SHMEM2_HAS(bp, dcc_support))
			SHMEM2_WR(bp, dcc_support,
				  (SHMEM_DCC_SUPPORT_DISABLE_ENABLE_PF_TLV |
				   SHMEM_DCC_SUPPORT_BANDWIDTH_ALLOCATION_TLV));
B
Barak Witkowski 已提交
2090 2091 2092
		if (SHMEM2_HAS(bp, afex_driver_support))
			SHMEM2_WR(bp, afex_driver_support,
				  SHMEM_AFEX_SUPPORTED_VERSION_ONE);
2093 2094
	}

B
Barak Witkowski 已提交
2095 2096 2097
	/* Set AFEX default VLAN tag to an invalid value */
	bp->afex_def_vlan_tag = -1;

2098 2099 2100 2101
	bp->state = BNX2X_STATE_OPENING_WAIT4_PORT;
	rc = bnx2x_func_start(bp);
	if (rc) {
		BNX2X_ERR("Function start failed!\n");
2102
		bnx2x_fw_command(bp, DRV_MSG_CODE_LOAD_DONE, 0);
2103 2104
		LOAD_ERROR_EXIT(bp, load_error3);
	}
D
Dmitry Kravkov 已提交
2105 2106 2107

	/* Send LOAD_DONE command to MCP */
	if (!BP_NOMCP(bp)) {
Y
Yaniv Rosner 已提交
2108
		load_code = bnx2x_fw_command(bp, DRV_MSG_CODE_LOAD_DONE, 0);
D
Dmitry Kravkov 已提交
2109 2110 2111
		if (!load_code) {
			BNX2X_ERR("MCP response failure, aborting\n");
			rc = -EBUSY;
2112
			LOAD_ERROR_EXIT(bp, load_error3);
D
Dmitry Kravkov 已提交
2113 2114 2115
		}
	}

2116
	rc = bnx2x_setup_leading(bp);
D
Dmitry Kravkov 已提交
2117 2118
	if (rc) {
		BNX2X_ERR("Setup leading failed!\n");
2119
		LOAD_ERROR_EXIT(bp, load_error3);
D
Dmitry Kravkov 已提交
2120
	}
D
Dmitry Kravkov 已提交
2121 2122

#ifdef BCM_CNIC
2123
	/* Enable Timer scan */
2124
	REG_WR(bp, TM_REG_EN_LINEAR0_TIMER + port*4, 1);
D
Dmitry Kravkov 已提交
2125
#endif
D
Dmitry Kravkov 已提交
2126

2127
	for_each_nondefault_queue(bp, i) {
2128
		rc = bnx2x_setup_queue(bp, &bp->fp[i], 0);
M
Merav Sicron 已提交
2129 2130
		if (rc) {
			BNX2X_ERR("Queue setup failed\n");
2131
			LOAD_ERROR_EXIT(bp, load_error4);
M
Merav Sicron 已提交
2132
		}
2133 2134
	}

2135
	rc = bnx2x_init_rss_pf(bp);
M
Merav Sicron 已提交
2136 2137
	if (rc) {
		BNX2X_ERR("PF RSS init failed\n");
2138
		LOAD_ERROR_EXIT(bp, load_error4);
M
Merav Sicron 已提交
2139
	}
2140

2141 2142 2143
	/* Now when Clients are configured we are ready to work */
	bp->state = BNX2X_STATE_OPEN;

2144 2145
	/* Configure a ucast MAC */
	rc = bnx2x_set_eth_mac(bp, true);
M
Merav Sicron 已提交
2146 2147
	if (rc) {
		BNX2X_ERR("Setting Ethernet MAC failed\n");
2148
		LOAD_ERROR_EXIT(bp, load_error4);
M
Merav Sicron 已提交
2149
	}
2150

2151 2152 2153 2154 2155
	if (bp->pending_max) {
		bnx2x_update_max_mf_config(bp, bp->pending_max);
		bp->pending_max = 0;
	}

D
Dmitry Kravkov 已提交
2156 2157 2158
	if (bp->port.pmf)
		bnx2x_initial_phy_init(bp, load_mode);

2159 2160 2161 2162
	/* Start fast path */

	/* Initialize Rx filter. */
	netif_addr_lock_bh(bp->dev);
2163
	bnx2x_set_rx_mode(bp->dev);
2164
	netif_addr_unlock_bh(bp->dev);
2165

2166
	/* Start the Tx */
D
Dmitry Kravkov 已提交
2167 2168
	switch (load_mode) {
	case LOAD_NORMAL:
2169 2170
		/* Tx queue should be only reenabled */
		netif_tx_wake_all_queues(bp->dev);
D
Dmitry Kravkov 已提交
2171 2172 2173 2174
		break;

	case LOAD_OPEN:
		netif_tx_start_all_queues(bp->dev);
2175
		smp_mb__after_clear_bit();
D
Dmitry Kravkov 已提交
2176 2177 2178 2179 2180 2181 2182 2183 2184 2185
		break;

	case LOAD_DIAG:
		bp->state = BNX2X_STATE_DIAG;
		break;

	default:
		break;
	}

D
Dmitry Kravkov 已提交
2186
	if (bp->port.pmf)
2187
		bnx2x_update_drv_flags(bp, 1 << DRV_FLAGS_DCB_CONFIGURED, 0);
D
Dmitry Kravkov 已提交
2188
	else
D
Dmitry Kravkov 已提交
2189 2190 2191 2192 2193 2194
		bnx2x__link_status_update(bp);

	/* start the timer */
	mod_timer(&bp->timer, jiffies + bp->current_interval);

#ifdef BCM_CNIC
2195 2196
	/* re-read iscsi info */
	bnx2x_get_iscsi_info(bp);
D
Dmitry Kravkov 已提交
2197 2198 2199 2200 2201
	bnx2x_setup_cnic_irq_info(bp);
	if (bp->state == BNX2X_STATE_OPEN)
		bnx2x_cnic_notify(bp, CNIC_CTL_START_CMD);
#endif

2202 2203 2204 2205 2206 2207 2208 2209 2210
	/* mark driver is loaded in shmem2 */
	if (SHMEM2_HAS(bp, drv_capabilities_flag)) {
		u32 val;
		val = SHMEM2_RD(bp, drv_capabilities_flag[BP_FW_MB_IDX(bp)]);
		SHMEM2_WR(bp, drv_capabilities_flag[BP_FW_MB_IDX(bp)],
			  val | DRV_FLAGS_CAPABILITIES_LOADED_SUPPORTED |
			  DRV_FLAGS_CAPABILITIES_LOADED_L2);
	}

2211 2212 2213 2214 2215 2216
	/* Wait for all pending SP commands to complete */
	if (!bnx2x_wait_sp_comp(bp, ~0x0UL)) {
		BNX2X_ERR("Timeout waiting for SP elements to complete\n");
		bnx2x_nic_unload(bp, UNLOAD_CLOSE);
		return -EBUSY;
	}
2217

2218
	bnx2x_dcbx_init(bp);
D
Dmitry Kravkov 已提交
2219 2220
	return 0;

2221
#ifndef BNX2X_STOP_ON_ERROR
D
Dmitry Kravkov 已提交
2222
load_error4:
2223
#ifdef BCM_CNIC
D
Dmitry Kravkov 已提交
2224
	/* Disable Timer scan */
2225
	REG_WR(bp, TM_REG_EN_LINEAR0_TIMER + port*4, 0);
D
Dmitry Kravkov 已提交
2226 2227 2228
#endif
load_error3:
	bnx2x_int_disable_sync(bp, 1);
2229

2230 2231 2232
	/* Clean queueable objects */
	bnx2x_squeeze_objects(bp);

D
Dmitry Kravkov 已提交
2233 2234
	/* Free SKBs, SGEs, TPA pool and driver internals */
	bnx2x_free_skbs(bp);
V
Vladislav Zolotarov 已提交
2235
	for_each_rx_queue(bp, i)
D
Dmitry Kravkov 已提交
2236
		bnx2x_free_rx_sge_range(bp, bp->fp + i, NUM_RX_SGE);
2237

D
Dmitry Kravkov 已提交
2238
	/* Release IRQs */
2239 2240 2241 2242 2243 2244 2245 2246
	bnx2x_free_irq(bp);
load_error2:
	if (!BP_NOMCP(bp)) {
		bnx2x_fw_command(bp, DRV_MSG_CODE_UNLOAD_REQ_WOL_MCP, 0);
		bnx2x_fw_command(bp, DRV_MSG_CODE_UNLOAD_DONE, 0);
	}

	bp->port.pmf = 0;
D
Dmitry Kravkov 已提交
2247 2248
load_error1:
	bnx2x_napi_disable(bp);
2249 2250
	/* clear pf_load status, as it was already set */
	bnx2x_clear_pf_load(bp);
2251
load_error0:
D
Dmitry Kravkov 已提交
2252 2253 2254
	bnx2x_free_mem(bp);

	return rc;
2255
#endif /* ! BNX2X_STOP_ON_ERROR */
D
Dmitry Kravkov 已提交
2256 2257 2258 2259 2260 2261
}

/* must be called with rtnl_lock */
int bnx2x_nic_unload(struct bnx2x *bp, int unload_mode)
{
	int i;
2262 2263
	bool global = false;

2264 2265 2266 2267 2268 2269 2270 2271
	/* mark driver is unloaded in shmem2 */
	if (SHMEM2_HAS(bp, drv_capabilities_flag)) {
		u32 val;
		val = SHMEM2_RD(bp, drv_capabilities_flag[BP_FW_MB_IDX(bp)]);
		SHMEM2_WR(bp, drv_capabilities_flag[BP_FW_MB_IDX(bp)],
			  val & ~DRV_FLAGS_CAPABILITIES_LOADED_L2);
	}

2272 2273 2274 2275 2276 2277 2278 2279 2280
	if ((bp->state == BNX2X_STATE_CLOSED) ||
	    (bp->state == BNX2X_STATE_ERROR)) {
		/* We can get here if the driver has been unloaded
		 * during parity error recovery and is either waiting for a
		 * leader to complete or for other functions to unload and
		 * then ifdown has been issued. In this case we want to
		 * unload and let other functions to complete a recovery
		 * process.
		 */
D
Dmitry Kravkov 已提交
2281 2282
		bp->recovery_state = BNX2X_RECOVERY_DONE;
		bp->is_leader = 0;
2283 2284 2285
		bnx2x_release_leader_lock(bp);
		smp_mb();

M
Merav Sicron 已提交
2286 2287
		DP(NETIF_MSG_IFDOWN, "Releasing a leadership...\n");
		BNX2X_ERR("Can't unload in closed or error state\n");
D
Dmitry Kravkov 已提交
2288 2289 2290
		return -EINVAL;
	}

2291 2292 2293 2294 2295 2296 2297 2298
	/*
	 * It's important to set the bp->state to the value different from
	 * BNX2X_STATE_OPEN and only then stop the Tx. Otherwise bnx2x_tx_int()
	 * may restart the Tx from the NAPI context (see bnx2x_tx_int()).
	 */
	bp->state = BNX2X_STATE_CLOSING_WAIT4_HALT;
	smp_mb();

2299 2300 2301
	/* Stop Tx */
	bnx2x_tx_disable(bp);

D
Dmitry Kravkov 已提交
2302 2303 2304 2305 2306 2307 2308
#ifdef BCM_CNIC
	bnx2x_cnic_notify(bp, CNIC_CTL_STOP_CMD);
#endif

	bp->rx_mode = BNX2X_RX_MODE_NONE;

	del_timer_sync(&bp->timer);
D
Dmitry Kravkov 已提交
2309

2310 2311 2312 2313
	/* Set ALWAYS_ALIVE bit in shmem */
	bp->fw_drv_pulse_wr_seq |= DRV_PULSE_ALWAYS_ALIVE;

	bnx2x_drv_pulse(bp);
D
Dmitry Kravkov 已提交
2314

D
Dmitry Kravkov 已提交
2315
	bnx2x_stats_handle(bp, STATS_EVENT_STOP);
2316
	bnx2x_save_statistics(bp);
D
Dmitry Kravkov 已提交
2317 2318 2319 2320

	/* Cleanup the chip if needed */
	if (unload_mode != UNLOAD_RECOVERY)
		bnx2x_chip_cleanup(bp, unload_mode);
2321
	else {
2322 2323 2324 2325 2326 2327 2328 2329 2330 2331 2332 2333 2334 2335
		/* Send the UNLOAD_REQUEST to the MCP */
		bnx2x_send_unload_req(bp, unload_mode);

		/*
		 * Prevent transactions to host from the functions on the
		 * engine that doesn't reset global blocks in case of global
		 * attention once gloabl blocks are reset and gates are opened
		 * (the engine which leader will perform the recovery
		 * last).
		 */
		if (!CHIP_IS_E1x(bp))
			bnx2x_pf_disable(bp);

		/* Disable HW interrupts, NAPI */
2336 2337 2338
		bnx2x_netif_stop(bp, 1);

		/* Release IRQs */
2339
		bnx2x_free_irq(bp);
2340 2341 2342

		/* Report UNLOAD_DONE to MCP */
		bnx2x_send_unload_done(bp);
2343
	}
D
Dmitry Kravkov 已提交
2344

2345 2346 2347 2348 2349 2350
	/*
	 * At this stage no more interrupts will arrive so we may safly clean
	 * the queueable objects here in case they failed to get cleaned so far.
	 */
	bnx2x_squeeze_objects(bp);

2351 2352 2353
	/* There should be no more pending SP commands at this stage */
	bp->sp_state = 0;

D
Dmitry Kravkov 已提交
2354 2355 2356 2357
	bp->port.pmf = 0;

	/* Free SKBs, SGEs, TPA pool and driver internals */
	bnx2x_free_skbs(bp);
V
Vladislav Zolotarov 已提交
2358
	for_each_rx_queue(bp, i)
D
Dmitry Kravkov 已提交
2359
		bnx2x_free_rx_sge_range(bp, bp->fp + i, NUM_RX_SGE);
2360

D
Dmitry Kravkov 已提交
2361 2362 2363 2364
	bnx2x_free_mem(bp);

	bp->state = BNX2X_STATE_CLOSED;

2365 2366 2367 2368 2369 2370 2371 2372 2373 2374 2375 2376
	/* Check if there are pending parity attentions. If there are - set
	 * RECOVERY_IN_PROGRESS.
	 */
	if (bnx2x_chk_parity_attn(bp, &global, false)) {
		bnx2x_set_reset_in_progress(bp);

		/* Set RESET_IS_GLOBAL if needed */
		if (global)
			bnx2x_set_reset_global(bp);
	}


D
Dmitry Kravkov 已提交
2377 2378 2379
	/* The last driver must disable a "close the gate" if there is no
	 * parity attention or "process kill" pending.
	 */
2380
	if (!bnx2x_clear_pf_load(bp) && bnx2x_reset_is_done(bp, BP_PATH(bp)))
D
Dmitry Kravkov 已提交
2381 2382 2383 2384
		bnx2x_disable_close_the_gate(bp);

	return 0;
}
D
Dmitry Kravkov 已提交
2385

D
Dmitry Kravkov 已提交
2386 2387 2388 2389
int bnx2x_set_power_state(struct bnx2x *bp, pci_power_t state)
{
	u16 pmcsr;

2390 2391
	/* If there is no power capability, silently succeed */
	if (!bp->pm_cap) {
M
Merav Sicron 已提交
2392
		BNX2X_DEV_INFO("No power capability. Breaking.\n");
2393 2394 2395
		return 0;
	}

D
Dmitry Kravkov 已提交
2396 2397 2398 2399 2400 2401 2402 2403 2404 2405 2406 2407 2408 2409 2410 2411 2412 2413 2414 2415 2416 2417 2418 2419 2420 2421 2422 2423 2424 2425 2426 2427 2428 2429 2430 2431 2432
	pci_read_config_word(bp->pdev, bp->pm_cap + PCI_PM_CTRL, &pmcsr);

	switch (state) {
	case PCI_D0:
		pci_write_config_word(bp->pdev, bp->pm_cap + PCI_PM_CTRL,
				      ((pmcsr & ~PCI_PM_CTRL_STATE_MASK) |
				       PCI_PM_CTRL_PME_STATUS));

		if (pmcsr & PCI_PM_CTRL_STATE_MASK)
			/* delay required during transition out of D3hot */
			msleep(20);
		break;

	case PCI_D3hot:
		/* If there are other clients above don't
		   shut down the power */
		if (atomic_read(&bp->pdev->enable_cnt) != 1)
			return 0;
		/* Don't shut down the power for emulation and FPGA */
		if (CHIP_REV_IS_SLOW(bp))
			return 0;

		pmcsr &= ~PCI_PM_CTRL_STATE_MASK;
		pmcsr |= 3;

		if (bp->wol)
			pmcsr |= PCI_PM_CTRL_PME_ENABLE;

		pci_write_config_word(bp->pdev, bp->pm_cap + PCI_PM_CTRL,
				      pmcsr);

		/* No more memory access after this point until
		* device is brought back to D0.
		*/
		break;

	default:
M
Merav Sicron 已提交
2433
		dev_err(&bp->pdev->dev, "Can't support state = %d\n", state);
D
Dmitry Kravkov 已提交
2434 2435 2436 2437 2438 2439 2440 2441
		return -EINVAL;
	}
	return 0;
}

/*
 * net_device service functions
 */
2442
int bnx2x_poll(struct napi_struct *napi, int budget)
D
Dmitry Kravkov 已提交
2443 2444
{
	int work_done = 0;
2445
	u8 cos;
D
Dmitry Kravkov 已提交
2446 2447 2448 2449 2450 2451 2452 2453 2454 2455 2456 2457
	struct bnx2x_fastpath *fp = container_of(napi, struct bnx2x_fastpath,
						 napi);
	struct bnx2x *bp = fp->bp;

	while (1) {
#ifdef BNX2X_STOP_ON_ERROR
		if (unlikely(bp->panic)) {
			napi_complete(napi);
			return 0;
		}
#endif

2458 2459 2460 2461
		for_each_cos_in_tx_queue(fp, cos)
			if (bnx2x_tx_queue_has_work(&fp->txdata[cos]))
				bnx2x_tx_int(bp, &fp->txdata[cos]);

D
Dmitry Kravkov 已提交
2462 2463 2464 2465 2466 2467 2468 2469 2470 2471 2472

		if (bnx2x_has_rx_work(fp)) {
			work_done += bnx2x_rx_int(fp, budget - work_done);

			/* must not complete if we consumed full budget */
			if (work_done >= budget)
				break;
		}

		/* Fall out from the NAPI loop if needed */
		if (!(bnx2x_has_rx_work(fp) || bnx2x_has_tx_work(fp))) {
V
Vladislav Zolotarov 已提交
2473 2474 2475 2476 2477 2478 2479 2480 2481 2482 2483
#ifdef BCM_CNIC
			/* No need to update SB for FCoE L2 ring as long as
			 * it's connected to the default SB and the SB
			 * has been updated when NAPI was scheduled.
			 */
			if (IS_FCOE_FP(fp)) {
				napi_complete(napi);
				break;
			}
#endif

D
Dmitry Kravkov 已提交
2484
			bnx2x_update_fpsb_idx(fp);
D
Dmitry Kravkov 已提交
2485 2486 2487 2488 2489 2490 2491 2492 2493 2494 2495 2496 2497
			/* bnx2x_has_rx_work() reads the status block,
			 * thus we need to ensure that status block indices
			 * have been actually read (bnx2x_update_fpsb_idx)
			 * prior to this check (bnx2x_has_rx_work) so that
			 * we won't write the "newer" value of the status block
			 * to IGU (if there was a DMA right after
			 * bnx2x_has_rx_work and if there is no rmb, the memory
			 * reading (bnx2x_update_fpsb_idx) may be postponed
			 * to right before bnx2x_ack_sb). In this case there
			 * will never be another interrupt until there is
			 * another update of the status block, while there
			 * is still unhandled work.
			 */
D
Dmitry Kravkov 已提交
2498 2499 2500 2501 2502
			rmb();

			if (!(bnx2x_has_rx_work(fp) || bnx2x_has_tx_work(fp))) {
				napi_complete(napi);
				/* Re-enable interrupts */
M
Merav Sicron 已提交
2503
				DP(NETIF_MSG_RX_STATUS,
2504 2505 2506
				   "Update index to %d\n", fp->fp_hc_idx);
				bnx2x_ack_sb(bp, fp->igu_sb_id, USTORM_ID,
					     le16_to_cpu(fp->fp_hc_idx),
D
Dmitry Kravkov 已提交
2507 2508 2509 2510 2511 2512 2513 2514 2515 2516 2517 2518 2519 2520
					     IGU_INT_ENABLE, 1);
				break;
			}
		}
	}

	return work_done;
}

/* we split the first BD into headers and data BDs
 * to ease the pain of our fellow microcode engineers
 * we use one mapping for both BDs
 */
static noinline u16 bnx2x_tx_split(struct bnx2x *bp,
2521
				   struct bnx2x_fp_txdata *txdata,
D
Dmitry Kravkov 已提交
2522 2523 2524 2525 2526 2527 2528 2529 2530 2531 2532 2533 2534
				   struct sw_tx_bd *tx_buf,
				   struct eth_tx_start_bd **tx_bd, u16 hlen,
				   u16 bd_prod, int nbd)
{
	struct eth_tx_start_bd *h_tx_bd = *tx_bd;
	struct eth_tx_bd *d_tx_bd;
	dma_addr_t mapping;
	int old_len = le16_to_cpu(h_tx_bd->nbytes);

	/* first fix first BD */
	h_tx_bd->nbd = cpu_to_le16(nbd);
	h_tx_bd->nbytes = cpu_to_le16(hlen);

M
Merav Sicron 已提交
2535 2536
	DP(NETIF_MSG_TX_QUEUED,	"TSO split header size is %d (%x:%x) nbd %d\n",
	   h_tx_bd->nbytes, h_tx_bd->addr_hi, h_tx_bd->addr_lo, h_tx_bd->nbd);
D
Dmitry Kravkov 已提交
2537 2538 2539 2540

	/* now get a new data BD
	 * (after the pbd) and fill it */
	bd_prod = TX_BD(NEXT_TX_IDX(bd_prod));
2541
	d_tx_bd = &txdata->tx_desc_ring[bd_prod].reg_bd;
D
Dmitry Kravkov 已提交
2542 2543 2544 2545 2546 2547 2548 2549 2550 2551 2552 2553 2554 2555 2556 2557 2558 2559 2560 2561 2562 2563 2564 2565 2566 2567 2568 2569 2570 2571 2572 2573 2574 2575 2576 2577 2578 2579 2580 2581 2582 2583

	mapping = HILO_U64(le32_to_cpu(h_tx_bd->addr_hi),
			   le32_to_cpu(h_tx_bd->addr_lo)) + hlen;

	d_tx_bd->addr_hi = cpu_to_le32(U64_HI(mapping));
	d_tx_bd->addr_lo = cpu_to_le32(U64_LO(mapping));
	d_tx_bd->nbytes = cpu_to_le16(old_len - hlen);

	/* this marks the BD as one that has no individual mapping */
	tx_buf->flags |= BNX2X_TSO_SPLIT_BD;

	DP(NETIF_MSG_TX_QUEUED,
	   "TSO split data size is %d (%x:%x)\n",
	   d_tx_bd->nbytes, d_tx_bd->addr_hi, d_tx_bd->addr_lo);

	/* update tx_bd */
	*tx_bd = (struct eth_tx_start_bd *)d_tx_bd;

	return bd_prod;
}

static inline u16 bnx2x_csum_fix(unsigned char *t_header, u16 csum, s8 fix)
{
	if (fix > 0)
		csum = (u16) ~csum_fold(csum_sub(csum,
				csum_partial(t_header - fix, fix, 0)));

	else if (fix < 0)
		csum = (u16) ~csum_fold(csum_add(csum,
				csum_partial(t_header, -fix, 0)));

	return swab16(csum);
}

static inline u32 bnx2x_xmit_type(struct bnx2x *bp, struct sk_buff *skb)
{
	u32 rc;

	if (skb->ip_summed != CHECKSUM_PARTIAL)
		rc = XMIT_PLAIN;

	else {
2584
		if (vlan_get_protocol(skb) == htons(ETH_P_IPV6)) {
D
Dmitry Kravkov 已提交
2585 2586 2587 2588 2589 2590 2591 2592 2593 2594 2595
			rc = XMIT_CSUM_V6;
			if (ipv6_hdr(skb)->nexthdr == IPPROTO_TCP)
				rc |= XMIT_CSUM_TCP;

		} else {
			rc = XMIT_CSUM_V4;
			if (ip_hdr(skb)->protocol == IPPROTO_TCP)
				rc |= XMIT_CSUM_TCP;
		}
	}

2596 2597 2598 2599
	if (skb_is_gso_v6(skb))
		rc |= XMIT_GSO_V6 | XMIT_CSUM_TCP | XMIT_CSUM_V6;
	else if (skb_is_gso(skb))
		rc |= XMIT_GSO_V4 | XMIT_CSUM_V4 | XMIT_CSUM_TCP;
D
Dmitry Kravkov 已提交
2600 2601 2602 2603 2604 2605 2606 2607 2608 2609 2610 2611 2612 2613 2614 2615 2616 2617 2618 2619 2620 2621 2622 2623 2624 2625 2626 2627 2628 2629 2630 2631 2632 2633 2634 2635 2636 2637 2638 2639 2640

	return rc;
}

#if (MAX_SKB_FRAGS >= MAX_FETCH_BD - 3)
/* check if packet requires linearization (packet is too fragmented)
   no need to check fragmentation if page size > 8K (there will be no
   violation to FW restrictions) */
static int bnx2x_pkt_req_lin(struct bnx2x *bp, struct sk_buff *skb,
			     u32 xmit_type)
{
	int to_copy = 0;
	int hlen = 0;
	int first_bd_sz = 0;

	/* 3 = 1 (for linear data BD) + 2 (for PBD and last BD) */
	if (skb_shinfo(skb)->nr_frags >= (MAX_FETCH_BD - 3)) {

		if (xmit_type & XMIT_GSO) {
			unsigned short lso_mss = skb_shinfo(skb)->gso_size;
			/* Check if LSO packet needs to be copied:
			   3 = 1 (for headers BD) + 2 (for PBD and last BD) */
			int wnd_size = MAX_FETCH_BD - 3;
			/* Number of windows to check */
			int num_wnds = skb_shinfo(skb)->nr_frags - wnd_size;
			int wnd_idx = 0;
			int frag_idx = 0;
			u32 wnd_sum = 0;

			/* Headers length */
			hlen = (int)(skb_transport_header(skb) - skb->data) +
				tcp_hdrlen(skb);

			/* Amount of data (w/o headers) on linear part of SKB*/
			first_bd_sz = skb_headlen(skb) - hlen;

			wnd_sum  = first_bd_sz;

			/* Calculate the first sum - it's special */
			for (frag_idx = 0; frag_idx < wnd_size - 1; frag_idx++)
				wnd_sum +=
E
Eric Dumazet 已提交
2641
					skb_frag_size(&skb_shinfo(skb)->frags[frag_idx]);
D
Dmitry Kravkov 已提交
2642 2643 2644 2645 2646 2647 2648 2649 2650 2651 2652 2653 2654 2655 2656

			/* If there was data on linear skb data - check it */
			if (first_bd_sz > 0) {
				if (unlikely(wnd_sum < lso_mss)) {
					to_copy = 1;
					goto exit_lbl;
				}

				wnd_sum -= first_bd_sz;
			}

			/* Others are easier: run through the frag list and
			   check all windows */
			for (wnd_idx = 0; wnd_idx <= num_wnds; wnd_idx++) {
				wnd_sum +=
E
Eric Dumazet 已提交
2657
			  skb_frag_size(&skb_shinfo(skb)->frags[wnd_idx + wnd_size - 1]);
D
Dmitry Kravkov 已提交
2658 2659 2660 2661 2662 2663

				if (unlikely(wnd_sum < lso_mss)) {
					to_copy = 1;
					break;
				}
				wnd_sum -=
E
Eric Dumazet 已提交
2664
					skb_frag_size(&skb_shinfo(skb)->frags[wnd_idx]);
D
Dmitry Kravkov 已提交
2665 2666 2667 2668 2669 2670 2671 2672 2673 2674 2675
			}
		} else {
			/* in non-LSO too fragmented packet should always
			   be linearized */
			to_copy = 1;
		}
	}

exit_lbl:
	if (unlikely(to_copy))
		DP(NETIF_MSG_TX_QUEUED,
M
Merav Sicron 已提交
2676
		   "Linearization IS REQUIRED for %s packet. num_frags %d  hlen %d  first_bd_sz %d\n",
D
Dmitry Kravkov 已提交
2677 2678 2679 2680 2681 2682 2683
		   (xmit_type & XMIT_GSO) ? "LSO" : "non-LSO",
		   skb_shinfo(skb)->nr_frags, hlen, first_bd_sz);

	return to_copy;
}
#endif

2684 2685
static inline void bnx2x_set_pbd_gso_e2(struct sk_buff *skb, u32 *parsing_data,
					u32 xmit_type)
D
Dmitry Kravkov 已提交
2686
{
2687 2688 2689
	*parsing_data |= (skb_shinfo(skb)->gso_size <<
			      ETH_TX_PARSE_BD_E2_LSO_MSS_SHIFT) &
			      ETH_TX_PARSE_BD_E2_LSO_MSS;
D
Dmitry Kravkov 已提交
2690 2691
	if ((xmit_type & XMIT_GSO_V6) &&
	    (ipv6_hdr(skb)->nexthdr == NEXTHDR_IPV6))
2692
		*parsing_data |= ETH_TX_PARSE_BD_E2_IPV6_WITH_EXT_HDR;
D
Dmitry Kravkov 已提交
2693 2694 2695
}

/**
2696
 * bnx2x_set_pbd_gso - update PBD in GSO case.
D
Dmitry Kravkov 已提交
2697
 *
2698 2699 2700
 * @skb:	packet skb
 * @pbd:	parse BD
 * @xmit_type:	xmit flags
D
Dmitry Kravkov 已提交
2701 2702 2703 2704 2705 2706 2707 2708 2709 2710 2711 2712 2713 2714 2715 2716 2717 2718 2719 2720 2721 2722 2723 2724
 */
static inline void bnx2x_set_pbd_gso(struct sk_buff *skb,
				     struct eth_tx_parse_bd_e1x *pbd,
				     u32 xmit_type)
{
	pbd->lso_mss = cpu_to_le16(skb_shinfo(skb)->gso_size);
	pbd->tcp_send_seq = swab32(tcp_hdr(skb)->seq);
	pbd->tcp_flags = pbd_tcp_flags(skb);

	if (xmit_type & XMIT_GSO_V4) {
		pbd->ip_id = swab16(ip_hdr(skb)->id);
		pbd->tcp_pseudo_csum =
			swab16(~csum_tcpudp_magic(ip_hdr(skb)->saddr,
						  ip_hdr(skb)->daddr,
						  0, IPPROTO_TCP, 0));

	} else
		pbd->tcp_pseudo_csum =
			swab16(~csum_ipv6_magic(&ipv6_hdr(skb)->saddr,
						&ipv6_hdr(skb)->daddr,
						0, IPPROTO_TCP, 0));

	pbd->global_data |= ETH_TX_PARSE_BD_E1X_PSEUDO_CS_WITHOUT_LEN;
}
D
Dmitry Kravkov 已提交
2725

D
Dmitry Kravkov 已提交
2726
/**
2727
 * bnx2x_set_pbd_csum_e2 - update PBD with checksum and return header length
D
Dmitry Kravkov 已提交
2728
 *
2729 2730 2731 2732
 * @bp:			driver handle
 * @skb:		packet skb
 * @parsing_data:	data to be updated
 * @xmit_type:		xmit flags
D
Dmitry Kravkov 已提交
2733
 *
2734
 * 57712 related
D
Dmitry Kravkov 已提交
2735 2736
 */
static inline  u8 bnx2x_set_pbd_csum_e2(struct bnx2x *bp, struct sk_buff *skb,
2737
	u32 *parsing_data, u32 xmit_type)
D
Dmitry Kravkov 已提交
2738
{
2739 2740 2741 2742
	*parsing_data |=
			((((u8 *)skb_transport_header(skb) - skb->data) >> 1) <<
			ETH_TX_PARSE_BD_E2_TCP_HDR_START_OFFSET_W_SHIFT) &
			ETH_TX_PARSE_BD_E2_TCP_HDR_START_OFFSET_W;
D
Dmitry Kravkov 已提交
2743

2744 2745 2746 2747
	if (xmit_type & XMIT_CSUM_TCP) {
		*parsing_data |= ((tcp_hdrlen(skb) / 4) <<
			ETH_TX_PARSE_BD_E2_TCP_HDR_LENGTH_DW_SHIFT) &
			ETH_TX_PARSE_BD_E2_TCP_HDR_LENGTH_DW;
D
Dmitry Kravkov 已提交
2748

2749 2750 2751 2752 2753 2754 2755
		return skb_transport_header(skb) + tcp_hdrlen(skb) - skb->data;
	} else
		/* We support checksum offload for TCP and UDP only.
		 * No need to pass the UDP header length - it's a constant.
		 */
		return skb_transport_header(skb) +
				sizeof(struct udphdr) - skb->data;
D
Dmitry Kravkov 已提交
2756 2757
}

2758 2759 2760 2761 2762 2763 2764 2765 2766 2767 2768 2769 2770 2771 2772 2773
static inline void bnx2x_set_sbd_csum(struct bnx2x *bp, struct sk_buff *skb,
	struct eth_tx_start_bd *tx_start_bd, u32 xmit_type)
{
	tx_start_bd->bd_flags.as_bitfield |= ETH_TX_BD_FLAGS_L4_CSUM;

	if (xmit_type & XMIT_CSUM_V4)
		tx_start_bd->bd_flags.as_bitfield |=
					ETH_TX_BD_FLAGS_IP_CSUM;
	else
		tx_start_bd->bd_flags.as_bitfield |=
					ETH_TX_BD_FLAGS_IPV6;

	if (!(xmit_type & XMIT_CSUM_TCP))
		tx_start_bd->bd_flags.as_bitfield |= ETH_TX_BD_FLAGS_IS_UDP;
}

D
Dmitry Kravkov 已提交
2774
/**
2775
 * bnx2x_set_pbd_csum - update PBD with checksum and return header length
D
Dmitry Kravkov 已提交
2776
 *
2777 2778 2779 2780
 * @bp:		driver handle
 * @skb:	packet skb
 * @pbd:	parse BD to be updated
 * @xmit_type:	xmit flags
D
Dmitry Kravkov 已提交
2781 2782 2783 2784 2785
 */
static inline u8 bnx2x_set_pbd_csum(struct bnx2x *bp, struct sk_buff *skb,
	struct eth_tx_parse_bd_e1x *pbd,
	u32 xmit_type)
{
2786
	u8 hlen = (skb_network_header(skb) - skb->data) >> 1;
D
Dmitry Kravkov 已提交
2787 2788 2789 2790 2791 2792 2793

	/* for now NS flag is not used in Linux */
	pbd->global_data =
		(hlen | ((skb->protocol == cpu_to_be16(ETH_P_8021Q)) <<
			 ETH_TX_PARSE_BD_E1X_LLC_SNAP_EN_SHIFT));

	pbd->ip_hlen_w = (skb_transport_header(skb) -
2794
			skb_network_header(skb)) >> 1;
D
Dmitry Kravkov 已提交
2795

2796 2797 2798 2799 2800 2801 2802
	hlen += pbd->ip_hlen_w;

	/* We support checksum offload for TCP and UDP only */
	if (xmit_type & XMIT_CSUM_TCP)
		hlen += tcp_hdrlen(skb) / 2;
	else
		hlen += sizeof(struct udphdr) / 2;
D
Dmitry Kravkov 已提交
2803 2804 2805 2806 2807 2808 2809 2810 2811 2812 2813 2814 2815 2816 2817 2818 2819 2820 2821 2822 2823 2824 2825 2826 2827

	pbd->total_hlen_w = cpu_to_le16(hlen);
	hlen = hlen*2;

	if (xmit_type & XMIT_CSUM_TCP) {
		pbd->tcp_pseudo_csum = swab16(tcp_hdr(skb)->check);

	} else {
		s8 fix = SKB_CS_OFF(skb); /* signed! */

		DP(NETIF_MSG_TX_QUEUED,
		   "hlen %d  fix %d  csum before fix %x\n",
		   le16_to_cpu(pbd->total_hlen_w), fix, SKB_CS(skb));

		/* HW bug: fixup the CSUM */
		pbd->tcp_pseudo_csum =
			bnx2x_csum_fix(skb_transport_header(skb),
				       SKB_CS(skb), fix);

		DP(NETIF_MSG_TX_QUEUED, "csum after fix %x\n",
		   pbd->tcp_pseudo_csum);
	}

	return hlen;
}
D
Dmitry Kravkov 已提交
2828

D
Dmitry Kravkov 已提交
2829 2830 2831 2832 2833 2834 2835
/* called with netif_tx_lock
 * bnx2x_tx_int() runs without netif_tx_lock unless it needs to call
 * netif_wake_queue()
 */
netdev_tx_t bnx2x_start_xmit(struct sk_buff *skb, struct net_device *dev)
{
	struct bnx2x *bp = netdev_priv(dev);
2836

D
Dmitry Kravkov 已提交
2837 2838
	struct bnx2x_fastpath *fp;
	struct netdev_queue *txq;
2839
	struct bnx2x_fp_txdata *txdata;
D
Dmitry Kravkov 已提交
2840
	struct sw_tx_bd *tx_buf;
2841
	struct eth_tx_start_bd *tx_start_bd, *first_bd;
D
Dmitry Kravkov 已提交
2842
	struct eth_tx_bd *tx_data_bd, *total_pkt_bd = NULL;
2843
	struct eth_tx_parse_bd_e1x *pbd_e1x = NULL;
D
Dmitry Kravkov 已提交
2844
	struct eth_tx_parse_bd_e2 *pbd_e2 = NULL;
2845
	u32 pbd_e2_parsing_data = 0;
D
Dmitry Kravkov 已提交
2846
	u16 pkt_prod, bd_prod;
2847
	int nbd, txq_index, fp_index, txdata_index;
D
Dmitry Kravkov 已提交
2848 2849 2850 2851 2852 2853 2854 2855 2856 2857 2858 2859 2860
	dma_addr_t mapping;
	u32 xmit_type = bnx2x_xmit_type(bp, skb);
	int i;
	u8 hlen = 0;
	__le16 pkt_size = 0;
	struct ethhdr *eth;
	u8 mac_type = UNICAST_ADDRESS;

#ifdef BNX2X_STOP_ON_ERROR
	if (unlikely(bp->panic))
		return NETDEV_TX_BUSY;
#endif

2861 2862 2863 2864 2865 2866 2867 2868 2869 2870 2871 2872 2873 2874 2875 2876 2877 2878 2879 2880 2881 2882 2883
	txq_index = skb_get_queue_mapping(skb);
	txq = netdev_get_tx_queue(dev, txq_index);

	BUG_ON(txq_index >= MAX_ETH_TXQ_IDX(bp) + FCOE_PRESENT);

	/* decode the fastpath index and the cos index from the txq */
	fp_index = TXQ_TO_FP(txq_index);
	txdata_index = TXQ_TO_COS(txq_index);

#ifdef BCM_CNIC
	/*
	 * Override the above for the FCoE queue:
	 *   - FCoE fp entry is right after the ETH entries.
	 *   - FCoE L2 queue uses bp->txdata[0] only.
	 */
	if (unlikely(!NO_FCOE(bp) && (txq_index ==
				      bnx2x_fcoe_tx(bp, txq_index)))) {
		fp_index = FCOE_IDX;
		txdata_index = 0;
	}
#endif

	/* enable this debug print to view the transmission queue being used
M
Merav Sicron 已提交
2884
	DP(NETIF_MSG_TX_QUEUED, "indices: txq %d, fp %d, txdata %d\n",
2885
	   txq_index, fp_index, txdata_index); */
D
Dmitry Kravkov 已提交
2886

2887
	/* locate the fastpath and the txdata */
D
Dmitry Kravkov 已提交
2888
	fp = &bp->fp[fp_index];
2889 2890 2891
	txdata = &fp->txdata[txdata_index];

	/* enable this debug print to view the tranmission details
M
Merav Sicron 已提交
2892 2893
	DP(NETIF_MSG_TX_QUEUED,
	   "transmitting packet cid %d fp index %d txdata_index %d tx_data ptr %p fp pointer %p\n",
2894
	   txdata->cid, fp_index, txdata_index, txdata, fp); */
D
Dmitry Kravkov 已提交
2895

2896 2897
	if (unlikely(bnx2x_tx_avail(bp, txdata) <
		     (skb_shinfo(skb)->nr_frags + 3))) {
D
Dmitry Kravkov 已提交
2898 2899 2900 2901 2902 2903
		fp->eth_q_stats.driver_xoff++;
		netif_tx_stop_queue(txq);
		BNX2X_ERR("BUG! Tx ring full when queue awake!\n");
		return NETDEV_TX_BUSY;
	}

M
Merav Sicron 已提交
2904 2905
	DP(NETIF_MSG_TX_QUEUED,
	   "queue[%d]: SKB: summed %x  protocol %x protocol(%x,%x) gso type %x  xmit_type %x\n",
2906
	   txq_index, skb->ip_summed, skb->protocol, ipv6_hdr(skb)->nexthdr,
D
Dmitry Kravkov 已提交
2907 2908 2909 2910 2911 2912 2913 2914 2915 2916 2917 2918 2919 2920 2921 2922 2923 2924 2925 2926
	   ip_hdr(skb)->protocol, skb_shinfo(skb)->gso_type, xmit_type);

	eth = (struct ethhdr *)skb->data;

	/* set flag according to packet type (UNICAST_ADDRESS is default)*/
	if (unlikely(is_multicast_ether_addr(eth->h_dest))) {
		if (is_broadcast_ether_addr(eth->h_dest))
			mac_type = BROADCAST_ADDRESS;
		else
			mac_type = MULTICAST_ADDRESS;
	}

#if (MAX_SKB_FRAGS >= MAX_FETCH_BD - 3)
	/* First, check if we need to linearize the skb (due to FW
	   restrictions). No need to check fragmentation if page size > 8K
	   (there will be no violation to FW restrictions) */
	if (bnx2x_pkt_req_lin(bp, skb, xmit_type)) {
		/* Statistics of linearization */
		bp->lin_cnt++;
		if (skb_linearize(skb) != 0) {
M
Merav Sicron 已提交
2927 2928
			DP(NETIF_MSG_TX_QUEUED,
			   "SKB linearization failed - silently dropping this SKB\n");
D
Dmitry Kravkov 已提交
2929 2930 2931 2932 2933
			dev_kfree_skb_any(skb);
			return NETDEV_TX_OK;
		}
	}
#endif
2934 2935 2936 2937
	/* Map skb linear data for DMA */
	mapping = dma_map_single(&bp->pdev->dev, skb->data,
				 skb_headlen(skb), DMA_TO_DEVICE);
	if (unlikely(dma_mapping_error(&bp->pdev->dev, mapping))) {
M
Merav Sicron 已提交
2938 2939
		DP(NETIF_MSG_TX_QUEUED,
		   "SKB mapping failed - silently dropping this SKB\n");
2940 2941 2942
		dev_kfree_skb_any(skb);
		return NETDEV_TX_OK;
	}
D
Dmitry Kravkov 已提交
2943 2944 2945 2946 2947 2948 2949 2950 2951
	/*
	Please read carefully. First we use one BD which we mark as start,
	then we have a parsing info BD (used for TSO or xsum),
	and only then we have the rest of the TSO BDs.
	(don't forget to mark the last one as last,
	and to unmap only AFTER you write to the BD ...)
	And above all, all pdb sizes are in words - NOT DWORDS!
	*/

2952 2953 2954
	/* get current pkt produced now - advance it just before sending packet
	 * since mapping of pages may fail and cause packet to be dropped
	 */
2955 2956
	pkt_prod = txdata->tx_pkt_prod;
	bd_prod = TX_BD(txdata->tx_bd_prod);
D
Dmitry Kravkov 已提交
2957

2958 2959 2960 2961
	/* get a tx_buf and first BD
	 * tx_start_bd may be changed during SPLIT,
	 * but first_bd will always stay first
	 */
2962 2963
	tx_buf = &txdata->tx_buf_ring[TX_BD(pkt_prod)];
	tx_start_bd = &txdata->tx_desc_ring[bd_prod].start_bd;
2964
	first_bd = tx_start_bd;
D
Dmitry Kravkov 已提交
2965 2966

	tx_start_bd->bd_flags.as_bitfield = ETH_TX_BD_FLAGS_START_BD;
D
Dmitry Kravkov 已提交
2967 2968 2969
	SET_FLAG(tx_start_bd->general_data, ETH_TX_START_BD_ETH_ADDR_TYPE,
		 mac_type);

D
Dmitry Kravkov 已提交
2970
	/* header nbd */
D
Dmitry Kravkov 已提交
2971
	SET_FLAG(tx_start_bd->general_data, ETH_TX_START_BD_HDR_NBDS, 1);
D
Dmitry Kravkov 已提交
2972 2973

	/* remember the first BD of the packet */
2974
	tx_buf->first_bd = txdata->tx_bd_prod;
D
Dmitry Kravkov 已提交
2975 2976 2977 2978 2979
	tx_buf->skb = skb;
	tx_buf->flags = 0;

	DP(NETIF_MSG_TX_QUEUED,
	   "sending pkt %u @%p  next_idx %u  bd %u @%p\n",
2980
	   pkt_prod, tx_buf, txdata->tx_pkt_prod, bd_prod, tx_start_bd);
D
Dmitry Kravkov 已提交
2981

2982
	if (vlan_tx_tag_present(skb)) {
2983 2984 2985 2986
		tx_start_bd->vlan_or_ethertype =
		    cpu_to_le16(vlan_tx_tag_get(skb));
		tx_start_bd->bd_flags.as_bitfield |=
		    (X_ETH_OUTBAND_VLAN << ETH_TX_BD_FLAGS_VLAN_MODE_SHIFT);
D
Dmitry Kravkov 已提交
2987
	} else
2988
		tx_start_bd->vlan_or_ethertype = cpu_to_le16(pkt_prod);
D
Dmitry Kravkov 已提交
2989 2990 2991 2992

	/* turn on parsing and get a BD */
	bd_prod = TX_BD(NEXT_TX_IDX(bd_prod));

2993 2994
	if (xmit_type & XMIT_CSUM)
		bnx2x_set_sbd_csum(bp, skb, tx_start_bd, xmit_type);
D
Dmitry Kravkov 已提交
2995

2996
	if (!CHIP_IS_E1x(bp)) {
2997
		pbd_e2 = &txdata->tx_desc_ring[bd_prod].parse_bd_e2;
D
Dmitry Kravkov 已提交
2998 2999 3000
		memset(pbd_e2, 0, sizeof(struct eth_tx_parse_bd_e2));
		/* Set PBD in checksum offload case */
		if (xmit_type & XMIT_CSUM)
3001 3002 3003
			hlen = bnx2x_set_pbd_csum_e2(bp, skb,
						     &pbd_e2_parsing_data,
						     xmit_type);
3004 3005 3006 3007 3008 3009 3010 3011 3012 3013 3014 3015 3016 3017
		if (IS_MF_SI(bp)) {
			/*
			 * fill in the MAC addresses in the PBD - for local
			 * switching
			 */
			bnx2x_set_fw_mac_addr(&pbd_e2->src_mac_addr_hi,
					      &pbd_e2->src_mac_addr_mid,
					      &pbd_e2->src_mac_addr_lo,
					      eth->h_source);
			bnx2x_set_fw_mac_addr(&pbd_e2->dst_mac_addr_hi,
					      &pbd_e2->dst_mac_addr_mid,
					      &pbd_e2->dst_mac_addr_lo,
					      eth->h_dest);
		}
D
Dmitry Kravkov 已提交
3018
	} else {
3019
		pbd_e1x = &txdata->tx_desc_ring[bd_prod].parse_bd_e1x;
D
Dmitry Kravkov 已提交
3020 3021 3022 3023
		memset(pbd_e1x, 0, sizeof(struct eth_tx_parse_bd_e1x));
		/* Set PBD in checksum offload case */
		if (xmit_type & XMIT_CSUM)
			hlen = bnx2x_set_pbd_csum(bp, skb, pbd_e1x, xmit_type);
D
Dmitry Kravkov 已提交
3024 3025 3026

	}

D
Dmitry Kravkov 已提交
3027
	/* Setup the data pointer of the first BD of the packet */
D
Dmitry Kravkov 已提交
3028 3029
	tx_start_bd->addr_hi = cpu_to_le32(U64_HI(mapping));
	tx_start_bd->addr_lo = cpu_to_le32(U64_LO(mapping));
3030
	nbd = 2; /* start_bd + pbd + frags (updated when pages are mapped) */
D
Dmitry Kravkov 已提交
3031 3032 3033
	tx_start_bd->nbytes = cpu_to_le16(skb_headlen(skb));
	pkt_size = tx_start_bd->nbytes;

M
Merav Sicron 已提交
3034 3035
	DP(NETIF_MSG_TX_QUEUED,
	   "first bd @%p  addr (%x:%x)  nbd %d  nbytes %d  flags %x  vlan %x\n",
D
Dmitry Kravkov 已提交
3036 3037
	   tx_start_bd, tx_start_bd->addr_hi, tx_start_bd->addr_lo,
	   le16_to_cpu(tx_start_bd->nbd), le16_to_cpu(tx_start_bd->nbytes),
3038 3039
	   tx_start_bd->bd_flags.as_bitfield,
	   le16_to_cpu(tx_start_bd->vlan_or_ethertype));
D
Dmitry Kravkov 已提交
3040 3041 3042 3043 3044 3045 3046 3047 3048 3049 3050

	if (xmit_type & XMIT_GSO) {

		DP(NETIF_MSG_TX_QUEUED,
		   "TSO packet len %d  hlen %d  total len %d  tso size %d\n",
		   skb->len, hlen, skb_headlen(skb),
		   skb_shinfo(skb)->gso_size);

		tx_start_bd->bd_flags.as_bitfield |= ETH_TX_BD_FLAGS_SW_LSO;

		if (unlikely(skb_headlen(skb) > hlen))
3051 3052 3053
			bd_prod = bnx2x_tx_split(bp, txdata, tx_buf,
						 &tx_start_bd, hlen,
						 bd_prod, ++nbd);
3054
		if (!CHIP_IS_E1x(bp))
3055 3056
			bnx2x_set_pbd_gso_e2(skb, &pbd_e2_parsing_data,
					     xmit_type);
D
Dmitry Kravkov 已提交
3057 3058
		else
			bnx2x_set_pbd_gso(skb, pbd_e1x, xmit_type);
D
Dmitry Kravkov 已提交
3059
	}
3060 3061 3062 3063 3064 3065 3066

	/* Set the PBD's parsing_data field if not zero
	 * (for the chips newer than 57711).
	 */
	if (pbd_e2_parsing_data)
		pbd_e2->parsing_data = cpu_to_le32(pbd_e2_parsing_data);

D
Dmitry Kravkov 已提交
3067 3068
	tx_data_bd = (struct eth_tx_bd *)tx_start_bd;

D
Dmitry Kravkov 已提交
3069
	/* Handle fragmented skb */
D
Dmitry Kravkov 已提交
3070 3071 3072
	for (i = 0; i < skb_shinfo(skb)->nr_frags; i++) {
		skb_frag_t *frag = &skb_shinfo(skb)->frags[i];

E
Eric Dumazet 已提交
3073 3074
		mapping = skb_frag_dma_map(&bp->pdev->dev, frag, 0,
					   skb_frag_size(frag), DMA_TO_DEVICE);
3075
		if (unlikely(dma_mapping_error(&bp->pdev->dev, mapping))) {
T
Tom Herbert 已提交
3076
			unsigned int pkts_compl = 0, bytes_compl = 0;
3077

M
Merav Sicron 已提交
3078 3079
			DP(NETIF_MSG_TX_QUEUED,
			   "Unable to map page - dropping packet...\n");
3080 3081 3082 3083 3084 3085 3086

			/* we need unmap all buffers already mapped
			 * for this SKB;
			 * first_bd->nbd need to be properly updated
			 * before call to bnx2x_free_tx_pkt
			 */
			first_bd->nbd = cpu_to_le16(nbd);
3087
			bnx2x_free_tx_pkt(bp, txdata,
T
Tom Herbert 已提交
3088 3089
					  TX_BD(txdata->tx_pkt_prod),
					  &pkts_compl, &bytes_compl);
3090 3091 3092
			return NETDEV_TX_OK;
		}

D
Dmitry Kravkov 已提交
3093
		bd_prod = TX_BD(NEXT_TX_IDX(bd_prod));
3094
		tx_data_bd = &txdata->tx_desc_ring[bd_prod].reg_bd;
D
Dmitry Kravkov 已提交
3095
		if (total_pkt_bd == NULL)
3096
			total_pkt_bd = &txdata->tx_desc_ring[bd_prod].reg_bd;
D
Dmitry Kravkov 已提交
3097 3098 3099

		tx_data_bd->addr_hi = cpu_to_le32(U64_HI(mapping));
		tx_data_bd->addr_lo = cpu_to_le32(U64_LO(mapping));
E
Eric Dumazet 已提交
3100 3101
		tx_data_bd->nbytes = cpu_to_le16(skb_frag_size(frag));
		le16_add_cpu(&pkt_size, skb_frag_size(frag));
3102
		nbd++;
D
Dmitry Kravkov 已提交
3103 3104 3105 3106 3107 3108 3109 3110 3111

		DP(NETIF_MSG_TX_QUEUED,
		   "frag %d  bd @%p  addr (%x:%x)  nbytes %d\n",
		   i, tx_data_bd, tx_data_bd->addr_hi, tx_data_bd->addr_lo,
		   le16_to_cpu(tx_data_bd->nbytes));
	}

	DP(NETIF_MSG_TX_QUEUED, "last bd @%p\n", tx_data_bd);

3112 3113 3114
	/* update with actual num BDs */
	first_bd->nbd = cpu_to_le16(nbd);

D
Dmitry Kravkov 已提交
3115 3116 3117 3118 3119 3120 3121 3122
	bd_prod = TX_BD(NEXT_TX_IDX(bd_prod));

	/* now send a tx doorbell, counting the next BD
	 * if the packet contains or ends with it
	 */
	if (TX_BD_POFF(bd_prod) < nbd)
		nbd++;

3123 3124 3125 3126 3127 3128 3129
	/* total_pkt_bytes should be set on the first data BD if
	 * it's not an LSO packet and there is more than one
	 * data BD. In this case pkt_size is limited by an MTU value.
	 * However we prefer to set it for an LSO packet (while we don't
	 * have to) in order to save some CPU cycles in a none-LSO
	 * case, when we much more care about them.
	 */
D
Dmitry Kravkov 已提交
3130 3131 3132
	if (total_pkt_bd != NULL)
		total_pkt_bd->total_pkt_bytes = pkt_size;

3133
	if (pbd_e1x)
D
Dmitry Kravkov 已提交
3134
		DP(NETIF_MSG_TX_QUEUED,
M
Merav Sicron 已提交
3135
		   "PBD (E1X) @%p  ip_data %x  ip_hlen %u  ip_id %u  lso_mss %u  tcp_flags %x  xsum %x  seq %u  hlen %u\n",
3136 3137 3138 3139
		   pbd_e1x, pbd_e1x->global_data, pbd_e1x->ip_hlen_w,
		   pbd_e1x->ip_id, pbd_e1x->lso_mss, pbd_e1x->tcp_flags,
		   pbd_e1x->tcp_pseudo_csum, pbd_e1x->tcp_send_seq,
		    le16_to_cpu(pbd_e1x->total_hlen_w));
D
Dmitry Kravkov 已提交
3140 3141 3142 3143 3144 3145 3146
	if (pbd_e2)
		DP(NETIF_MSG_TX_QUEUED,
		   "PBD (E2) @%p  dst %x %x %x src %x %x %x parsing_data %x\n",
		   pbd_e2, pbd_e2->dst_mac_addr_hi, pbd_e2->dst_mac_addr_mid,
		   pbd_e2->dst_mac_addr_lo, pbd_e2->src_mac_addr_hi,
		   pbd_e2->src_mac_addr_mid, pbd_e2->src_mac_addr_lo,
		   pbd_e2->parsing_data);
D
Dmitry Kravkov 已提交
3147 3148
	DP(NETIF_MSG_TX_QUEUED, "doorbell: nbd %d  bd %u\n", nbd, bd_prod);

T
Tom Herbert 已提交
3149 3150
	netdev_tx_sent_queue(txq, skb->len);

3151 3152
	skb_tx_timestamp(skb);

3153
	txdata->tx_pkt_prod++;
D
Dmitry Kravkov 已提交
3154 3155 3156 3157 3158 3159 3160 3161 3162
	/*
	 * Make sure that the BD data is updated before updating the producer
	 * since FW might read the BD right after the producer is updated.
	 * This is only applicable for weak-ordered memory model archs such
	 * as IA-64. The following barrier is also mandatory since FW will
	 * assumes packets must have BDs.
	 */
	wmb();

3163
	txdata->tx_db.data.prod += nbd;
D
Dmitry Kravkov 已提交
3164
	barrier();
D
Dmitry Kravkov 已提交
3165

3166
	DOORBELL(bp, txdata->cid, txdata->tx_db.raw);
D
Dmitry Kravkov 已提交
3167 3168 3169

	mmiowb();

3170
	txdata->tx_bd_prod += nbd;
D
Dmitry Kravkov 已提交
3171

3172
	if (unlikely(bnx2x_tx_avail(bp, txdata) < MAX_SKB_FRAGS + 4)) {
D
Dmitry Kravkov 已提交
3173 3174 3175 3176 3177 3178 3179 3180
		netif_tx_stop_queue(txq);

		/* paired memory barrier is in bnx2x_tx_int(), we have to keep
		 * ordering of set_bit() in netif_tx_stop_queue() and read of
		 * fp->bd_tx_cons */
		smp_mb();

		fp->eth_q_stats.driver_xoff++;
3181
		if (bnx2x_tx_avail(bp, txdata) >= MAX_SKB_FRAGS + 4)
D
Dmitry Kravkov 已提交
3182 3183
			netif_tx_wake_queue(txq);
	}
3184
	txdata->tx_pkt++;
D
Dmitry Kravkov 已提交
3185 3186 3187

	return NETDEV_TX_OK;
}
D
Dmitry Kravkov 已提交
3188

3189 3190 3191 3192 3193 3194 3195 3196 3197 3198 3199 3200 3201 3202 3203 3204 3205 3206 3207 3208 3209 3210 3211 3212
/**
 * bnx2x_setup_tc - routine to configure net_device for multi tc
 *
 * @netdev: net device to configure
 * @tc: number of traffic classes to enable
 *
 * callback connected to the ndo_setup_tc function pointer
 */
int bnx2x_setup_tc(struct net_device *dev, u8 num_tc)
{
	int cos, prio, count, offset;
	struct bnx2x *bp = netdev_priv(dev);

	/* setup tc must be called under rtnl lock */
	ASSERT_RTNL();

	/* no traffic classes requested. aborting */
	if (!num_tc) {
		netdev_reset_tc(dev);
		return 0;
	}

	/* requested to support too many traffic classes */
	if (num_tc > bp->max_cos) {
M
Merav Sicron 已提交
3213 3214
		BNX2X_ERR("support for too many traffic classes requested: %d. max supported is %d\n",
			  num_tc, bp->max_cos);
3215 3216 3217 3218 3219
		return -EINVAL;
	}

	/* declare amount of supported traffic classes */
	if (netdev_set_num_tc(dev, num_tc)) {
M
Merav Sicron 已提交
3220
		BNX2X_ERR("failed to declare %d traffic classes\n", num_tc);
3221 3222 3223 3224 3225 3226
		return -EINVAL;
	}

	/* configure priority to traffic class mapping */
	for (prio = 0; prio < BNX2X_MAX_PRIORITY; prio++) {
		netdev_set_prio_tc_map(dev, prio, bp->prio_to_cos[prio]);
M
Merav Sicron 已提交
3227 3228
		DP(BNX2X_MSG_SP | NETIF_MSG_IFUP,
		   "mapping priority %d to tc %d\n",
3229 3230 3231 3232 3233 3234 3235 3236
		   prio, bp->prio_to_cos[prio]);
	}


	/* Use this configuration to diffrentiate tc0 from other COSes
	   This can be used for ets or pfc, and save the effort of setting
	   up a multio class queue disc or negotiating DCBX with a switch
	netdev_set_prio_tc_map(dev, 0, 0);
3237
	DP(BNX2X_MSG_SP, "mapping priority %d to tc %d\n", 0, 0);
3238 3239
	for (prio = 1; prio < 16; prio++) {
		netdev_set_prio_tc_map(dev, prio, 1);
3240
		DP(BNX2X_MSG_SP, "mapping priority %d to tc %d\n", prio, 1);
3241 3242 3243 3244 3245 3246 3247
	} */

	/* configure traffic class to transmission queue mapping */
	for (cos = 0; cos < bp->max_cos; cos++) {
		count = BNX2X_NUM_ETH_QUEUES(bp);
		offset = cos * MAX_TXQS_PER_COS;
		netdev_set_tc_queue(dev, cos, count, offset);
M
Merav Sicron 已提交
3248 3249
		DP(BNX2X_MSG_SP | NETIF_MSG_IFUP,
		   "mapping tc %d to offset %d count %d\n",
3250 3251 3252 3253 3254 3255
		   cos, offset, count);
	}

	return 0;
}

D
Dmitry Kravkov 已提交
3256 3257 3258 3259 3260
/* called with rtnl_lock */
int bnx2x_change_mac_addr(struct net_device *dev, void *p)
{
	struct sockaddr *addr = p;
	struct bnx2x *bp = netdev_priv(dev);
3261
	int rc = 0;
D
Dmitry Kravkov 已提交
3262

M
Merav Sicron 已提交
3263 3264
	if (!bnx2x_is_valid_ether_addr(bp, addr->sa_data)) {
		BNX2X_ERR("Requested MAC address is not valid\n");
D
Dmitry Kravkov 已提交
3265
		return -EINVAL;
M
Merav Sicron 已提交
3266
	}
D
Dmitry Kravkov 已提交
3267 3268

#ifdef BCM_CNIC
B
Barak Witkowski 已提交
3269 3270
	if ((IS_MF_STORAGE_SD(bp) || IS_MF_FCOE_AFEX(bp)) &&
	    !is_zero_ether_addr(addr->sa_data)) {
M
Merav Sicron 已提交
3271
		BNX2X_ERR("Can't configure non-zero address on iSCSI or FCoE functions in MF-SD mode\n");
D
Dmitry Kravkov 已提交
3272
		return -EINVAL;
M
Merav Sicron 已提交
3273
	}
D
Dmitry Kravkov 已提交
3274
#endif
D
Dmitry Kravkov 已提交
3275

3276 3277 3278 3279 3280 3281
	if (netif_running(dev))  {
		rc = bnx2x_set_eth_mac(bp, false);
		if (rc)
			return rc;
	}

3282
	dev->addr_assign_type &= ~NET_ADDR_RANDOM;
D
Dmitry Kravkov 已提交
3283
	memcpy(dev->dev_addr, addr->sa_data, dev->addr_len);
3284

3285
	if (netif_running(dev))
3286
		rc = bnx2x_set_eth_mac(bp, true);
D
Dmitry Kravkov 已提交
3287

3288
	return rc;
D
Dmitry Kravkov 已提交
3289 3290
}

3291 3292 3293 3294
static void bnx2x_free_fp_mem_at(struct bnx2x *bp, int fp_index)
{
	union host_hc_status_block *sb = &bnx2x_fp(bp, fp_index, status_blk);
	struct bnx2x_fastpath *fp = &bp->fp[fp_index];
3295
	u8 cos;
3296 3297 3298 3299 3300 3301 3302 3303 3304 3305

	/* Common */
#ifdef BCM_CNIC
	if (IS_FCOE_IDX(fp_index)) {
		memset(sb, 0, sizeof(union host_hc_status_block));
		fp->status_blk_mapping = 0;

	} else {
#endif
		/* status blocks */
3306
		if (!CHIP_IS_E1x(bp))
3307 3308 3309 3310 3311 3312 3313 3314 3315 3316 3317 3318 3319 3320 3321 3322 3323 3324 3325 3326 3327 3328 3329 3330 3331 3332 3333 3334 3335 3336 3337 3338 3339 3340 3341 3342 3343
			BNX2X_PCI_FREE(sb->e2_sb,
				       bnx2x_fp(bp, fp_index,
						status_blk_mapping),
				       sizeof(struct host_hc_status_block_e2));
		else
			BNX2X_PCI_FREE(sb->e1x_sb,
				       bnx2x_fp(bp, fp_index,
						status_blk_mapping),
				       sizeof(struct host_hc_status_block_e1x));
#ifdef BCM_CNIC
	}
#endif
	/* Rx */
	if (!skip_rx_queue(bp, fp_index)) {
		bnx2x_free_rx_bds(fp);

		/* fastpath rx rings: rx_buf rx_desc rx_comp */
		BNX2X_FREE(bnx2x_fp(bp, fp_index, rx_buf_ring));
		BNX2X_PCI_FREE(bnx2x_fp(bp, fp_index, rx_desc_ring),
			       bnx2x_fp(bp, fp_index, rx_desc_mapping),
			       sizeof(struct eth_rx_bd) * NUM_RX_BD);

		BNX2X_PCI_FREE(bnx2x_fp(bp, fp_index, rx_comp_ring),
			       bnx2x_fp(bp, fp_index, rx_comp_mapping),
			       sizeof(struct eth_fast_path_rx_cqe) *
			       NUM_RCQ_BD);

		/* SGE ring */
		BNX2X_FREE(bnx2x_fp(bp, fp_index, rx_page_ring));
		BNX2X_PCI_FREE(bnx2x_fp(bp, fp_index, rx_sge_ring),
			       bnx2x_fp(bp, fp_index, rx_sge_mapping),
			       BCM_PAGE_SIZE * NUM_RX_SGE_PAGES);
	}

	/* Tx */
	if (!skip_tx_queue(bp, fp_index)) {
		/* fastpath tx rings: tx_buf tx_desc */
3344 3345 3346
		for_each_cos_in_tx_queue(fp, cos) {
			struct bnx2x_fp_txdata *txdata = &fp->txdata[cos];

M
Merav Sicron 已提交
3347
			DP(NETIF_MSG_IFDOWN,
3348
			   "freeing tx memory of fp %d cos %d cid %d\n",
3349 3350 3351 3352 3353 3354 3355
			   fp_index, cos, txdata->cid);

			BNX2X_FREE(txdata->tx_buf_ring);
			BNX2X_PCI_FREE(txdata->tx_desc_ring,
				txdata->tx_desc_mapping,
				sizeof(union eth_tx_bd_types) * NUM_TX_BD);
		}
3356 3357 3358 3359 3360 3361 3362 3363 3364 3365 3366
	}
	/* end of fastpath */
}

void bnx2x_free_fp_mem(struct bnx2x *bp)
{
	int i;
	for_each_queue(bp, i)
		bnx2x_free_fp_mem_at(bp, i);
}

E
Eric Dumazet 已提交
3367
static void set_sb_shortcuts(struct bnx2x *bp, int index)
3368 3369
{
	union host_hc_status_block status_blk = bnx2x_fp(bp, index, status_blk);
3370
	if (!CHIP_IS_E1x(bp)) {
3371 3372 3373 3374 3375 3376 3377 3378 3379 3380 3381 3382
		bnx2x_fp(bp, index, sb_index_values) =
			(__le16 *)status_blk.e2_sb->sb.index_values;
		bnx2x_fp(bp, index, sb_running_index) =
			(__le16 *)status_blk.e2_sb->sb.running_index;
	} else {
		bnx2x_fp(bp, index, sb_index_values) =
			(__le16 *)status_blk.e1x_sb->sb.index_values;
		bnx2x_fp(bp, index, sb_running_index) =
			(__le16 *)status_blk.e1x_sb->sb.running_index;
	}
}

E
Eric Dumazet 已提交
3383 3384 3385 3386 3387 3388 3389 3390 3391 3392 3393 3394 3395 3396 3397 3398 3399 3400 3401 3402 3403 3404 3405 3406 3407 3408 3409 3410 3411 3412 3413 3414 3415 3416 3417 3418 3419 3420 3421 3422 3423 3424 3425 3426 3427 3428 3429 3430 3431 3432 3433 3434 3435 3436 3437 3438 3439
/* Returns the number of actually allocated BDs */
static int bnx2x_alloc_rx_bds(struct bnx2x_fastpath *fp,
			      int rx_ring_size)
{
	struct bnx2x *bp = fp->bp;
	u16 ring_prod, cqe_ring_prod;
	int i, failure_cnt = 0;

	fp->rx_comp_cons = 0;
	cqe_ring_prod = ring_prod = 0;

	/* This routine is called only during fo init so
	 * fp->eth_q_stats.rx_skb_alloc_failed = 0
	 */
	for (i = 0; i < rx_ring_size; i++) {
		if (bnx2x_alloc_rx_data(bp, fp, ring_prod) < 0) {
			failure_cnt++;
			continue;
		}
		ring_prod = NEXT_RX_IDX(ring_prod);
		cqe_ring_prod = NEXT_RCQ_IDX(cqe_ring_prod);
		WARN_ON(ring_prod <= (i - failure_cnt));
	}

	if (failure_cnt)
		BNX2X_ERR("was only able to allocate %d rx skbs on queue[%d]\n",
			  i - failure_cnt, fp->index);

	fp->rx_bd_prod = ring_prod;
	/* Limit the CQE producer by the CQE ring size */
	fp->rx_comp_prod = min_t(u16, NUM_RCQ_RINGS*RCQ_DESC_CNT,
			       cqe_ring_prod);
	fp->rx_pkt = fp->rx_calls = 0;

	fp->eth_q_stats.rx_skb_alloc_failed += failure_cnt;

	return i - failure_cnt;
}

static void bnx2x_set_next_page_rx_cq(struct bnx2x_fastpath *fp)
{
	int i;

	for (i = 1; i <= NUM_RCQ_RINGS; i++) {
		struct eth_rx_cqe_next_page *nextpg;

		nextpg = (struct eth_rx_cqe_next_page *)
			&fp->rx_comp_ring[RCQ_DESC_CNT * i - 1];
		nextpg->addr_hi =
			cpu_to_le32(U64_HI(fp->rx_comp_mapping +
				   BCM_PAGE_SIZE*(i % NUM_RCQ_RINGS)));
		nextpg->addr_lo =
			cpu_to_le32(U64_LO(fp->rx_comp_mapping +
				   BCM_PAGE_SIZE*(i % NUM_RCQ_RINGS)));
	}
}

3440 3441 3442 3443 3444
static int bnx2x_alloc_fp_mem_at(struct bnx2x *bp, int index)
{
	union host_hc_status_block *sb;
	struct bnx2x_fastpath *fp = &bp->fp[index];
	int ring_size = 0;
3445
	u8 cos;
3446
	int rx_ring_size = 0;
3447

D
Dmitry Kravkov 已提交
3448
#ifdef BCM_CNIC
B
Barak Witkowski 已提交
3449 3450
	if (!bp->rx_ring_size &&
	    (IS_MF_STORAGE_SD(bp) || IS_MF_FCOE_AFEX(bp))) {
D
Dmitry Kravkov 已提交
3451 3452 3453 3454
		rx_ring_size = MIN_RX_SIZE_NONTPA;
		bp->rx_ring_size = rx_ring_size;
	} else
#endif
3455
	if (!bp->rx_ring_size) {
3456 3457
		u32 cfg = SHMEM_RD(bp,
			     dev_info.port_hw_config[BP_PORT(bp)].default_cfg);
3458

3459 3460
		rx_ring_size = MAX_RX_AVAIL/BNX2X_NUM_RX_QUEUES(bp);

3461 3462 3463 3464 3465
		/* Dercease ring size for 1G functions */
		if ((cfg & PORT_HW_CFG_NET_SERDES_IF_MASK) ==
		    PORT_HW_CFG_NET_SERDES_IF_SGMII)
			rx_ring_size /= 10;

3466 3467 3468 3469 3470
		/* allocate at least number of buffers required by FW */
		rx_ring_size = max_t(int, bp->disable_tpa ? MIN_RX_SIZE_NONTPA :
				     MIN_RX_SIZE_TPA, rx_ring_size);

		bp->rx_ring_size = rx_ring_size;
D
Dmitry Kravkov 已提交
3471
	} else /* if rx_ring_size specified - use it */
3472
		rx_ring_size = bp->rx_ring_size;
3473 3474 3475 3476 3477 3478 3479

	/* Common */
	sb = &bnx2x_fp(bp, index, status_blk);
#ifdef BCM_CNIC
	if (!IS_FCOE_IDX(index)) {
#endif
		/* status blocks */
3480
		if (!CHIP_IS_E1x(bp))
3481 3482 3483 3484 3485 3486 3487 3488 3489 3490
			BNX2X_PCI_ALLOC(sb->e2_sb,
				&bnx2x_fp(bp, index, status_blk_mapping),
				sizeof(struct host_hc_status_block_e2));
		else
			BNX2X_PCI_ALLOC(sb->e1x_sb,
				&bnx2x_fp(bp, index, status_blk_mapping),
			    sizeof(struct host_hc_status_block_e1x));
#ifdef BCM_CNIC
	}
#endif
3491 3492 3493 3494 3495 3496

	/* FCoE Queue uses Default SB and doesn't ACK the SB, thus no need to
	 * set shortcuts for it.
	 */
	if (!IS_FCOE_IDX(index))
		set_sb_shortcuts(bp, index);
3497 3498 3499 3500

	/* Tx */
	if (!skip_tx_queue(bp, index)) {
		/* fastpath tx rings: tx_buf tx_desc */
3501 3502 3503
		for_each_cos_in_tx_queue(fp, cos) {
			struct bnx2x_fp_txdata *txdata = &fp->txdata[cos];

M
Merav Sicron 已提交
3504 3505
			DP(NETIF_MSG_IFUP,
			   "allocating tx memory of fp %d cos %d\n",
3506 3507 3508
			   index, cos);

			BNX2X_ALLOC(txdata->tx_buf_ring,
3509
				sizeof(struct sw_tx_bd) * NUM_TX_BD);
3510 3511
			BNX2X_PCI_ALLOC(txdata->tx_desc_ring,
				&txdata->tx_desc_mapping,
3512
				sizeof(union eth_tx_bd_types) * NUM_TX_BD);
3513
		}
3514 3515 3516 3517 3518 3519 3520 3521 3522 3523 3524 3525 3526 3527 3528 3529 3530 3531 3532 3533 3534 3535 3536 3537 3538 3539 3540 3541 3542 3543 3544 3545 3546 3547 3548 3549 3550 3551 3552 3553 3554 3555
	}

	/* Rx */
	if (!skip_rx_queue(bp, index)) {
		/* fastpath rx rings: rx_buf rx_desc rx_comp */
		BNX2X_ALLOC(bnx2x_fp(bp, index, rx_buf_ring),
				sizeof(struct sw_rx_bd) * NUM_RX_BD);
		BNX2X_PCI_ALLOC(bnx2x_fp(bp, index, rx_desc_ring),
				&bnx2x_fp(bp, index, rx_desc_mapping),
				sizeof(struct eth_rx_bd) * NUM_RX_BD);

		BNX2X_PCI_ALLOC(bnx2x_fp(bp, index, rx_comp_ring),
				&bnx2x_fp(bp, index, rx_comp_mapping),
				sizeof(struct eth_fast_path_rx_cqe) *
				NUM_RCQ_BD);

		/* SGE ring */
		BNX2X_ALLOC(bnx2x_fp(bp, index, rx_page_ring),
				sizeof(struct sw_rx_page) * NUM_RX_SGE);
		BNX2X_PCI_ALLOC(bnx2x_fp(bp, index, rx_sge_ring),
				&bnx2x_fp(bp, index, rx_sge_mapping),
				BCM_PAGE_SIZE * NUM_RX_SGE_PAGES);
		/* RX BD ring */
		bnx2x_set_next_page_rx_bd(fp);

		/* CQ ring */
		bnx2x_set_next_page_rx_cq(fp);

		/* BDs */
		ring_size = bnx2x_alloc_rx_bds(fp, rx_ring_size);
		if (ring_size < rx_ring_size)
			goto alloc_mem_err;
	}

	return 0;

/* handles low memory cases */
alloc_mem_err:
	BNX2X_ERR("Unable to allocate full memory for queue %d (size %d)\n",
						index, ring_size);
	/* FW will drop all packets if queue is not big enough,
	 * In these cases we disable the queue
3556
	 * Min size is different for OOO, TPA and non-TPA queues
3557 3558
	 */
	if (ring_size < (fp->disable_tpa ?
D
Dmitry Kravkov 已提交
3559
				MIN_RX_SIZE_NONTPA : MIN_RX_SIZE_TPA)) {
3560 3561 3562 3563 3564 3565 3566 3567 3568 3569 3570 3571 3572 3573
			/* release memory allocated for this queue */
			bnx2x_free_fp_mem_at(bp, index);
			return -ENOMEM;
	}
	return 0;
}

int bnx2x_alloc_fp_mem(struct bnx2x *bp)
{
	int i;

	/**
	 * 1. Allocate FP for leading - fatal if error
	 * 2. {CNIC} Allocate FCoE FP - fatal if error
3574 3575
	 * 3. {CNIC} Allocate OOO + FWD - disable OOO if error
	 * 4. Allocate RSS - fix number of queues if error
3576 3577 3578 3579 3580
	 */

	/* leading */
	if (bnx2x_alloc_fp_mem_at(bp, 0))
		return -ENOMEM;
3581

3582
#ifdef BCM_CNIC
3583 3584 3585 3586 3587 3588 3589
	if (!NO_FCOE(bp))
		/* FCoE */
		if (bnx2x_alloc_fp_mem_at(bp, FCOE_IDX))
			/* we will fail load process instead of mark
			 * NO_FCOE_FLAG
			 */
			return -ENOMEM;
3590
#endif
3591

3592 3593 3594 3595 3596 3597 3598 3599 3600 3601 3602 3603 3604 3605 3606 3607 3608
	/* RSS */
	for_each_nondefault_eth_queue(bp, i)
		if (bnx2x_alloc_fp_mem_at(bp, i))
			break;

	/* handle memory failures */
	if (i != BNX2X_NUM_ETH_QUEUES(bp)) {
		int delta = BNX2X_NUM_ETH_QUEUES(bp) - i;

		WARN_ON(delta < 0);
#ifdef BCM_CNIC
		/**
		 * move non eth FPs next to last eth FP
		 * must be done in that order
		 * FCOE_IDX < FWD_IDX < OOO_IDX
		 */

3609
		/* move FCoE fp even NO_FCOE_FLAG is on */
3610 3611 3612 3613 3614 3615 3616 3617 3618
		bnx2x_move_fp(bp, FCOE_IDX, FCOE_IDX - delta);
#endif
		bp->num_queues -= delta;
		BNX2X_ERR("Adjusted num of queues from %d to %d\n",
			  bp->num_queues + delta, bp->num_queues);
	}

	return 0;
}
3619

3620 3621 3622 3623 3624 3625 3626 3627 3628 3629 3630 3631
void bnx2x_free_mem_bp(struct bnx2x *bp)
{
	kfree(bp->fp);
	kfree(bp->msix_table);
	kfree(bp->ilt);
}

int __devinit bnx2x_alloc_mem_bp(struct bnx2x *bp)
{
	struct bnx2x_fastpath *fp;
	struct msix_entry *tbl;
	struct bnx2x_ilt *ilt;
3632 3633 3634 3635 3636 3637 3638
	int msix_table_size = 0;

	/*
	 * The biggest MSI-X table we might need is as a maximum number of fast
	 * path IGU SBs plus default SB (for PF).
	 */
	msix_table_size = bp->igu_sb_cnt + 1;
3639

3640
	/* fp array: RSS plus CNIC related L2 queues */
3641
	fp = kcalloc(BNX2X_MAX_RSS_COUNT(bp) + NON_ETH_CONTEXT_USE,
3642
		     sizeof(*fp), GFP_KERNEL);
3643 3644 3645 3646 3647
	if (!fp)
		goto alloc_err;
	bp->fp = fp;

	/* msix table */
3648
	tbl = kcalloc(msix_table_size, sizeof(*tbl), GFP_KERNEL);
3649 3650 3651 3652 3653 3654 3655 3656 3657 3658 3659 3660 3661 3662 3663 3664 3665
	if (!tbl)
		goto alloc_err;
	bp->msix_table = tbl;

	/* ilt */
	ilt = kzalloc(sizeof(*ilt), GFP_KERNEL);
	if (!ilt)
		goto alloc_err;
	bp->ilt = ilt;

	return 0;
alloc_err:
	bnx2x_free_mem_bp(bp);
	return -ENOMEM;

}

3666
int bnx2x_reload_if_running(struct net_device *dev)
3667 3668 3669 3670 3671 3672 3673 3674 3675 3676
{
	struct bnx2x *bp = netdev_priv(dev);

	if (unlikely(!netif_running(dev)))
		return 0;

	bnx2x_nic_unload(bp, UNLOAD_NORMAL);
	return bnx2x_nic_load(bp, LOAD_NORMAL);
}

Y
Yaniv Rosner 已提交
3677 3678 3679 3680 3681 3682 3683 3684 3685 3686 3687 3688 3689 3690 3691 3692 3693 3694 3695 3696 3697 3698 3699 3700 3701 3702 3703 3704 3705 3706 3707 3708 3709 3710 3711 3712 3713 3714 3715 3716 3717 3718 3719 3720 3721 3722 3723 3724 3725
int bnx2x_get_cur_phy_idx(struct bnx2x *bp)
{
	u32 sel_phy_idx = 0;
	if (bp->link_params.num_phys <= 1)
		return INT_PHY;

	if (bp->link_vars.link_up) {
		sel_phy_idx = EXT_PHY1;
		/* In case link is SERDES, check if the EXT_PHY2 is the one */
		if ((bp->link_vars.link_status & LINK_STATUS_SERDES_LINK) &&
		    (bp->link_params.phy[EXT_PHY2].supported & SUPPORTED_FIBRE))
			sel_phy_idx = EXT_PHY2;
	} else {

		switch (bnx2x_phy_selection(&bp->link_params)) {
		case PORT_HW_CFG_PHY_SELECTION_HARDWARE_DEFAULT:
		case PORT_HW_CFG_PHY_SELECTION_FIRST_PHY:
		case PORT_HW_CFG_PHY_SELECTION_FIRST_PHY_PRIORITY:
		       sel_phy_idx = EXT_PHY1;
		       break;
		case PORT_HW_CFG_PHY_SELECTION_SECOND_PHY:
		case PORT_HW_CFG_PHY_SELECTION_SECOND_PHY_PRIORITY:
		       sel_phy_idx = EXT_PHY2;
		       break;
		}
	}

	return sel_phy_idx;

}
int bnx2x_get_link_cfg_idx(struct bnx2x *bp)
{
	u32 sel_phy_idx = bnx2x_get_cur_phy_idx(bp);
	/*
	 * The selected actived PHY is always after swapping (in case PHY
	 * swapping is enabled). So when swapping is enabled, we need to reverse
	 * the configuration
	 */

	if (bp->link_params.multi_phy_config &
	    PORT_HW_CFG_PHY_SWAPPED_ENABLED) {
		if (sel_phy_idx == EXT_PHY1)
			sel_phy_idx = EXT_PHY2;
		else if (sel_phy_idx == EXT_PHY2)
			sel_phy_idx = EXT_PHY1;
	}
	return LINK_CONFIG_IDX(sel_phy_idx);
}

3726 3727 3728 3729 3730 3731 3732 3733 3734 3735 3736 3737 3738 3739 3740 3741
#if defined(NETDEV_FCOE_WWNN) && defined(BCM_CNIC)
int bnx2x_fcoe_get_wwn(struct net_device *dev, u64 *wwn, int type)
{
	struct bnx2x *bp = netdev_priv(dev);
	struct cnic_eth_dev *cp = &bp->cnic_eth_dev;

	switch (type) {
	case NETDEV_FCOE_WWNN:
		*wwn = HILO_U64(cp->fcoe_wwn_node_name_hi,
				cp->fcoe_wwn_node_name_lo);
		break;
	case NETDEV_FCOE_WWPN:
		*wwn = HILO_U64(cp->fcoe_wwn_port_name_hi,
				cp->fcoe_wwn_port_name_lo);
		break;
	default:
M
Merav Sicron 已提交
3742
		BNX2X_ERR("Wrong WWN type requested - %d\n", type);
3743 3744 3745 3746 3747 3748 3749
		return -EINVAL;
	}

	return 0;
}
#endif

D
Dmitry Kravkov 已提交
3750 3751 3752 3753 3754 3755
/* called with rtnl_lock */
int bnx2x_change_mtu(struct net_device *dev, int new_mtu)
{
	struct bnx2x *bp = netdev_priv(dev);

	if (bp->recovery_state != BNX2X_RECOVERY_DONE) {
M
Merav Sicron 已提交
3756
		BNX2X_ERR("Can't perform change MTU during parity recovery\n");
D
Dmitry Kravkov 已提交
3757 3758 3759 3760
		return -EAGAIN;
	}

	if ((new_mtu > ETH_MAX_JUMBO_PACKET_SIZE) ||
M
Merav Sicron 已提交
3761 3762
	    ((new_mtu + ETH_HLEN) < ETH_MIN_PACKET_SIZE)) {
		BNX2X_ERR("Can't support requested MTU size\n");
D
Dmitry Kravkov 已提交
3763
		return -EINVAL;
M
Merav Sicron 已提交
3764
	}
D
Dmitry Kravkov 已提交
3765 3766 3767 3768 3769 3770 3771

	/* This does not race with packet allocation
	 * because the actual alloc size is
	 * only updated as part of load
	 */
	dev->mtu = new_mtu;

3772 3773 3774
	return bnx2x_reload_if_running(dev);
}

3775
netdev_features_t bnx2x_fix_features(struct net_device *dev,
D
Dmitry Kravkov 已提交
3776
				     netdev_features_t features)
3777 3778 3779 3780
{
	struct bnx2x *bp = netdev_priv(dev);

	/* TPA requires Rx CSUM offloading */
D
Dmitry Kravkov 已提交
3781
	if (!(features & NETIF_F_RXCSUM) || bp->disable_tpa) {
3782
		features &= ~NETIF_F_LRO;
D
Dmitry Kravkov 已提交
3783 3784
		features &= ~NETIF_F_GRO;
	}
3785 3786 3787 3788

	return features;
}

3789
int bnx2x_set_features(struct net_device *dev, netdev_features_t features)
3790 3791 3792
{
	struct bnx2x *bp = netdev_priv(dev);
	u32 flags = bp->flags;
3793
	bool bnx2x_reload = false;
3794 3795 3796 3797 3798 3799

	if (features & NETIF_F_LRO)
		flags |= TPA_ENABLE_FLAG;
	else
		flags &= ~TPA_ENABLE_FLAG;

D
Dmitry Kravkov 已提交
3800 3801 3802 3803 3804
	if (features & NETIF_F_GRO)
		flags |= GRO_ENABLE_FLAG;
	else
		flags &= ~GRO_ENABLE_FLAG;

3805 3806 3807 3808 3809 3810 3811 3812 3813 3814 3815 3816
	if (features & NETIF_F_LOOPBACK) {
		if (bp->link_params.loopback_mode != LOOPBACK_BMAC) {
			bp->link_params.loopback_mode = LOOPBACK_BMAC;
			bnx2x_reload = true;
		}
	} else {
		if (bp->link_params.loopback_mode != LOOPBACK_NONE) {
			bp->link_params.loopback_mode = LOOPBACK_NONE;
			bnx2x_reload = true;
		}
	}

3817 3818
	if (flags ^ bp->flags) {
		bp->flags = flags;
3819 3820
		bnx2x_reload = true;
	}
3821

3822
	if (bnx2x_reload) {
3823 3824 3825
		if (bp->recovery_state == BNX2X_RECOVERY_DONE)
			return bnx2x_reload_if_running(dev);
		/* else: bnx2x_nic_load() will be called at end of recovery */
D
Dmitry Kravkov 已提交
3826 3827
	}

3828
	return 0;
D
Dmitry Kravkov 已提交
3829 3830 3831 3832 3833 3834 3835 3836 3837 3838
}

void bnx2x_tx_timeout(struct net_device *dev)
{
	struct bnx2x *bp = netdev_priv(dev);

#ifdef BNX2X_STOP_ON_ERROR
	if (!bp->panic)
		bnx2x_panic();
#endif
3839 3840 3841 3842 3843

	smp_mb__before_clear_bit();
	set_bit(BNX2X_SP_RTNL_TX_TIMEOUT, &bp->sp_rtnl_state);
	smp_mb__after_clear_bit();

D
Dmitry Kravkov 已提交
3844
	/* This allows the netif to be shutdown gracefully before resetting */
3845
	schedule_delayed_work(&bp->sp_rtnl_task, 0);
D
Dmitry Kravkov 已提交
3846 3847 3848 3849 3850 3851 3852 3853 3854 3855 3856 3857 3858 3859 3860 3861 3862 3863 3864 3865 3866 3867 3868 3869 3870 3871 3872 3873 3874 3875 3876 3877 3878 3879 3880 3881 3882 3883 3884 3885 3886 3887 3888 3889 3890 3891
}

int bnx2x_suspend(struct pci_dev *pdev, pm_message_t state)
{
	struct net_device *dev = pci_get_drvdata(pdev);
	struct bnx2x *bp;

	if (!dev) {
		dev_err(&pdev->dev, "BAD net device from bnx2x_init_one\n");
		return -ENODEV;
	}
	bp = netdev_priv(dev);

	rtnl_lock();

	pci_save_state(pdev);

	if (!netif_running(dev)) {
		rtnl_unlock();
		return 0;
	}

	netif_device_detach(dev);

	bnx2x_nic_unload(bp, UNLOAD_CLOSE);

	bnx2x_set_power_state(bp, pci_choose_state(pdev, state));

	rtnl_unlock();

	return 0;
}

int bnx2x_resume(struct pci_dev *pdev)
{
	struct net_device *dev = pci_get_drvdata(pdev);
	struct bnx2x *bp;
	int rc;

	if (!dev) {
		dev_err(&pdev->dev, "BAD net device from bnx2x_init_one\n");
		return -ENODEV;
	}
	bp = netdev_priv(dev);

	if (bp->recovery_state != BNX2X_RECOVERY_DONE) {
M
Merav Sicron 已提交
3892
		BNX2X_ERR("Handling parity error recovery. Try again later\n");
D
Dmitry Kravkov 已提交
3893 3894 3895 3896 3897 3898 3899 3900 3901 3902 3903 3904 3905 3906 3907 3908 3909 3910 3911 3912 3913
		return -EAGAIN;
	}

	rtnl_lock();

	pci_restore_state(pdev);

	if (!netif_running(dev)) {
		rtnl_unlock();
		return 0;
	}

	bnx2x_set_power_state(bp, PCI_D0);
	netif_device_attach(dev);

	rc = bnx2x_nic_load(bp, LOAD_OPEN);

	rtnl_unlock();

	return rc;
}
3914 3915 3916 3917 3918 3919 3920 3921 3922 3923 3924 3925 3926 3927 3928


void bnx2x_set_ctx_validation(struct bnx2x *bp, struct eth_context *cxt,
			      u32 cid)
{
	/* ustorm cxt validation */
	cxt->ustorm_ag_context.cdu_usage =
		CDU_RSRVD_VALUE_TYPE_A(HW_CID(bp, cid),
			CDU_REGION_NUMBER_UCM_AG, ETH_CONNECTION_TYPE);
	/* xcontext validation */
	cxt->xstorm_ag_context.cdu_reserved =
		CDU_RSRVD_VALUE_TYPE_A(HW_CID(bp, cid),
			CDU_REGION_NUMBER_XCM_AG, ETH_CONNECTION_TYPE);
}

E
Eric Dumazet 已提交
3929 3930 3931
static void storm_memset_hc_timeout(struct bnx2x *bp, u8 port,
				    u8 fw_sb_id, u8 sb_index,
				    u8 ticks)
3932 3933 3934 3935 3936
{

	u32 addr = BAR_CSTRORM_INTMEM +
		   CSTORM_STATUS_BLOCK_DATA_TIMEOUT_OFFSET(fw_sb_id, sb_index);
	REG_WR8(bp, addr, ticks);
M
Merav Sicron 已提交
3937 3938 3939
	DP(NETIF_MSG_IFUP,
	   "port %x fw_sb_id %d sb_index %d ticks %d\n",
	   port, fw_sb_id, sb_index, ticks);
3940 3941
}

E
Eric Dumazet 已提交
3942 3943 3944
static void storm_memset_hc_disable(struct bnx2x *bp, u8 port,
				    u16 fw_sb_id, u8 sb_index,
				    u8 disable)
3945 3946 3947 3948 3949 3950 3951 3952 3953
{
	u32 enable_flag = disable ? 0 : (1 << HC_INDEX_DATA_HC_ENABLED_SHIFT);
	u32 addr = BAR_CSTRORM_INTMEM +
		   CSTORM_STATUS_BLOCK_DATA_FLAGS_OFFSET(fw_sb_id, sb_index);
	u16 flags = REG_RD16(bp, addr);
	/* clear and set */
	flags &= ~HC_INDEX_DATA_HC_ENABLED;
	flags |= enable_flag;
	REG_WR16(bp, addr, flags);
M
Merav Sicron 已提交
3954 3955 3956
	DP(NETIF_MSG_IFUP,
	   "port %x fw_sb_id %d sb_index %d disable %d\n",
	   port, fw_sb_id, sb_index, disable);
3957 3958 3959 3960 3961 3962 3963 3964 3965 3966 3967 3968 3969
}

void bnx2x_update_coalesce_sb_index(struct bnx2x *bp, u8 fw_sb_id,
				    u8 sb_index, u8 disable, u16 usec)
{
	int port = BP_PORT(bp);
	u8 ticks = usec / BNX2X_BTR;

	storm_memset_hc_timeout(bp, port, fw_sb_id, sb_index, ticks);

	disable = disable ? 1 : (usec ? 0 : 1);
	storm_memset_hc_disable(bp, port, fw_sb_id, sb_index, disable);
}