Lines Matching refs:qp
77 struct ntb_transport_qp *qp; member
92 ntb_transport_link_query(dev->qp)); in ntb_netdev_event_handler()
95 if (ntb_transport_link_query(dev->qp)) in ntb_netdev_event_handler()
102 static void ntb_netdev_rx_handler(struct ntb_transport_qp *qp, void *qp_data, in ntb_netdev_rx_handler() argument
141 rc = ntb_transport_rx_enqueue(qp, skb, skb->data, ndev->mtu + ETH_HLEN); in ntb_netdev_rx_handler()
150 struct ntb_transport_qp *qp, int size) in __ntb_netdev_maybe_stop_tx() argument
160 if (likely(ntb_transport_tx_free_entry(qp) < size)) { in __ntb_netdev_maybe_stop_tx()
170 struct ntb_transport_qp *qp, int size) in ntb_netdev_maybe_stop_tx() argument
173 (ntb_transport_tx_free_entry(qp) >= size)) in ntb_netdev_maybe_stop_tx()
176 return __ntb_netdev_maybe_stop_tx(ndev, qp, size); in ntb_netdev_maybe_stop_tx()
179 static void ntb_netdev_tx_handler(struct ntb_transport_qp *qp, void *qp_data, in ntb_netdev_tx_handler() argument
200 if (ntb_transport_tx_free_entry(dev->qp) >= tx_start) { in ntb_netdev_tx_handler()
216 ntb_netdev_maybe_stop_tx(ndev, dev->qp, tx_stop); in ntb_netdev_start_xmit()
218 rc = ntb_transport_tx_enqueue(dev->qp, skb, skb->data, skb->len); in ntb_netdev_start_xmit()
223 ntb_netdev_maybe_stop_tx(ndev, dev->qp, tx_stop); in ntb_netdev_start_xmit()
238 if (ntb_transport_tx_free_entry(dev->qp) < tx_stop) { in ntb_netdev_tx_timer()
264 rc = ntb_transport_rx_enqueue(dev->qp, skb, skb->data, in ntb_netdev_open()
275 ntb_transport_link_up(dev->qp); in ntb_netdev_open()
281 while ((skb = ntb_transport_rx_remove(dev->qp, &len))) in ntb_netdev_open()
292 ntb_transport_link_down(dev->qp); in ntb_netdev_close()
294 while ((skb = ntb_transport_rx_remove(dev->qp, &len))) in ntb_netdev_close()
308 if (new_mtu > ntb_transport_max_size(dev->qp) - ETH_HLEN) in ntb_netdev_change_mtu()
317 ntb_transport_link_down(dev->qp); in ntb_netdev_change_mtu()
322 for (i = 0; (skb = ntb_transport_rx_remove(dev->qp, &len)); i++) in ntb_netdev_change_mtu()
332 rc = ntb_transport_rx_enqueue(dev->qp, skb, skb->data, in ntb_netdev_change_mtu()
343 ntb_transport_link_up(dev->qp); in ntb_netdev_change_mtu()
348 ntb_transport_link_down(dev->qp); in ntb_netdev_change_mtu()
350 while ((skb = ntb_transport_rx_remove(dev->qp, &len))) in ntb_netdev_change_mtu()
436 dev->qp = ntb_transport_create_queue(ndev, client_dev, in ntb_netdev_probe()
438 if (!dev->qp) { in ntb_netdev_probe()
443 ndev->mtu = ntb_transport_max_size(dev->qp) - ETH_HLEN; in ntb_netdev_probe()
454 ntb_transport_free_queue(dev->qp); in ntb_netdev_probe()
485 ntb_transport_free_queue(dev->qp); in ntb_netdev_remove()