xref: /illumos-gate/usr/src/uts/common/io/ixgbe/ixgbe_tx.c (revision 8a2b682e57a046b828f37bcde1776f131ef4629f)
1 /*
2  * CDDL HEADER START
3  *
4  * The contents of this file are subject to the terms of the
5  * Common Development and Distribution License (the "License").
6  * You may not use this file except in compliance with the License.
7  *
8  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9  * or http://www.opensolaris.org/os/licensing.
10  * See the License for the specific language governing permissions
11  * and limitations under the License.
12  *
13  * When distributing Covered Code, include this CDDL HEADER in each
14  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15  * If applicable, add the following below this CDDL HEADER, with the
16  * fields enclosed by brackets "[]" replaced with your own identifying
17  * information: Portions Copyright [yyyy] [name of copyright owner]
18  *
19  * CDDL HEADER END
20  */
21 
22 /*
23  * Copyright(c) 2007-2010 Intel Corporation. All rights reserved.
24  */
25 
26 /*
27  * Copyright (c) 2008, 2010, Oracle and/or its affiliates. All rights reserved.
28  * Copyright 2012 Nexenta Systems, Inc. All rights reserved.
29  * Copyright 2016 OmniTI Computer Consulting, Inc. All rights reserved.
30  * Copyright 2017 Joyent, Inc.
31  */
32 
33 #include "ixgbe_sw.h"
34 
35 static int ixgbe_tx_copy(ixgbe_tx_ring_t *, tx_control_block_t *, mblk_t *,
36     uint32_t, boolean_t);
37 static int ixgbe_tx_bind(ixgbe_tx_ring_t *, tx_control_block_t *, mblk_t *,
38     uint32_t);
39 static int ixgbe_tx_fill_ring(ixgbe_tx_ring_t *, link_list_t *,
40     ixgbe_tx_context_t *, size_t);
41 static void ixgbe_save_desc(tx_control_block_t *, uint64_t, size_t);
42 static tx_control_block_t *ixgbe_get_free_list(ixgbe_tx_ring_t *);
43 
44 static int ixgbe_get_context(mblk_t *, ixgbe_tx_context_t *);
45 static boolean_t ixgbe_check_context(ixgbe_tx_ring_t *,
46     ixgbe_tx_context_t *);
47 static void ixgbe_fill_context(struct ixgbe_adv_tx_context_desc *,
48     ixgbe_tx_context_t *);
49 
50 #ifndef IXGBE_DEBUG
51 #pragma inline(ixgbe_save_desc)
52 #pragma inline(ixgbe_get_context)
53 #pragma inline(ixgbe_check_context)
54 #pragma inline(ixgbe_fill_context)
55 #endif
56 
57 /*
58  * ixgbe_ring_tx
59  *
60  * To transmit one mblk through one specified ring.
61  *
62  * One mblk can consist of several fragments, each fragment
63  * will be processed with different methods based on the size.
64  * For the fragments with size less than the bcopy threshold,
65  * they will be processed by using bcopy; otherwise, they will
66  * be processed by using DMA binding.
67  *
68  * To process the mblk, a tx control block is got from the
69  * free list. One tx control block contains one tx buffer, which
70  * is used to copy mblk fragments' data; and one tx DMA handle,
71  * which is used to bind a mblk fragment with DMA resource.
72  *
73  * Several small mblk fragments can be copied into one tx control
74  * block's buffer, and then the buffer will be transmitted with
75  * one tx descriptor.
76  *
77  * A large fragment only binds with one tx control block's DMA
78  * handle, and it can span several tx descriptors for transmitting.
79  *
80  * So to transmit a packet (mblk), several tx control blocks can
81  * be used. After the processing, those tx control blocks will
82  * be put to the work list.
83  */
84 mblk_t *
85 ixgbe_ring_tx(void *arg, mblk_t *mp)
86 {
87 	ixgbe_tx_ring_t *tx_ring = (ixgbe_tx_ring_t *)arg;
88 	ixgbe_t *ixgbe = tx_ring->ixgbe;
89 	tx_type_t current_flag, next_flag;
90 	uint32_t current_len, next_len;
91 	uint32_t desc_total;
92 	size_t mbsize;
93 	int desc_num;
94 	boolean_t copy_done, eop;
95 	mblk_t *current_mp, *next_mp, *nmp, *pull_mp = NULL;
96 	tx_control_block_t *tcb;
97 	ixgbe_tx_context_t tx_context, *ctx;
98 	link_list_t pending_list;
99 	uint32_t len, hdr_frag_len, hdr_len;
100 	uint32_t copy_thresh;
101 	mblk_t *hdr_new_mp = NULL;
102 	mblk_t *hdr_pre_mp = NULL;
103 	mblk_t *hdr_nmp = NULL;
104 
105 	ASSERT(mp->b_next == NULL);
106 
107 	if ((ixgbe->ixgbe_state & IXGBE_SUSPENDED) ||
108 	    (ixgbe->ixgbe_state & IXGBE_ERROR) ||
109 	    (ixgbe->ixgbe_state & IXGBE_OVERTEMP) ||
110 	    !(ixgbe->ixgbe_state & IXGBE_STARTED) ||
111 	    ixgbe->link_state != LINK_STATE_UP) {
112 		freemsg(mp);
113 		return (NULL);
114 	}
115 
116 	copy_thresh = ixgbe->tx_copy_thresh;
117 
118 	/* Get the mblk size */
119 	mbsize = 0;
120 	for (nmp = mp; nmp != NULL; nmp = nmp->b_cont) {
121 		mbsize += MBLKL(nmp);
122 	}
123 
124 	if (ixgbe->tx_hcksum_enable) {
125 		/*
126 		 * Retrieve checksum context information from the mblk
127 		 * that will be used to decide whether/how to fill the
128 		 * context descriptor.
129 		 */
130 		ctx = &tx_context;
131 		if (ixgbe_get_context(mp, ctx) < 0) {
132 			freemsg(mp);
133 			return (NULL);
134 		}
135 
136 		/*
137 		 * If the mblk size exceeds the max size ixgbe could
138 		 * process, then discard this mblk, and return NULL.
139 		 */
140 		if ((ctx->lso_flag &&
141 		    ((mbsize - ctx->mac_hdr_len) > IXGBE_LSO_MAXLEN)) ||
142 		    (!ctx->lso_flag &&
143 		    (mbsize > (ixgbe->max_frame_size - ETHERFCSL)))) {
144 			freemsg(mp);
145 			IXGBE_DEBUGLOG_0(ixgbe, "ixgbe_tx: packet oversize");
146 			return (NULL);
147 		}
148 	} else {
149 		ctx = NULL;
150 	}
151 
152 	/*
153 	 * Check and recycle tx descriptors.
154 	 * The recycle threshold here should be selected carefully
155 	 */
156 	if (tx_ring->tbd_free < ixgbe->tx_recycle_thresh) {
157 		tx_ring->tx_recycle(tx_ring);
158 	}
159 
160 	/*
161 	 * After the recycling, if the tbd_free is less than the
162 	 * overload_threshold, assert overload, return mp;
163 	 * and we need to re-schedule the tx again.
164 	 */
165 	if (tx_ring->tbd_free < ixgbe->tx_overload_thresh) {
166 		tx_ring->reschedule = B_TRUE;
167 		tx_ring->stat_overload++;
168 		return (mp);
169 	}
170 
171 	/*
172 	 * The pending_list is a linked list that is used to save
173 	 * the tx control blocks that have packet data processed
174 	 * but have not put the data to the tx descriptor ring.
175 	 * It is used to reduce the lock contention of the tx_lock.
176 	 */
177 	LINK_LIST_INIT(&pending_list);
178 	desc_num = 0;
179 	desc_total = 0;
180 
181 	/*
182 	 * The software should guarantee LSO packet header(MAC+IP+TCP)
183 	 * to be within one descriptor. Here we reallocate and refill the
184 	 * the header if it's physical memory non-contiguous.
185 	 */
186 	if ((ctx != NULL) && ctx->lso_flag) {
187 		/* find the last fragment of the header */
188 		len = MBLKL(mp);
189 		ASSERT(len > 0);
190 		hdr_nmp = mp;
191 		hdr_len = ctx->ip_hdr_len + ctx->mac_hdr_len + ctx->l4_hdr_len;
192 		while (len < hdr_len) {
193 			hdr_pre_mp = hdr_nmp;
194 			hdr_nmp = hdr_nmp->b_cont;
195 			len += MBLKL(hdr_nmp);
196 		}
197 		/*
198 		 * If the header and the payload are in different mblks,
199 		 * we simply force the header to be copied into pre-allocated
200 		 * page-aligned buffer.
201 		 */
202 		if (len == hdr_len)
203 			goto adjust_threshold;
204 
205 		hdr_frag_len = hdr_len - (len - MBLKL(hdr_nmp));
206 		/*
207 		 * There are two cases we need to reallocate a mblk for the
208 		 * last header fragment:
209 		 * 1. the header is in multiple mblks and the last fragment
210 		 * share the same mblk with the payload
211 		 * 2. the header is in a single mblk shared with the payload
212 		 * and the header is physical memory non-contiguous
213 		 */
214 		if ((hdr_nmp != mp) ||
215 		    (P2NPHASE((uintptr_t)hdr_nmp->b_rptr, ixgbe->sys_page_size)
216 		    < hdr_len)) {
217 			tx_ring->stat_lso_header_fail++;
218 			/*
219 			 * reallocate the mblk for the last header fragment,
220 			 * expect to bcopy into pre-allocated page-aligned
221 			 * buffer
222 			 */
223 			hdr_new_mp = allocb(hdr_frag_len, 0);
224 			if (!hdr_new_mp)
225 				return (mp);
226 			bcopy(hdr_nmp->b_rptr, hdr_new_mp->b_rptr,
227 			    hdr_frag_len);
228 			/* link the new header fragment with the other parts */
229 			hdr_new_mp->b_wptr = hdr_new_mp->b_rptr + hdr_frag_len;
230 			hdr_new_mp->b_cont = hdr_nmp;
231 			if (hdr_pre_mp)
232 				hdr_pre_mp->b_cont = hdr_new_mp;
233 			else
234 				mp = hdr_new_mp;
235 			hdr_nmp->b_rptr += hdr_frag_len;
236 		}
237 adjust_threshold:
238 		/*
239 		 * adjust the bcopy threshhold to guarantee
240 		 * the header to use bcopy way
241 		 */
242 		if (copy_thresh < hdr_len)
243 			copy_thresh = hdr_len;
244 	}
245 
246 	current_mp = mp;
247 	current_len = MBLKL(current_mp);
248 	/*
249 	 * Decide which method to use for the first fragment
250 	 */
251 	current_flag = (current_len <= copy_thresh) ?
252 	    USE_COPY : USE_DMA;
253 	/*
254 	 * If the mblk includes several contiguous small fragments,
255 	 * they may be copied into one buffer. This flag is used to
256 	 * indicate whether there are pending fragments that need to
257 	 * be copied to the current tx buffer.
258 	 *
259 	 * If this flag is B_TRUE, it indicates that a new tx control
260 	 * block is needed to process the next fragment using either
261 	 * copy or DMA binding.
262 	 *
263 	 * Otherwise, it indicates that the next fragment will be
264 	 * copied to the current tx buffer that is maintained by the
265 	 * current tx control block. No new tx control block is needed.
266 	 */
267 	copy_done = B_TRUE;
268 	while (current_mp) {
269 		next_mp = current_mp->b_cont;
270 		eop = (next_mp == NULL); /* Last fragment of the packet? */
271 		next_len = eop ? 0: MBLKL(next_mp);
272 
273 		/*
274 		 * When the current fragment is an empty fragment, if
275 		 * the next fragment will still be copied to the current
276 		 * tx buffer, we cannot skip this fragment here. Because
277 		 * the copy processing is pending for completion. We have
278 		 * to process this empty fragment in the tx_copy routine.
279 		 *
280 		 * If the copy processing is completed or a DMA binding
281 		 * processing is just completed, we can just skip this
282 		 * empty fragment.
283 		 */
284 		if ((current_len == 0) && (copy_done)) {
285 			current_mp = next_mp;
286 			current_len = next_len;
287 			current_flag = (current_len <= copy_thresh) ?
288 			    USE_COPY : USE_DMA;
289 			continue;
290 		}
291 
292 		if (copy_done) {
293 			/*
294 			 * Get a new tx control block from the free list
295 			 */
296 			tcb = ixgbe_get_free_list(tx_ring);
297 
298 			if (tcb == NULL) {
299 				tx_ring->stat_fail_no_tcb++;
300 				goto tx_failure;
301 			}
302 
303 			/*
304 			 * Push the tx control block to the pending list
305 			 * to avoid using lock too early
306 			 */
307 			LIST_PUSH_TAIL(&pending_list, &tcb->link);
308 		}
309 
310 		if (current_flag == USE_COPY) {
311 			/*
312 			 * Check whether to use bcopy or DMA binding to process
313 			 * the next fragment, and if using bcopy, whether we
314 			 * need to continue copying the next fragment into the
315 			 * current tx buffer.
316 			 */
317 			ASSERT((tcb->tx_buf.len + current_len) <=
318 			    tcb->tx_buf.size);
319 
320 			if (eop) {
321 				/*
322 				 * This is the last fragment of the packet, so
323 				 * the copy processing will be completed with
324 				 * this fragment.
325 				 */
326 				next_flag = USE_NONE;
327 				copy_done = B_TRUE;
328 			} else if ((tcb->tx_buf.len + current_len + next_len) >
329 			    tcb->tx_buf.size) {
330 				/*
331 				 * If the next fragment is too large to be
332 				 * copied to the current tx buffer, we need
333 				 * to complete the current copy processing.
334 				 */
335 				next_flag = (next_len > copy_thresh) ?
336 				    USE_DMA: USE_COPY;
337 				copy_done = B_TRUE;
338 			} else if (next_len > copy_thresh) {
339 				/*
340 				 * The next fragment needs to be processed with
341 				 * DMA binding. So the copy prcessing will be
342 				 * completed with the current fragment.
343 				 */
344 				next_flag = USE_DMA;
345 				copy_done = B_TRUE;
346 			} else {
347 				/*
348 				 * Continue to copy the next fragment to the
349 				 * current tx buffer.
350 				 */
351 				next_flag = USE_COPY;
352 				copy_done = B_FALSE;
353 			}
354 
355 			desc_num = ixgbe_tx_copy(tx_ring, tcb, current_mp,
356 			    current_len, copy_done);
357 		} else {
358 			/*
359 			 * Check whether to use bcopy or DMA binding to process
360 			 * the next fragment.
361 			 */
362 			next_flag = (next_len > copy_thresh) ?
363 			    USE_DMA: USE_COPY;
364 			ASSERT(copy_done == B_TRUE);
365 
366 			desc_num = ixgbe_tx_bind(tx_ring, tcb, current_mp,
367 			    current_len);
368 		}
369 
370 		if (desc_num > 0)
371 			desc_total += desc_num;
372 		else if (desc_num < 0)
373 			goto tx_failure;
374 
375 		current_mp = next_mp;
376 		current_len = next_len;
377 		current_flag = next_flag;
378 	}
379 
380 	/*
381 	 * Attach the mblk to the last tx control block
382 	 */
383 	ASSERT(tcb);
384 	ASSERT(tcb->mp == NULL);
385 	tcb->mp = mp;
386 
387 	/*
388 	 * 82598/82599 chipset has a limitation that no more than 32 tx
389 	 * descriptors can be transmited out at one time.
390 	 *
391 	 * Here is a workaround for it: pull up the mblk then send it
392 	 * out with bind way. By doing so, no more than MAX_COOKIE (18)
393 	 * descriptors is needed.
394 	 */
395 	if (desc_total + 1 > IXGBE_TX_DESC_LIMIT) {
396 		tx_ring->stat_break_tbd_limit++;
397 
398 		/*
399 		 * Discard the mblk and free the used resources
400 		 */
401 		tcb = (tx_control_block_t *)LIST_GET_HEAD(&pending_list);
402 		while (tcb) {
403 			tcb->mp = NULL;
404 			ixgbe_free_tcb(tcb);
405 			tcb = (tx_control_block_t *)
406 			    LIST_GET_NEXT(&pending_list, &tcb->link);
407 		}
408 
409 		/*
410 		 * Return the tx control blocks in the pending list to
411 		 * the free list.
412 		 */
413 		ixgbe_put_free_list(tx_ring, &pending_list);
414 
415 		/*
416 		 * pull up the mblk and send it out with bind way
417 		 */
418 		if ((pull_mp = msgpullup(mp, -1)) == NULL) {
419 			tx_ring->reschedule = B_TRUE;
420 
421 			/*
422 			 * If new mblk has been allocted for the last header
423 			 * fragment of a LSO packet, we should restore the
424 			 * modified mp.
425 			 */
426 			if (hdr_new_mp) {
427 				hdr_new_mp->b_cont = NULL;
428 				freeb(hdr_new_mp);
429 				hdr_nmp->b_rptr -= hdr_frag_len;
430 				if (hdr_pre_mp)
431 					hdr_pre_mp->b_cont = hdr_nmp;
432 				else
433 					mp = hdr_nmp;
434 			}
435 			return (mp);
436 		}
437 
438 		LINK_LIST_INIT(&pending_list);
439 		desc_total = 0;
440 
441 		/*
442 		 * if the packet is a LSO packet, we simply
443 		 * transmit the header in one descriptor using the copy way
444 		 */
445 		if ((ctx != NULL) && ctx->lso_flag) {
446 			hdr_len = ctx->ip_hdr_len + ctx->mac_hdr_len +
447 			    ctx->l4_hdr_len;
448 
449 			tcb = ixgbe_get_free_list(tx_ring);
450 			if (tcb == NULL) {
451 				tx_ring->stat_fail_no_tcb++;
452 				goto tx_failure;
453 			}
454 			desc_num = ixgbe_tx_copy(tx_ring, tcb, pull_mp,
455 			    hdr_len, B_TRUE);
456 			LIST_PUSH_TAIL(&pending_list, &tcb->link);
457 			desc_total  += desc_num;
458 
459 			pull_mp->b_rptr += hdr_len;
460 		}
461 
462 		tcb = ixgbe_get_free_list(tx_ring);
463 		if (tcb == NULL) {
464 			tx_ring->stat_fail_no_tcb++;
465 			goto tx_failure;
466 		}
467 		if ((ctx != NULL) && ctx->lso_flag) {
468 			desc_num = ixgbe_tx_bind(tx_ring, tcb, pull_mp,
469 			    mbsize - hdr_len);
470 		} else {
471 			desc_num = ixgbe_tx_bind(tx_ring, tcb, pull_mp,
472 			    mbsize);
473 		}
474 		if (desc_num < 0) {
475 			goto tx_failure;
476 		}
477 		LIST_PUSH_TAIL(&pending_list, &tcb->link);
478 
479 		desc_total += desc_num;
480 		tcb->mp = pull_mp;
481 	}
482 
483 	/*
484 	 * Before fill the tx descriptor ring with the data, we need to
485 	 * ensure there are adequate free descriptors for transmit
486 	 * (including one context descriptor).
487 	 * Do not use up all the tx descriptors.
488 	 * Otherwise tx recycle will fail and cause false hang.
489 	 */
490 	if (tx_ring->tbd_free <= (desc_total + 1)) {
491 		tx_ring->tx_recycle(tx_ring);
492 	}
493 
494 	mutex_enter(&tx_ring->tx_lock);
495 	/*
496 	 * If the number of free tx descriptors is not enough for transmit
497 	 * then return mp.
498 	 *
499 	 * Note: we must put this check under the mutex protection to
500 	 * ensure the correctness when multiple threads access it in
501 	 * parallel.
502 	 */
503 	if (tx_ring->tbd_free <= (desc_total + 1)) {
504 		tx_ring->stat_fail_no_tbd++;
505 		mutex_exit(&tx_ring->tx_lock);
506 		goto tx_failure;
507 	}
508 
509 	desc_num = ixgbe_tx_fill_ring(tx_ring, &pending_list, ctx,
510 	    mbsize);
511 
512 	ASSERT((desc_num == desc_total) || (desc_num == (desc_total + 1)));
513 
514 	tx_ring->stat_obytes += mbsize;
515 	tx_ring->stat_opackets ++;
516 
517 	mutex_exit(&tx_ring->tx_lock);
518 
519 	/*
520 	 * now that the transmission succeeds, need to free the original
521 	 * mp if we used the pulling up mblk for transmission.
522 	 */
523 	if (pull_mp) {
524 		freemsg(mp);
525 	}
526 
527 	return (NULL);
528 
529 tx_failure:
530 	/*
531 	 * If transmission fails, need to free the pulling up mblk.
532 	 */
533 	if (pull_mp) {
534 		freemsg(pull_mp);
535 	}
536 
537 	/*
538 	 * If new mblk has been allocted for the last header
539 	 * fragment of a LSO packet, we should restore the
540 	 * modified mp.
541 	 */
542 	if (hdr_new_mp) {
543 		hdr_new_mp->b_cont = NULL;
544 		freeb(hdr_new_mp);
545 		hdr_nmp->b_rptr -= hdr_frag_len;
546 		if (hdr_pre_mp)
547 			hdr_pre_mp->b_cont = hdr_nmp;
548 		else
549 			mp = hdr_nmp;
550 	}
551 	/*
552 	 * Discard the mblk and free the used resources
553 	 */
554 	tcb = (tx_control_block_t *)LIST_GET_HEAD(&pending_list);
555 	while (tcb) {
556 		tcb->mp = NULL;
557 
558 		ixgbe_free_tcb(tcb);
559 
560 		tcb = (tx_control_block_t *)
561 		    LIST_GET_NEXT(&pending_list, &tcb->link);
562 	}
563 
564 	/*
565 	 * Return the tx control blocks in the pending list to the free list.
566 	 */
567 	ixgbe_put_free_list(tx_ring, &pending_list);
568 
569 	/* Transmit failed, do not drop the mblk, rechedule the transmit */
570 	tx_ring->reschedule = B_TRUE;
571 
572 	return (mp);
573 }
574 
575 /*
576  * ixgbe_tx_copy
577  *
578  * Copy the mblk fragment to the pre-allocated tx buffer
579  */
580 static int
581 ixgbe_tx_copy(ixgbe_tx_ring_t *tx_ring, tx_control_block_t *tcb, mblk_t *mp,
582     uint32_t len, boolean_t copy_done)
583 {
584 	dma_buffer_t *tx_buf;
585 	uint32_t desc_num;
586 	_NOTE(ARGUNUSED(tx_ring));
587 
588 	tx_buf = &tcb->tx_buf;
589 
590 	/*
591 	 * Copy the packet data of the mblk fragment into the
592 	 * pre-allocated tx buffer, which is maintained by the
593 	 * tx control block.
594 	 *
595 	 * Several mblk fragments can be copied into one tx buffer.
596 	 * The destination address of the current copied fragment in
597 	 * the tx buffer is next to the end of the previous copied
598 	 * fragment.
599 	 */
600 	if (len > 0) {
601 		bcopy(mp->b_rptr, tx_buf->address + tx_buf->len, len);
602 
603 		tx_buf->len += len;
604 		tcb->frag_num++;
605 	}
606 
607 	desc_num = 0;
608 
609 	/*
610 	 * If it is the last fragment copied to the current tx buffer,
611 	 * in other words, if there's no remaining fragment or the remaining
612 	 * fragment requires a new tx control block to process, we need to
613 	 * complete the current copy processing by syncing up the current
614 	 * DMA buffer and saving the descriptor data.
615 	 */
616 	if (copy_done) {
617 		/*
618 		 * Sync the DMA buffer of the packet data
619 		 */
620 		DMA_SYNC(tx_buf, DDI_DMA_SYNC_FORDEV);
621 
622 		tcb->tx_type = USE_COPY;
623 
624 		/*
625 		 * Save the address and length to the private data structure
626 		 * of the tx control block, which will be used to fill the
627 		 * tx descriptor ring after all the fragments are processed.
628 		 */
629 		ixgbe_save_desc(tcb, tx_buf->dma_address, tx_buf->len);
630 		desc_num++;
631 	}
632 
633 	return (desc_num);
634 }
635 
636 /*
637  * ixgbe_tx_bind
638  *
639  * Bind the mblk fragment with DMA
640  */
641 static int
642 ixgbe_tx_bind(ixgbe_tx_ring_t *tx_ring, tx_control_block_t *tcb, mblk_t *mp,
643     uint32_t len)
644 {
645 	int status, i;
646 	ddi_dma_cookie_t dma_cookie;
647 	uint_t ncookies;
648 	int desc_num;
649 
650 	/*
651 	 * Use DMA binding to process the mblk fragment
652 	 */
653 	status = ddi_dma_addr_bind_handle(tcb->tx_dma_handle, NULL,
654 	    (caddr_t)mp->b_rptr, len,
655 	    DDI_DMA_WRITE | DDI_DMA_STREAMING, DDI_DMA_DONTWAIT,
656 	    0, &dma_cookie, &ncookies);
657 
658 	if (status != DDI_DMA_MAPPED) {
659 		tx_ring->stat_fail_dma_bind++;
660 		return (-1);
661 	}
662 
663 	tcb->frag_num++;
664 	tcb->tx_type = USE_DMA;
665 	/*
666 	 * Each fragment can span several cookies. One cookie will have
667 	 * one tx descriptor to transmit.
668 	 */
669 	desc_num = 0;
670 	for (i = ncookies; i > 0; i--) {
671 		/*
672 		 * Save the address and length to the private data structure
673 		 * of the tx control block, which will be used to fill the
674 		 * tx descriptor ring after all the fragments are processed.
675 		 */
676 		ixgbe_save_desc(tcb,
677 		    dma_cookie.dmac_laddress,
678 		    dma_cookie.dmac_size);
679 
680 		desc_num++;
681 
682 		if (i > 1)
683 			ddi_dma_nextcookie(tcb->tx_dma_handle, &dma_cookie);
684 	}
685 
686 	return (desc_num);
687 }
688 
689 /*
690  * ixgbe_get_context
691  *
692  * Get the context information from the mblk
693  */
694 static int
695 ixgbe_get_context(mblk_t *mp, ixgbe_tx_context_t *ctx)
696 {
697 	uint32_t start;
698 	uint32_t hckflags;
699 	uint32_t lsoflags;
700 	uint32_t mss;
701 	uint32_t len;
702 	uint32_t size;
703 	uint32_t offset;
704 	unsigned char *pos;
705 	ushort_t etype;
706 	uint32_t mac_hdr_len;
707 	uint32_t l4_proto;
708 	uint32_t l4_hdr_len;
709 
710 	ASSERT(mp != NULL);
711 
712 	mac_hcksum_get(mp, &start, NULL, NULL, NULL, &hckflags);
713 	bzero(ctx, sizeof (ixgbe_tx_context_t));
714 
715 	if (hckflags == 0) {
716 		return (0);
717 	}
718 
719 	ctx->hcksum_flags = hckflags;
720 
721 	mac_lso_get(mp, &mss, &lsoflags);
722 	ctx->mss = mss;
723 	ctx->lso_flag = (lsoflags == HW_LSO);
724 
725 	/*
726 	 * LSO relies on tx h/w checksum, so here will drop the package
727 	 * if h/w checksum flag is not declared.
728 	 */
729 	if (ctx->lso_flag) {
730 		if (!((ctx->hcksum_flags & HCK_PARTIALCKSUM) &&
731 		    (ctx->hcksum_flags & HCK_IPV4_HDRCKSUM))) {
732 			IXGBE_DEBUGLOG_0(NULL, "ixgbe_tx: h/w "
733 			    "checksum flags are not specified when doing LSO");
734 			return (-1);
735 		}
736 	}
737 
738 	etype = 0;
739 	mac_hdr_len = 0;
740 	l4_proto = 0;
741 
742 	/*
743 	 * Firstly get the position of the ether_type/ether_tpid.
744 	 * Here we don't assume the ether (VLAN) header is fully included
745 	 * in one mblk fragment, so we go thourgh the fragments to parse
746 	 * the ether type.
747 	 */
748 	size = len = MBLKL(mp);
749 	offset = offsetof(struct ether_header, ether_type);
750 	while (size <= offset) {
751 		mp = mp->b_cont;
752 		ASSERT(mp != NULL);
753 		len = MBLKL(mp);
754 		size += len;
755 	}
756 	pos = mp->b_rptr + offset + len - size;
757 
758 	etype = ntohs(*(ushort_t *)(uintptr_t)pos);
759 	if (etype == ETHERTYPE_VLAN) {
760 		/*
761 		 * Get the position of the ether_type in VLAN header
762 		 */
763 		offset = offsetof(struct ether_vlan_header, ether_type);
764 		while (size <= offset) {
765 			mp = mp->b_cont;
766 			ASSERT(mp != NULL);
767 			len = MBLKL(mp);
768 			size += len;
769 		}
770 		pos = mp->b_rptr + offset + len - size;
771 
772 		etype = ntohs(*(ushort_t *)(uintptr_t)pos);
773 		mac_hdr_len = sizeof (struct ether_vlan_header);
774 	} else {
775 		mac_hdr_len = sizeof (struct ether_header);
776 	}
777 
778 	/*
779 	 * Here we don't assume the IP(V6) header is fully included in
780 	 * one mblk fragment.
781 	 */
782 	switch (etype) {
783 	case ETHERTYPE_IP:
784 		if (ctx->lso_flag) {
785 			offset = offsetof(ipha_t, ipha_length) + mac_hdr_len;
786 			while (size <= offset) {
787 				mp = mp->b_cont;
788 				ASSERT(mp != NULL);
789 				len = MBLKL(mp);
790 				size += len;
791 			}
792 			pos = mp->b_rptr + offset + len - size;
793 			*((uint16_t *)(uintptr_t)(pos)) = 0;
794 
795 			offset = offsetof(ipha_t, ipha_hdr_checksum) +
796 			    mac_hdr_len;
797 			while (size <= offset) {
798 				mp = mp->b_cont;
799 				ASSERT(mp != NULL);
800 				len = MBLKL(mp);
801 				size += len;
802 			}
803 			pos = mp->b_rptr + offset + len - size;
804 			*((uint16_t *)(uintptr_t)(pos)) = 0;
805 
806 			/*
807 			 * To perform ixgbe LSO, here also need to fill
808 			 * the tcp checksum field of the packet with the
809 			 * following pseudo-header checksum:
810 			 * (ip_source_addr, ip_destination_addr, l4_proto)
811 			 * Currently the tcp/ip stack has done it.
812 			 */
813 		}
814 
815 		offset = offsetof(ipha_t, ipha_protocol) + mac_hdr_len;
816 		while (size <= offset) {
817 			mp = mp->b_cont;
818 			ASSERT(mp != NULL);
819 			len = MBLKL(mp);
820 			size += len;
821 		}
822 		pos = mp->b_rptr + offset + len - size;
823 
824 		l4_proto = *(uint8_t *)pos;
825 		break;
826 	case ETHERTYPE_IPV6:
827 		offset = offsetof(ip6_t, ip6_nxt) + mac_hdr_len;
828 		while (size <= offset) {
829 			mp = mp->b_cont;
830 			ASSERT(mp != NULL);
831 			len = MBLKL(mp);
832 			size += len;
833 		}
834 		pos = mp->b_rptr + offset + len - size;
835 
836 		l4_proto = *(uint8_t *)pos;
837 		break;
838 	default:
839 		/* Unrecoverable error */
840 		IXGBE_DEBUGLOG_0(NULL, "Ether type error with tx hcksum");
841 		return (-2);
842 	}
843 
844 	if (ctx->lso_flag) {
845 		offset = mac_hdr_len + start;
846 		while (size <= offset) {
847 			mp = mp->b_cont;
848 			ASSERT(mp != NULL);
849 			len = MBLKL(mp);
850 			size += len;
851 		}
852 		pos = mp->b_rptr + offset + len - size;
853 
854 		l4_hdr_len = TCP_HDR_LENGTH((tcph_t *)pos);
855 	} else {
856 		/*
857 		 * l4 header length is only required for LSO
858 		 */
859 		l4_hdr_len = 0;
860 	}
861 
862 	ctx->mac_hdr_len = mac_hdr_len;
863 	ctx->ip_hdr_len = start;
864 	ctx->l4_proto = l4_proto;
865 	ctx->l4_hdr_len = l4_hdr_len;
866 
867 	return (0);
868 }
869 
870 /*
871  * ixgbe_check_context
872  *
873  * Check if a new context descriptor is needed
874  */
875 static boolean_t
876 ixgbe_check_context(ixgbe_tx_ring_t *tx_ring, ixgbe_tx_context_t *ctx)
877 {
878 	ixgbe_tx_context_t *last;
879 
880 	if (ctx == NULL)
881 		return (B_FALSE);
882 
883 	/*
884 	 * Compare the context data retrieved from the mblk and the
885 	 * stored data of the last context descriptor. The data need
886 	 * to be checked are:
887 	 *	hcksum_flags
888 	 *	l4_proto
889 	 *	mac_hdr_len
890 	 *	ip_hdr_len
891 	 *	lso_flag
892 	 *	mss (only checked for LSO)
893 	 *	l4_hr_len (only checked for LSO)
894 	 * Either one of the above data is changed, a new context descriptor
895 	 * will be needed.
896 	 */
897 	last = &tx_ring->tx_context;
898 
899 	if ((ctx->hcksum_flags != last->hcksum_flags) ||
900 	    (ctx->l4_proto != last->l4_proto) ||
901 	    (ctx->mac_hdr_len != last->mac_hdr_len) ||
902 	    (ctx->ip_hdr_len != last->ip_hdr_len) ||
903 	    (ctx->lso_flag != last->lso_flag) ||
904 	    (ctx->lso_flag && ((ctx->mss != last->mss) ||
905 	    (ctx->l4_hdr_len != last->l4_hdr_len)))) {
906 		return (B_TRUE);
907 	}
908 
909 	return (B_FALSE);
910 }
911 
912 /*
913  * ixgbe_fill_context
914  *
915  * Fill the context descriptor with hardware checksum informations
916  */
917 static void
918 ixgbe_fill_context(struct ixgbe_adv_tx_context_desc *ctx_tbd,
919     ixgbe_tx_context_t *ctx)
920 {
921 	/*
922 	 * Fill the context descriptor with the checksum
923 	 * context information we've got.
924 	 */
925 	ctx_tbd->vlan_macip_lens = ctx->ip_hdr_len;
926 	ctx_tbd->vlan_macip_lens |= ctx->mac_hdr_len <<
927 	    IXGBE_ADVTXD_MACLEN_SHIFT;
928 
929 	ctx_tbd->type_tucmd_mlhl =
930 	    IXGBE_ADVTXD_DCMD_DEXT | IXGBE_ADVTXD_DTYP_CTXT;
931 
932 	if (ctx->hcksum_flags & HCK_IPV4_HDRCKSUM)
933 		ctx_tbd->type_tucmd_mlhl |= IXGBE_ADVTXD_TUCMD_IPV4;
934 
935 	if (ctx->hcksum_flags & HCK_PARTIALCKSUM) {
936 		switch (ctx->l4_proto) {
937 		case IPPROTO_TCP:
938 			ctx_tbd->type_tucmd_mlhl |= IXGBE_ADVTXD_TUCMD_L4T_TCP;
939 			break;
940 		case IPPROTO_UDP:
941 			/*
942 			 * We don't have to explicitly set:
943 			 *	ctx_tbd->type_tucmd_mlhl |=
944 			 *	    IXGBE_ADVTXD_TUCMD_L4T_UDP;
945 			 * Because IXGBE_ADVTXD_TUCMD_L4T_UDP == 0b
946 			 */
947 			break;
948 		default:
949 			/* Unrecoverable error */
950 			IXGBE_DEBUGLOG_0(NULL, "L4 type error with tx hcksum");
951 			break;
952 		}
953 	}
954 
955 	ctx_tbd->seqnum_seed = 0;
956 
957 	if (ctx->lso_flag) {
958 		ctx_tbd->mss_l4len_idx =
959 		    (ctx->l4_hdr_len << IXGBE_ADVTXD_L4LEN_SHIFT) |
960 		    (ctx->mss << IXGBE_ADVTXD_MSS_SHIFT);
961 	} else {
962 		ctx_tbd->mss_l4len_idx = 0;
963 	}
964 }
965 
966 /*
967  * ixgbe_tx_fill_ring
968  *
969  * Fill the tx descriptor ring with the data
970  */
971 static int
972 ixgbe_tx_fill_ring(ixgbe_tx_ring_t *tx_ring, link_list_t *pending_list,
973     ixgbe_tx_context_t *ctx, size_t mbsize)
974 {
975 	struct ixgbe_hw *hw = &tx_ring->ixgbe->hw;
976 	boolean_t load_context;
977 	uint32_t index, tcb_index, desc_num;
978 	union ixgbe_adv_tx_desc *tbd, *first_tbd;
979 	tx_control_block_t *tcb, *first_tcb;
980 	uint32_t hcksum_flags;
981 	int i;
982 
983 	ASSERT(mutex_owned(&tx_ring->tx_lock));
984 
985 	tbd = NULL;
986 	first_tbd = NULL;
987 	first_tcb = NULL;
988 	desc_num = 0;
989 	hcksum_flags = 0;
990 	load_context = B_FALSE;
991 
992 	/*
993 	 * Get the index of the first tx descriptor that will be filled,
994 	 * and the index of the first work list item that will be attached
995 	 * with the first used tx control block in the pending list.
996 	 * Note: the two indexes are the same.
997 	 */
998 	index = tx_ring->tbd_tail;
999 	tcb_index = tx_ring->tbd_tail;
1000 
1001 	if (ctx != NULL) {
1002 		hcksum_flags = ctx->hcksum_flags;
1003 
1004 		/*
1005 		 * Check if a new context descriptor is needed for this packet
1006 		 */
1007 		load_context = ixgbe_check_context(tx_ring, ctx);
1008 
1009 		if (load_context) {
1010 			tbd = &tx_ring->tbd_ring[index];
1011 
1012 			/*
1013 			 * Fill the context descriptor with the
1014 			 * hardware checksum offload informations.
1015 			 */
1016 			ixgbe_fill_context(
1017 			    (struct ixgbe_adv_tx_context_desc *)tbd, ctx);
1018 
1019 			index = NEXT_INDEX(index, 1, tx_ring->ring_size);
1020 			desc_num++;
1021 
1022 			/*
1023 			 * Store the checksum context data if
1024 			 * a new context descriptor is added
1025 			 */
1026 			tx_ring->tx_context = *ctx;
1027 		}
1028 	}
1029 
1030 	first_tbd = &tx_ring->tbd_ring[index];
1031 
1032 	/*
1033 	 * Fill tx data descriptors with the data saved in the pending list.
1034 	 * The tx control blocks in the pending list are added to the work list
1035 	 * at the same time.
1036 	 *
1037 	 * The work list is strictly 1:1 corresponding to the descriptor ring.
1038 	 * One item of the work list corresponds to one tx descriptor. Because
1039 	 * one tx control block can span multiple tx descriptors, the tx
1040 	 * control block will be added to the first work list item that
1041 	 * corresponds to the first tx descriptor generated from that tx
1042 	 * control block.
1043 	 */
1044 	tcb = (tx_control_block_t *)LIST_POP_HEAD(pending_list);
1045 	first_tcb = tcb;
1046 	while (tcb != NULL) {
1047 
1048 		for (i = 0; i < tcb->desc_num; i++) {
1049 			tbd = &tx_ring->tbd_ring[index];
1050 
1051 			tbd->read.buffer_addr = tcb->desc[i].address;
1052 			tbd->read.cmd_type_len = tcb->desc[i].length;
1053 
1054 			tbd->read.cmd_type_len |= IXGBE_ADVTXD_DCMD_DEXT
1055 			    | IXGBE_ADVTXD_DTYP_DATA;
1056 
1057 			tbd->read.olinfo_status = 0;
1058 
1059 			index = NEXT_INDEX(index, 1, tx_ring->ring_size);
1060 			desc_num++;
1061 		}
1062 
1063 		/*
1064 		 * Add the tx control block to the work list
1065 		 */
1066 		ASSERT(tx_ring->work_list[tcb_index] == NULL);
1067 		tx_ring->work_list[tcb_index] = tcb;
1068 
1069 		tcb_index = index;
1070 		tcb = (tx_control_block_t *)LIST_POP_HEAD(pending_list);
1071 	}
1072 
1073 	if (load_context) {
1074 		/*
1075 		 * Count the context descriptor for
1076 		 * the first tx control block.
1077 		 */
1078 		first_tcb->desc_num++;
1079 	}
1080 	first_tcb->last_index = PREV_INDEX(index, 1, tx_ring->ring_size);
1081 
1082 	/*
1083 	 * The Insert Ethernet CRC (IFCS) bit and the checksum fields are only
1084 	 * valid in the first descriptor of the packet.
1085 	 * Setting paylen in every first_tbd for all parts.
1086 	 * 82599, X540 and X550 require the packet length in paylen field
1087 	 * with or without LSO and 82598 will ignore it in non-LSO mode.
1088 	 */
1089 	ASSERT(first_tbd != NULL);
1090 	first_tbd->read.cmd_type_len |= IXGBE_ADVTXD_DCMD_IFCS;
1091 
1092 	switch (hw->mac.type) {
1093 	case ixgbe_mac_82598EB:
1094 		if (ctx != NULL && ctx->lso_flag) {
1095 			first_tbd->read.cmd_type_len |= IXGBE_ADVTXD_DCMD_TSE;
1096 			first_tbd->read.olinfo_status |=
1097 			    (mbsize - ctx->mac_hdr_len - ctx->ip_hdr_len
1098 			    - ctx->l4_hdr_len) << IXGBE_ADVTXD_PAYLEN_SHIFT;
1099 		}
1100 		break;
1101 
1102 	case ixgbe_mac_82599EB:
1103 	case ixgbe_mac_X540:
1104 	case ixgbe_mac_X550:
1105 	case ixgbe_mac_X550EM_x:
1106 	case ixgbe_mac_X550EM_a:
1107 		if (ctx != NULL && ctx->lso_flag) {
1108 			first_tbd->read.cmd_type_len |= IXGBE_ADVTXD_DCMD_TSE;
1109 			first_tbd->read.olinfo_status |=
1110 			    (mbsize - ctx->mac_hdr_len - ctx->ip_hdr_len
1111 			    - ctx->l4_hdr_len) << IXGBE_ADVTXD_PAYLEN_SHIFT;
1112 		} else {
1113 			first_tbd->read.olinfo_status |=
1114 			    (mbsize << IXGBE_ADVTXD_PAYLEN_SHIFT);
1115 		}
1116 		break;
1117 
1118 	default:
1119 		break;
1120 	}
1121 
1122 	/* Set hardware checksum bits */
1123 	if (hcksum_flags != 0) {
1124 		if (hcksum_flags & HCK_IPV4_HDRCKSUM)
1125 			first_tbd->read.olinfo_status |=
1126 			    IXGBE_ADVTXD_POPTS_IXSM;
1127 		if (hcksum_flags & HCK_PARTIALCKSUM)
1128 			first_tbd->read.olinfo_status |=
1129 			    IXGBE_ADVTXD_POPTS_TXSM;
1130 	}
1131 
1132 	/*
1133 	 * The last descriptor of packet needs End Of Packet (EOP),
1134 	 * and Report Status (RS) bits set
1135 	 */
1136 	ASSERT(tbd != NULL);
1137 	tbd->read.cmd_type_len |=
1138 	    IXGBE_ADVTXD_DCMD_EOP | IXGBE_ADVTXD_DCMD_RS;
1139 
1140 	/*
1141 	 * Sync the DMA buffer of the tx descriptor ring
1142 	 */
1143 	DMA_SYNC(&tx_ring->tbd_area, DDI_DMA_SYNC_FORDEV);
1144 
1145 	/*
1146 	 * Update the number of the free tx descriptors.
1147 	 * The mutual exclusion between the transmission and the recycling
1148 	 * (for the tx descriptor ring and the work list) is implemented
1149 	 * with the atomic operation on the number of the free tx descriptors.
1150 	 *
1151 	 * Note: we should always decrement the counter tbd_free before
1152 	 * advancing the hardware TDT pointer to avoid the race condition -
1153 	 * before the counter tbd_free is decremented, the transmit of the
1154 	 * tx descriptors has done and the counter tbd_free is increased by
1155 	 * the tx recycling.
1156 	 */
1157 	i = ixgbe_atomic_reserve(&tx_ring->tbd_free, desc_num);
1158 	ASSERT(i >= 0);
1159 
1160 	tx_ring->tbd_tail = index;
1161 
1162 	/*
1163 	 * Advance the hardware TDT pointer of the tx descriptor ring
1164 	 */
1165 	IXGBE_WRITE_REG(hw, IXGBE_TDT(tx_ring->index), index);
1166 
1167 	if (ixgbe_check_acc_handle(tx_ring->ixgbe->osdep.reg_handle) !=
1168 	    DDI_FM_OK) {
1169 		ddi_fm_service_impact(tx_ring->ixgbe->dip,
1170 		    DDI_SERVICE_DEGRADED);
1171 		atomic_or_32(&tx_ring->ixgbe->ixgbe_state, IXGBE_ERROR);
1172 	}
1173 
1174 	return (desc_num);
1175 }
1176 
1177 /*
1178  * ixgbe_save_desc
1179  *
1180  * Save the address/length pair to the private array
1181  * of the tx control block. The address/length pairs
1182  * will be filled into the tx descriptor ring later.
1183  */
1184 static void
1185 ixgbe_save_desc(tx_control_block_t *tcb, uint64_t address, size_t length)
1186 {
1187 	sw_desc_t *desc;
1188 
1189 	desc = &tcb->desc[tcb->desc_num];
1190 	desc->address = address;
1191 	desc->length = length;
1192 
1193 	tcb->desc_num++;
1194 }
1195 
1196 /*
1197  * ixgbe_tx_recycle_legacy
1198  *
1199  * Recycle the tx descriptors and tx control blocks.
1200  *
1201  * The work list is traversed to check if the corresponding
1202  * tx descriptors have been transmitted. If so, the resources
1203  * bound to the tx control blocks will be freed, and those
1204  * tx control blocks will be returned to the free list.
1205  */
1206 uint32_t
1207 ixgbe_tx_recycle_legacy(ixgbe_tx_ring_t *tx_ring)
1208 {
1209 	uint32_t index, last_index, prev_index;
1210 	int desc_num;
1211 	boolean_t desc_done;
1212 	tx_control_block_t *tcb;
1213 	link_list_t pending_list;
1214 	ixgbe_t *ixgbe = tx_ring->ixgbe;
1215 
1216 	mutex_enter(&tx_ring->recycle_lock);
1217 
1218 	ASSERT(tx_ring->tbd_free <= tx_ring->ring_size);
1219 
1220 	if (tx_ring->tbd_free == tx_ring->ring_size) {
1221 		tx_ring->recycle_fail = 0;
1222 		tx_ring->stall_watchdog = 0;
1223 		if (tx_ring->reschedule) {
1224 			tx_ring->reschedule = B_FALSE;
1225 			mac_tx_ring_update(ixgbe->mac_hdl,
1226 			    tx_ring->ring_handle);
1227 		}
1228 		mutex_exit(&tx_ring->recycle_lock);
1229 		return (0);
1230 	}
1231 
1232 	/*
1233 	 * Sync the DMA buffer of the tx descriptor ring
1234 	 */
1235 	DMA_SYNC(&tx_ring->tbd_area, DDI_DMA_SYNC_FORKERNEL);
1236 
1237 	if (ixgbe_check_dma_handle(tx_ring->tbd_area.dma_handle) != DDI_FM_OK) {
1238 		mutex_exit(&tx_ring->recycle_lock);
1239 		ddi_fm_service_impact(ixgbe->dip, DDI_SERVICE_DEGRADED);
1240 		atomic_or_32(&ixgbe->ixgbe_state, IXGBE_ERROR);
1241 		return (0);
1242 	}
1243 
1244 	LINK_LIST_INIT(&pending_list);
1245 	desc_num = 0;
1246 	index = tx_ring->tbd_head;	/* Index of next tbd/tcb to recycle */
1247 
1248 	tcb = tx_ring->work_list[index];
1249 	ASSERT(tcb != NULL);
1250 
1251 	while (tcb != NULL) {
1252 		/*
1253 		 * Get the last tx descriptor of this packet.
1254 		 * If the last tx descriptor is done, then
1255 		 * we can recycle all descriptors of a packet
1256 		 * which usually includes several tx control blocks.
1257 		 * For 82599, LSO descriptors can not be recycled
1258 		 * unless the whole packet's transmission is done.
1259 		 * That's why packet level recycling is used here.
1260 		 * For 82598, there's not such limit.
1261 		 */
1262 		last_index = tcb->last_index;
1263 		/*
1264 		 * MAX_TX_RING_SIZE is used to judge whether
1265 		 * the index is a valid value or not.
1266 		 */
1267 		if (last_index == MAX_TX_RING_SIZE)
1268 			break;
1269 
1270 		/*
1271 		 * Check if the Descriptor Done bit is set
1272 		 */
1273 		desc_done = tx_ring->tbd_ring[last_index].wb.status &
1274 		    IXGBE_TXD_STAT_DD;
1275 		if (desc_done) {
1276 			/*
1277 			 * recycle all descriptors of the packet
1278 			 */
1279 			while (tcb != NULL) {
1280 				/*
1281 				 * Strip off the tx control block from
1282 				 * the work list, and add it to the
1283 				 * pending list.
1284 				 */
1285 				tx_ring->work_list[index] = NULL;
1286 				LIST_PUSH_TAIL(&pending_list, &tcb->link);
1287 
1288 				/*
1289 				 * Count the total number of the tx
1290 				 * descriptors recycled
1291 				 */
1292 				desc_num += tcb->desc_num;
1293 
1294 				index = NEXT_INDEX(index, tcb->desc_num,
1295 				    tx_ring->ring_size);
1296 
1297 				tcb = tx_ring->work_list[index];
1298 
1299 				prev_index = PREV_INDEX(index, 1,
1300 				    tx_ring->ring_size);
1301 				if (prev_index == last_index)
1302 					break;
1303 			}
1304 		} else {
1305 			break;
1306 		}
1307 	}
1308 
1309 	/*
1310 	 * If no tx descriptors are recycled, no need to do more processing
1311 	 */
1312 	if (desc_num == 0) {
1313 		tx_ring->recycle_fail++;
1314 		mutex_exit(&tx_ring->recycle_lock);
1315 		return (0);
1316 	}
1317 
1318 	tx_ring->recycle_fail = 0;
1319 	tx_ring->stall_watchdog = 0;
1320 
1321 	/*
1322 	 * Update the head index of the tx descriptor ring
1323 	 */
1324 	tx_ring->tbd_head = index;
1325 
1326 	/*
1327 	 * Update the number of the free tx descriptors with atomic operations
1328 	 */
1329 	atomic_add_32(&tx_ring->tbd_free, desc_num);
1330 
1331 	if ((tx_ring->tbd_free >= ixgbe->tx_resched_thresh) &&
1332 	    (tx_ring->reschedule)) {
1333 		tx_ring->reschedule = B_FALSE;
1334 		mac_tx_ring_update(ixgbe->mac_hdl,
1335 		    tx_ring->ring_handle);
1336 	}
1337 	mutex_exit(&tx_ring->recycle_lock);
1338 
1339 	/*
1340 	 * Free the resources used by the tx control blocks
1341 	 * in the pending list
1342 	 */
1343 	tcb = (tx_control_block_t *)LIST_GET_HEAD(&pending_list);
1344 	while (tcb != NULL) {
1345 		/*
1346 		 * Release the resources occupied by the tx control block
1347 		 */
1348 		ixgbe_free_tcb(tcb);
1349 
1350 		tcb = (tx_control_block_t *)
1351 		    LIST_GET_NEXT(&pending_list, &tcb->link);
1352 	}
1353 
1354 	/*
1355 	 * Add the tx control blocks in the pending list to the free list.
1356 	 */
1357 	ixgbe_put_free_list(tx_ring, &pending_list);
1358 
1359 	return (desc_num);
1360 }
1361 
1362 /*
1363  * ixgbe_tx_recycle_head_wb
1364  *
1365  * Check the head write-back, and recycle all the transmitted
1366  * tx descriptors and tx control blocks.
1367  */
1368 uint32_t
1369 ixgbe_tx_recycle_head_wb(ixgbe_tx_ring_t *tx_ring)
1370 {
1371 	uint32_t index;
1372 	uint32_t head_wb;
1373 	int desc_num;
1374 	tx_control_block_t *tcb;
1375 	link_list_t pending_list;
1376 	ixgbe_t *ixgbe = tx_ring->ixgbe;
1377 
1378 	mutex_enter(&tx_ring->recycle_lock);
1379 
1380 	ASSERT(tx_ring->tbd_free <= tx_ring->ring_size);
1381 
1382 	if (tx_ring->tbd_free == tx_ring->ring_size) {
1383 		tx_ring->recycle_fail = 0;
1384 		tx_ring->stall_watchdog = 0;
1385 		if (tx_ring->reschedule) {
1386 			tx_ring->reschedule = B_FALSE;
1387 			mac_tx_ring_update(ixgbe->mac_hdl,
1388 			    tx_ring->ring_handle);
1389 		}
1390 		mutex_exit(&tx_ring->recycle_lock);
1391 		return (0);
1392 	}
1393 
1394 	/*
1395 	 * Sync the DMA buffer of the tx descriptor ring
1396 	 *
1397 	 * Note: For head write-back mode, the tx descriptors will not
1398 	 * be written back, but the head write-back value is stored at
1399 	 * the last extra tbd at the end of the DMA area, we still need
1400 	 * to sync the head write-back value for kernel.
1401 	 *
1402 	 * DMA_SYNC(&tx_ring->tbd_area, DDI_DMA_SYNC_FORKERNEL);
1403 	 */
1404 	(void) ddi_dma_sync(tx_ring->tbd_area.dma_handle,
1405 	    sizeof (union ixgbe_adv_tx_desc) * tx_ring->ring_size,
1406 	    sizeof (uint32_t),
1407 	    DDI_DMA_SYNC_FORKERNEL);
1408 
1409 	if (ixgbe_check_dma_handle(tx_ring->tbd_area.dma_handle) != DDI_FM_OK) {
1410 		mutex_exit(&tx_ring->recycle_lock);
1411 		ddi_fm_service_impact(ixgbe->dip,
1412 		    DDI_SERVICE_DEGRADED);
1413 		atomic_or_32(&ixgbe->ixgbe_state, IXGBE_ERROR);
1414 		return (0);
1415 	}
1416 
1417 	LINK_LIST_INIT(&pending_list);
1418 	desc_num = 0;
1419 	index = tx_ring->tbd_head;	/* Next index to clean */
1420 
1421 	/*
1422 	 * Get the value of head write-back
1423 	 */
1424 	head_wb = *tx_ring->tbd_head_wb;
1425 	while (index != head_wb) {
1426 		tcb = tx_ring->work_list[index];
1427 		ASSERT(tcb != NULL);
1428 
1429 		if (OFFSET(index, head_wb, tx_ring->ring_size) <
1430 		    tcb->desc_num) {
1431 			/*
1432 			 * The current tx control block is not
1433 			 * completely transmitted, stop recycling
1434 			 */
1435 			break;
1436 		}
1437 
1438 		/*
1439 		 * Strip off the tx control block from the work list,
1440 		 * and add it to the pending list.
1441 		 */
1442 		tx_ring->work_list[index] = NULL;
1443 		LIST_PUSH_TAIL(&pending_list, &tcb->link);
1444 
1445 		/*
1446 		 * Advance the index of the tx descriptor ring
1447 		 */
1448 		index = NEXT_INDEX(index, tcb->desc_num, tx_ring->ring_size);
1449 
1450 		/*
1451 		 * Count the total number of the tx descriptors recycled
1452 		 */
1453 		desc_num += tcb->desc_num;
1454 	}
1455 
1456 	/*
1457 	 * If no tx descriptors are recycled, no need to do more processing
1458 	 */
1459 	if (desc_num == 0) {
1460 		tx_ring->recycle_fail++;
1461 		mutex_exit(&tx_ring->recycle_lock);
1462 		return (0);
1463 	}
1464 
1465 	tx_ring->recycle_fail = 0;
1466 	tx_ring->stall_watchdog = 0;
1467 
1468 	/*
1469 	 * Update the head index of the tx descriptor ring
1470 	 */
1471 	tx_ring->tbd_head = index;
1472 
1473 	/*
1474 	 * Update the number of the free tx descriptors with atomic operations
1475 	 */
1476 	atomic_add_32(&tx_ring->tbd_free, desc_num);
1477 
1478 	if ((tx_ring->tbd_free >= ixgbe->tx_resched_thresh) &&
1479 	    (tx_ring->reschedule)) {
1480 		tx_ring->reschedule = B_FALSE;
1481 		mac_tx_ring_update(ixgbe->mac_hdl,
1482 		    tx_ring->ring_handle);
1483 	}
1484 	mutex_exit(&tx_ring->recycle_lock);
1485 
1486 	/*
1487 	 * Free the resources used by the tx control blocks
1488 	 * in the pending list
1489 	 */
1490 	tcb = (tx_control_block_t *)LIST_GET_HEAD(&pending_list);
1491 	while (tcb) {
1492 		/*
1493 		 * Release the resources occupied by the tx control block
1494 		 */
1495 		ixgbe_free_tcb(tcb);
1496 
1497 		tcb = (tx_control_block_t *)
1498 		    LIST_GET_NEXT(&pending_list, &tcb->link);
1499 	}
1500 
1501 	/*
1502 	 * Add the tx control blocks in the pending list to the free list.
1503 	 */
1504 	ixgbe_put_free_list(tx_ring, &pending_list);
1505 
1506 	return (desc_num);
1507 }
1508 
1509 /*
1510  * ixgbe_free_tcb - free up the tx control block
1511  *
1512  * Free the resources of the tx control block, including
1513  * unbind the previously bound DMA handle, and reset other
1514  * control fields.
1515  */
1516 void
1517 ixgbe_free_tcb(tx_control_block_t *tcb)
1518 {
1519 	switch (tcb->tx_type) {
1520 	case USE_COPY:
1521 		/*
1522 		 * Reset the buffer length that is used for copy
1523 		 */
1524 		tcb->tx_buf.len = 0;
1525 		break;
1526 	case USE_DMA:
1527 		/*
1528 		 * Release the DMA resource that is used for
1529 		 * DMA binding.
1530 		 */
1531 		(void) ddi_dma_unbind_handle(tcb->tx_dma_handle);
1532 		break;
1533 	default:
1534 		break;
1535 	}
1536 
1537 	/*
1538 	 * Free the mblk
1539 	 */
1540 	if (tcb->mp != NULL) {
1541 		freemsg(tcb->mp);
1542 		tcb->mp = NULL;
1543 	}
1544 
1545 	tcb->tx_type = USE_NONE;
1546 	tcb->last_index = MAX_TX_RING_SIZE;
1547 	tcb->frag_num = 0;
1548 	tcb->desc_num = 0;
1549 }
1550 
1551 /*
1552  * ixgbe_get_free_list - Get a free tx control block from the free list
1553  *
1554  * The atomic operation on the number of the available tx control block
1555  * in the free list is used to keep this routine mutual exclusive with
1556  * the routine ixgbe_put_check_list.
1557  */
1558 static tx_control_block_t *
1559 ixgbe_get_free_list(ixgbe_tx_ring_t *tx_ring)
1560 {
1561 	tx_control_block_t *tcb;
1562 
1563 	/*
1564 	 * Check and update the number of the free tx control block
1565 	 * in the free list.
1566 	 */
1567 	if (ixgbe_atomic_reserve(&tx_ring->tcb_free, 1) < 0)
1568 		return (NULL);
1569 
1570 	mutex_enter(&tx_ring->tcb_head_lock);
1571 
1572 	tcb = tx_ring->free_list[tx_ring->tcb_head];
1573 	ASSERT(tcb != NULL);
1574 	tx_ring->free_list[tx_ring->tcb_head] = NULL;
1575 	tx_ring->tcb_head = NEXT_INDEX(tx_ring->tcb_head, 1,
1576 	    tx_ring->free_list_size);
1577 
1578 	mutex_exit(&tx_ring->tcb_head_lock);
1579 
1580 	return (tcb);
1581 }
1582 
1583 /*
1584  * ixgbe_put_free_list
1585  *
1586  * Put a list of used tx control blocks back to the free list
1587  *
1588  * A mutex is used here to ensure the serialization. The mutual exclusion
1589  * between ixgbe_get_free_list and ixgbe_put_free_list is implemented with
1590  * the atomic operation on the counter tcb_free.
1591  */
1592 void
1593 ixgbe_put_free_list(ixgbe_tx_ring_t *tx_ring, link_list_t *pending_list)
1594 {
1595 	uint32_t index;
1596 	int tcb_num;
1597 	tx_control_block_t *tcb;
1598 
1599 	mutex_enter(&tx_ring->tcb_tail_lock);
1600 
1601 	index = tx_ring->tcb_tail;
1602 
1603 	tcb_num = 0;
1604 	tcb = (tx_control_block_t *)LIST_POP_HEAD(pending_list);
1605 	while (tcb != NULL) {
1606 		ASSERT(tx_ring->free_list[index] == NULL);
1607 		tx_ring->free_list[index] = tcb;
1608 
1609 		tcb_num++;
1610 
1611 		index = NEXT_INDEX(index, 1, tx_ring->free_list_size);
1612 
1613 		tcb = (tx_control_block_t *)LIST_POP_HEAD(pending_list);
1614 	}
1615 
1616 	tx_ring->tcb_tail = index;
1617 
1618 	/*
1619 	 * Update the number of the free tx control block
1620 	 * in the free list. This operation must be placed
1621 	 * under the protection of the lock.
1622 	 */
1623 	atomic_add_32(&tx_ring->tcb_free, tcb_num);
1624 
1625 	mutex_exit(&tx_ring->tcb_tail_lock);
1626 }
1627