freescale/dpaa2/dpaa2-switch.c

664 		napi_enable(&ethsw->fq[i].napi);
680 		napi_disable(&ethsw->fq[i].napi);
2428 static void dpaa2_switch_tx_conf(struct dpaa2_switch_fq *fq,
2431 	dpaa2_switch_free_fd(fq->ethsw, fd);
2434 static void dpaa2_switch_rx(struct dpaa2_switch_fq *fq,
2437 	struct ethsw_core *ethsw = fq->ethsw;
2521 	ethsw->fq[i].fqid = ctrl_if_attr.rx_fqid;
2522 	ethsw->fq[i].ethsw = ethsw;
2523 	ethsw->fq[i++].type = DPSW_QUEUE_RX;
2525 	ethsw->fq[i].fqid = ctrl_if_attr.tx_err_conf_fqid;
2526 	ethsw->fq[i].ethsw = ethsw;
2527 	ethsw->fq[i++].type = DPSW_QUEUE_TX_ERR_CONF;
2754 		ethsw->fq[i].store =
2757 		if (!ethsw->fq[i].store) {
2760 				dpaa2_io_store_destroy(ethsw->fq[i].store);
2773 		dpaa2_io_store_destroy(ethsw->fq[i].store);
2776 static int dpaa2_switch_pull_fq(struct dpaa2_switch_fq *fq)
2784 		err = dpaa2_io_service_pull_fq(NULL, fq->fqid, fq->store);
2789 		dev_err(fq->ethsw->dev, "dpaa2_io_service_pull err %d", err);
2795 static int dpaa2_switch_store_consume(struct dpaa2_switch_fq *fq)
2797 	struct ethsw_core *ethsw = fq->ethsw;
2804 		dq = dpaa2_io_store_next(fq->store, &is_last);
2814 		if (fq->type == DPSW_QUEUE_RX)
2815 			dpaa2_switch_rx(fq, dpaa2_dq_fd(dq));
2817 			dpaa2_switch_tx_conf(fq, dpaa2_dq_fd(dq));
2829 	struct dpaa2_switch_fq *fq;
2832 	fq = container_of(napi, struct dpaa2_switch_fq, napi);
2835 		err = dpaa2_switch_pull_fq(fq);
2840 		dpaa2_switch_refill_bp(fq->ethsw);
2842 		store_cleaned = dpaa2_switch_store_consume(fq);
2857 		err = dpaa2_io_service_rearm(NULL, &fq->nctx);
2869 	struct dpaa2_switch_fq *fq;
2871 	fq = container_of(nctx, struct dpaa2_switch_fq, nctx);
2873 	napi_schedule(&fq->napi);
2883 		nctx = &ethsw->fq[i].nctx;
2890 		nctx->id = ethsw->fq[i].fqid;
2908 					     ethsw->fq[i].type,
2920 		dpaa2_io_service_deregister(NULL, &ethsw->fq[j].nctx,
2931 		dpaa2_io_service_deregister(NULL, &ethsw->fq[i].nctx,
3423 		netif_napi_add(ethsw->ports[0]->netdev, &ethsw->fq[i].napi,