dev/e1000/if_igb.c

902 	struct igb_queue	*que;
933 	que = &adapter->queues[i];
942 		taskqueue_enqueue(que->tq, &txr->txq_task);
1399 	struct igb_queue *que = context;
1400 	struct adapter *adapter = que->adapter;
1401 	struct tx_ring *txr = que->txr;
1407 		more = igb_rxeof(que, adapter->rx_process_limit, NULL);
1423 			taskqueue_enqueue(que->tq, &que->que_task);
1433 	if (que->eims)
1434 		E1000_WRITE_REG(&adapter->hw, E1000_EIMS, que->eims);
1486 	struct igb_queue	*que = adapter->queues;
1509 	taskqueue_enqueue(que->tq, &que->que_task);
1513 		taskqueue_enqueue(que->tq, &adapter->link_task);
1531 	struct igb_queue	*que;
1555 		que = &adapter->queues[i];
1556 		txr = que->txr;
1558 		igb_rxeof(que, count, &rx_done);
1586 	struct igb_queue *que = arg;
1587 	struct adapter *adapter = que->adapter;
1589 	struct tx_ring *txr = que->txr;
1590 	struct rx_ring *rxr = que->rxr;
1598 	E1000_WRITE_REG(&adapter->hw, E1000_EIMC, que->eims);
1599 	++que->irqs;
1614 	more_rx = igb_rxeof(que, adapter->rx_process_limit, NULL);
1624         if (que->eitr_setting)
1626                     E1000_EITR(que->msix), que->eitr_setting);
1628         que->eitr_setting = 0;
1659         que->eitr_setting = newitr;
1670 		taskqueue_enqueue(que->tq, &que->que_task);
1673 		E1000_WRITE_REG(&adapter->hw, E1000_EIMS, que->eims);
2100 	struct igb_queue	*que = adapter->queues;
2114 	for (int i = 0; i < adapter->num_queues; i++, que++, txr++) {
2121 			taskqueue_enqueue(que->tq, &que->que_task);
2373 	struct igb_queue	*que = adapter->queues;
2403 	TASK_INIT(&que->que_task, 0, igb_handle_que, que);
2406 	que->tq = taskqueue_create_fast("igb_taskq", M_NOWAIT,
2407 	    taskqueue_thread_enqueue, &que->tq);
2408 	taskqueue_start_threads(&que->tq, 1, PI_NET, "%s taskq",
2415 		taskqueue_free(que->tq);
2416 		que->tq = NULL;
2433 	struct igb_queue	*que = adapter->queues;
2466 	for (int i = 0; i < adapter->num_queues; i++, vector++, que++) {
2468 		que->res = bus_alloc_resource_any(dev,
2470 		if (que->res == NULL) {
2476 		error = bus_setup_intr(dev, que->res,
2478 		    igb_msix_que, que, &que->tag);
2480 			que->res = NULL;
2485 		bus_describe_intr(dev, que->res, que->tag, "que %d", i);
2487 		que->msix = vector;
2489 			que->eims = E1000_EICR_TX_QUEUE0 << i;
2491 			que->eims = 1 << vector;
2516 			bus_bind_intr(dev, que->res, cpu_id);
2529 		TASK_INIT(&que->txr->txq_task, 0, igb_deferred_mq_start,
2530 		    que->txr);
2533 		TASK_INIT(&que->que_task, 0, igb_handle_que, que);
2534 		que->tq = taskqueue_create("igb_que", M_NOWAIT,
2535 		    taskqueue_thread_enqueue, &que->tq);
2546 			taskqueue_start_threads_cpuset(&que->tq, 1, PI_NET,
2548 			    "%s que (bucket %d)",
2552 			taskqueue_start_threads(&que->tq, 1, PI_NET,
2553 			    "%s que (qid %d)",
2558 			taskqueue_start_threads(&que->tq, 1, PI_NET, "%s que",
2596 	struct	igb_queue	*que;
2618 			que = &adapter->queues[i];
2621 				ivar |= (que->msix | E1000_IVAR_VALID) << 16;
2624 				ivar |= que->msix | E1000_IVAR_VALID;
2632 			que = &adapter->queues[i];
2635 				ivar |= (que->msix | E1000_IVAR_VALID) << 24;
2638 				ivar |= (que->msix | E1000_IVAR_VALID) << 8;
2641 			adapter->que_mask |= que->eims;
2654 			que = &adapter->queues[i];
2657 				ivar |= que->msix | E1000_IVAR_VALID;
2660 				ivar |= (que->msix | E1000_IVAR_VALID) << 16;
2663 			adapter->que_mask |= que->eims;
2669 			que = &adapter->queues[i];
2672 				ivar |= (que->msix | E1000_IVAR_VALID) << 8;
2675 				ivar |= (que->msix | E1000_IVAR_VALID) << 24;
2678 			adapter->que_mask |= que->eims;
2698 			que = &adapter->queues[i];
2701 			que->eims = tmp;
2703 			    i, que->eims);
2704 			adapter->que_mask |= que->eims;
2725 		que = &adapter->queues[i];
2726 		E1000_WRITE_REG(hw, E1000_EITR(que->msix), newitr);
2736 	struct		igb_queue *que = adapter->queues;
2754 	for (int i = 0; i < adapter->num_queues; i++, que++) {
2755 		rid = que->msix + 1;
2756 		if (que->tag != NULL) {
2757 			bus_teardown_intr(dev, que->res, que->tag);
2758 			que->tag = NULL;
2760 		if (que->res != NULL)
2762 			    SYS_RES_IRQ, rid, que->res);
2771 	que = adapter->queues;
2773 		taskqueue_drain(que->tq, &adapter->link_task);
2780 	for (int i = 0; i < adapter->num_queues; i++, que++) {
2781 		if (que->tq != NULL) {
2783 			taskqueue_drain(que->tq, &que->txr->txq_task);
2785 			taskqueue_drain(que->tq, &que->que_task);
2786 			taskqueue_free(que->tq);
3369 	struct igb_queue	*que = NULL;
3483 		que = &adapter->queues[i];
3484 		que->adapter = adapter;
3485 		que->txr = &adapter->tx_rings[i];
3486 		que->rxr = &adapter->rx_rings[i];
4981 igb_rxeof(struct igb_queue *que, int count, int *done)
4983 	struct adapter		*adapter = que->adapter;
4984 	struct rx_ring		*rxr = que->rxr;
5170 				rxr->fmp->m_pkthdr.flowid = que->msix;
5886 	struct igb_queue	*que = ((struct igb_queue *)oidp->oid_arg1);
5890 	reg = E1000_READ_REG(&que->adapter->hw, E1000_EITR(que->msix));