Lines Matching refs:queue
202 static struct sk_buff *xennet_get_rx_skb(struct netfront_queue *queue, in xennet_get_rx_skb() argument
206 struct sk_buff *skb = queue->rx_skbs[i]; in xennet_get_rx_skb()
207 queue->rx_skbs[i] = NULL; in xennet_get_rx_skb()
211 static grant_ref_t xennet_get_rx_ref(struct netfront_queue *queue, in xennet_get_rx_ref() argument
215 grant_ref_t ref = queue->grant_rx_ref[i]; in xennet_get_rx_ref()
216 queue->grant_rx_ref[i] = GRANT_INVALID_REF; in xennet_get_rx_ref()
232 struct netfront_queue *queue = (struct netfront_queue *)data; in rx_refill_timeout() local
233 napi_schedule(&queue->napi); in rx_refill_timeout()
236 static int netfront_tx_slot_available(struct netfront_queue *queue) in netfront_tx_slot_available() argument
238 return (queue->tx.req_prod_pvt - queue->tx.rsp_cons) < in netfront_tx_slot_available()
242 static void xennet_maybe_wake_tx(struct netfront_queue *queue) in xennet_maybe_wake_tx() argument
244 struct net_device *dev = queue->info->netdev; in xennet_maybe_wake_tx()
245 struct netdev_queue *dev_queue = netdev_get_tx_queue(dev, queue->id); in xennet_maybe_wake_tx()
248 netfront_tx_slot_available(queue) && in xennet_maybe_wake_tx()
250 netif_tx_wake_queue(netdev_get_tx_queue(dev, queue->id)); in xennet_maybe_wake_tx()
254 static struct sk_buff *xennet_alloc_one_rx_buffer(struct netfront_queue *queue) in xennet_alloc_one_rx_buffer() argument
259 skb = __netdev_alloc_skb(queue->info->netdev, in xennet_alloc_one_rx_buffer()
274 skb->dev = queue->info->netdev; in xennet_alloc_one_rx_buffer()
280 static void xennet_alloc_rx_buffers(struct netfront_queue *queue) in xennet_alloc_rx_buffers() argument
282 RING_IDX req_prod = queue->rx.req_prod_pvt; in xennet_alloc_rx_buffers()
285 if (unlikely(!netif_carrier_ok(queue->info->netdev))) in xennet_alloc_rx_buffers()
288 for (req_prod = queue->rx.req_prod_pvt; in xennet_alloc_rx_buffers()
289 req_prod - queue->rx.rsp_cons < NET_RX_RING_SIZE; in xennet_alloc_rx_buffers()
297 skb = xennet_alloc_one_rx_buffer(queue); in xennet_alloc_rx_buffers()
303 BUG_ON(queue->rx_skbs[id]); in xennet_alloc_rx_buffers()
304 queue->rx_skbs[id] = skb; in xennet_alloc_rx_buffers()
306 ref = gnttab_claim_grant_reference(&queue->gref_rx_head); in xennet_alloc_rx_buffers()
308 queue->grant_rx_ref[id] = ref; in xennet_alloc_rx_buffers()
312 req = RING_GET_REQUEST(&queue->rx, req_prod); in xennet_alloc_rx_buffers()
314 queue->info->xbdev->otherend_id, in xennet_alloc_rx_buffers()
321 queue->rx.req_prod_pvt = req_prod; in xennet_alloc_rx_buffers()
324 if (req_prod - queue->rx.rsp_cons < NET_RX_SLOTS_MIN) { in xennet_alloc_rx_buffers()
325 mod_timer(&queue->rx_refill_timer, jiffies + (HZ/10)); in xennet_alloc_rx_buffers()
331 RING_PUSH_REQUESTS_AND_CHECK_NOTIFY(&queue->rx, notify); in xennet_alloc_rx_buffers()
333 notify_remote_via_irq(queue->rx_irq); in xennet_alloc_rx_buffers()
341 struct netfront_queue *queue = NULL; in xennet_open() local
344 queue = &np->queues[i]; in xennet_open()
345 napi_enable(&queue->napi); in xennet_open()
347 spin_lock_bh(&queue->rx_lock); in xennet_open()
349 xennet_alloc_rx_buffers(queue); in xennet_open()
350 queue->rx.sring->rsp_event = queue->rx.rsp_cons + 1; in xennet_open()
351 if (RING_HAS_UNCONSUMED_RESPONSES(&queue->rx)) in xennet_open()
352 napi_schedule(&queue->napi); in xennet_open()
354 spin_unlock_bh(&queue->rx_lock); in xennet_open()
362 static void xennet_tx_buf_gc(struct netfront_queue *queue) in xennet_tx_buf_gc() argument
368 BUG_ON(!netif_carrier_ok(queue->info->netdev)); in xennet_tx_buf_gc()
371 prod = queue->tx.sring->rsp_prod; in xennet_tx_buf_gc()
374 for (cons = queue->tx.rsp_cons; cons != prod; cons++) { in xennet_tx_buf_gc()
377 txrsp = RING_GET_RESPONSE(&queue->tx, cons); in xennet_tx_buf_gc()
382 skb = queue->tx_skbs[id].skb; in xennet_tx_buf_gc()
384 queue->grant_tx_ref[id]) != 0)) { in xennet_tx_buf_gc()
390 queue->grant_tx_ref[id], GNTMAP_readonly); in xennet_tx_buf_gc()
392 &queue->gref_tx_head, queue->grant_tx_ref[id]); in xennet_tx_buf_gc()
393 queue->grant_tx_ref[id] = GRANT_INVALID_REF; in xennet_tx_buf_gc()
394 queue->grant_tx_page[id] = NULL; in xennet_tx_buf_gc()
395 add_id_to_freelist(&queue->tx_skb_freelist, queue->tx_skbs, id); in xennet_tx_buf_gc()
399 queue->tx.rsp_cons = prod; in xennet_tx_buf_gc()
409 queue->tx.sring->rsp_event = in xennet_tx_buf_gc()
410 prod + ((queue->tx.sring->req_prod - prod) >> 1) + 1; in xennet_tx_buf_gc()
412 } while ((cons == prod) && (prod != queue->tx.sring->rsp_prod)); in xennet_tx_buf_gc()
414 xennet_maybe_wake_tx(queue); in xennet_tx_buf_gc()
418 struct netfront_queue *queue; member
434 struct netfront_queue *queue = info->queue; in xennet_tx_setup_grant() local
437 id = get_id_from_freelist(&queue->tx_skb_freelist, queue->tx_skbs); in xennet_tx_setup_grant()
438 tx = RING_GET_REQUEST(&queue->tx, queue->tx.req_prod_pvt++); in xennet_tx_setup_grant()
439 ref = gnttab_claim_grant_reference(&queue->gref_tx_head); in xennet_tx_setup_grant()
442 gnttab_grant_foreign_access_ref(ref, queue->info->xbdev->otherend_id, in xennet_tx_setup_grant()
445 queue->tx_skbs[id].skb = skb; in xennet_tx_setup_grant()
446 queue->grant_tx_page[id] = page; in xennet_tx_setup_grant()
447 queue->grant_tx_ref[id] = ref; in xennet_tx_setup_grant()
460 struct netfront_queue *queue, struct sk_buff *skb, in xennet_make_first_txreq() argument
464 .queue = queue, in xennet_make_first_txreq()
486 struct netfront_queue *queue, struct xen_netif_tx_request *tx, in xennet_make_txreqs() argument
491 .queue = queue, in xennet_make_txreqs()
574 struct netfront_queue *queue = NULL; in xennet_start_xmit() local
583 queue = &np->queues[queue_index]; in xennet_start_xmit()
607 spin_lock_irqsave(&queue->tx_lock, flags); in xennet_start_xmit()
612 spin_unlock_irqrestore(&queue->tx_lock, flags); in xennet_start_xmit()
617 first_tx = tx = xennet_make_first_txreq(queue, skb, in xennet_start_xmit()
638 RING_GET_REQUEST(&queue->tx, queue->tx.req_prod_pvt++); in xennet_start_xmit()
654 tx = xennet_make_txreqs(queue, tx, skb, page, offset, len); in xennet_start_xmit()
659 tx = xennet_make_txreqs(queue, tx, skb, in xennet_start_xmit()
667 RING_PUSH_REQUESTS_AND_CHECK_NOTIFY(&queue->tx, notify); in xennet_start_xmit()
669 notify_remote_via_irq(queue->tx_irq); in xennet_start_xmit()
677 xennet_tx_buf_gc(queue); in xennet_start_xmit()
679 if (!netfront_tx_slot_available(queue)) in xennet_start_xmit()
680 netif_tx_stop_queue(netdev_get_tx_queue(dev, queue->id)); in xennet_start_xmit()
682 spin_unlock_irqrestore(&queue->tx_lock, flags); in xennet_start_xmit()
697 struct netfront_queue *queue; in xennet_close() local
700 queue = &np->queues[i]; in xennet_close()
701 napi_disable(&queue->napi); in xennet_close()
706 static void xennet_move_rx_slot(struct netfront_queue *queue, struct sk_buff *skb, in xennet_move_rx_slot() argument
709 int new = xennet_rxidx(queue->rx.req_prod_pvt); in xennet_move_rx_slot()
711 BUG_ON(queue->rx_skbs[new]); in xennet_move_rx_slot()
712 queue->rx_skbs[new] = skb; in xennet_move_rx_slot()
713 queue->grant_rx_ref[new] = ref; in xennet_move_rx_slot()
714 RING_GET_REQUEST(&queue->rx, queue->rx.req_prod_pvt)->id = new; in xennet_move_rx_slot()
715 RING_GET_REQUEST(&queue->rx, queue->rx.req_prod_pvt)->gref = ref; in xennet_move_rx_slot()
716 queue->rx.req_prod_pvt++; in xennet_move_rx_slot()
719 static int xennet_get_extras(struct netfront_queue *queue, in xennet_get_extras() argument
725 struct device *dev = &queue->info->netdev->dev; in xennet_get_extras()
726 RING_IDX cons = queue->rx.rsp_cons; in xennet_get_extras()
741 RING_GET_RESPONSE(&queue->rx, ++cons); in xennet_get_extras()
754 skb = xennet_get_rx_skb(queue, cons); in xennet_get_extras()
755 ref = xennet_get_rx_ref(queue, cons); in xennet_get_extras()
756 xennet_move_rx_slot(queue, skb, ref); in xennet_get_extras()
759 queue->rx.rsp_cons = cons; in xennet_get_extras()
763 static int xennet_get_responses(struct netfront_queue *queue, in xennet_get_responses() argument
769 struct device *dev = &queue->info->netdev->dev; in xennet_get_responses()
770 RING_IDX cons = queue->rx.rsp_cons; in xennet_get_responses()
771 struct sk_buff *skb = xennet_get_rx_skb(queue, cons); in xennet_get_responses()
772 grant_ref_t ref = xennet_get_rx_ref(queue, cons); in xennet_get_responses()
779 err = xennet_get_extras(queue, extras, rp); in xennet_get_responses()
780 cons = queue->rx.rsp_cons; in xennet_get_responses()
789 xennet_move_rx_slot(queue, skb, ref); in xennet_get_responses()
810 gnttab_release_grant_reference(&queue->gref_rx_head, ref); in xennet_get_responses()
825 rx = RING_GET_RESPONSE(&queue->rx, cons + slots); in xennet_get_responses()
826 skb = xennet_get_rx_skb(queue, cons + slots); in xennet_get_responses()
827 ref = xennet_get_rx_ref(queue, cons + slots); in xennet_get_responses()
838 queue->rx.rsp_cons = cons + slots; in xennet_get_responses()
872 static RING_IDX xennet_fill_frags(struct netfront_queue *queue, in xennet_fill_frags() argument
877 RING_IDX cons = queue->rx.rsp_cons; in xennet_fill_frags()
882 RING_GET_RESPONSE(&queue->rx, ++cons); in xennet_fill_frags()
927 static int handle_incoming_queue(struct netfront_queue *queue, in handle_incoming_queue() argument
930 struct netfront_stats *rx_stats = this_cpu_ptr(queue->info->rx_stats); in handle_incoming_queue()
941 skb->protocol = eth_type_trans(skb, queue->info->netdev); in handle_incoming_queue()
944 if (checksum_setup(queue->info->netdev, skb)) { in handle_incoming_queue()
947 queue->info->netdev->stats.rx_errors++; in handle_incoming_queue()
957 napi_gro_receive(&queue->napi, skb); in handle_incoming_queue()
965 struct netfront_queue *queue = container_of(napi, struct netfront_queue, napi); in xennet_poll() local
966 struct net_device *dev = queue->info->netdev; in xennet_poll()
978 spin_lock(&queue->rx_lock); in xennet_poll()
984 rp = queue->rx.sring->rsp_prod; in xennet_poll()
987 i = queue->rx.rsp_cons; in xennet_poll()
990 memcpy(rx, RING_GET_RESPONSE(&queue->rx, i), sizeof(*rx)); in xennet_poll()
993 err = xennet_get_responses(queue, &rinfo, rp, &tmpq); in xennet_poll()
1000 i = queue->rx.rsp_cons; in xennet_poll()
1012 queue->rx.rsp_cons += skb_queue_len(&tmpq); in xennet_poll()
1026 i = xennet_fill_frags(queue, skb, &tmpq); in xennet_poll()
1035 queue->rx.rsp_cons = ++i; in xennet_poll()
1041 work_done -= handle_incoming_queue(queue, &rxq); in xennet_poll()
1043 xennet_alloc_rx_buffers(queue); in xennet_poll()
1050 RING_FINAL_CHECK_FOR_RESPONSES(&queue->rx, more_to_do); in xennet_poll()
1055 spin_unlock(&queue->rx_lock); in xennet_poll()
1106 static void xennet_release_tx_bufs(struct netfront_queue *queue) in xennet_release_tx_bufs() argument
1113 if (skb_entry_is_link(&queue->tx_skbs[i])) in xennet_release_tx_bufs()
1116 skb = queue->tx_skbs[i].skb; in xennet_release_tx_bufs()
1117 get_page(queue->grant_tx_page[i]); in xennet_release_tx_bufs()
1118 gnttab_end_foreign_access(queue->grant_tx_ref[i], in xennet_release_tx_bufs()
1120 (unsigned long)page_address(queue->grant_tx_page[i])); in xennet_release_tx_bufs()
1121 queue->grant_tx_page[i] = NULL; in xennet_release_tx_bufs()
1122 queue->grant_tx_ref[i] = GRANT_INVALID_REF; in xennet_release_tx_bufs()
1123 add_id_to_freelist(&queue->tx_skb_freelist, queue->tx_skbs, i); in xennet_release_tx_bufs()
1128 static void xennet_release_rx_bufs(struct netfront_queue *queue) in xennet_release_rx_bufs() argument
1132 spin_lock_bh(&queue->rx_lock); in xennet_release_rx_bufs()
1138 skb = queue->rx_skbs[id]; in xennet_release_rx_bufs()
1142 ref = queue->grant_rx_ref[id]; in xennet_release_rx_bufs()
1154 queue->grant_rx_ref[id] = GRANT_INVALID_REF; in xennet_release_rx_bufs()
1159 spin_unlock_bh(&queue->rx_lock); in xennet_release_rx_bufs()
1220 struct netfront_queue *queue = dev_id; in xennet_tx_interrupt() local
1223 spin_lock_irqsave(&queue->tx_lock, flags); in xennet_tx_interrupt()
1224 xennet_tx_buf_gc(queue); in xennet_tx_interrupt()
1225 spin_unlock_irqrestore(&queue->tx_lock, flags); in xennet_tx_interrupt()
1232 struct netfront_queue *queue = dev_id; in xennet_rx_interrupt() local
1233 struct net_device *dev = queue->info->netdev; in xennet_rx_interrupt()
1236 RING_HAS_UNCONSUMED_RESPONSES(&queue->rx))) in xennet_rx_interrupt()
1237 napi_schedule(&queue->napi); in xennet_rx_interrupt()
1392 struct netfront_queue *queue = &info->queues[i]; in xennet_disconnect_backend() local
1394 if (queue->tx_irq && (queue->tx_irq == queue->rx_irq)) in xennet_disconnect_backend()
1395 unbind_from_irqhandler(queue->tx_irq, queue); in xennet_disconnect_backend()
1396 if (queue->tx_irq && (queue->tx_irq != queue->rx_irq)) { in xennet_disconnect_backend()
1397 unbind_from_irqhandler(queue->tx_irq, queue); in xennet_disconnect_backend()
1398 unbind_from_irqhandler(queue->rx_irq, queue); in xennet_disconnect_backend()
1400 queue->tx_evtchn = queue->rx_evtchn = 0; in xennet_disconnect_backend()
1401 queue->tx_irq = queue->rx_irq = 0; in xennet_disconnect_backend()
1404 napi_synchronize(&queue->napi); in xennet_disconnect_backend()
1406 xennet_release_tx_bufs(queue); in xennet_disconnect_backend()
1407 xennet_release_rx_bufs(queue); in xennet_disconnect_backend()
1408 gnttab_free_grant_references(queue->gref_tx_head); in xennet_disconnect_backend()
1409 gnttab_free_grant_references(queue->gref_rx_head); in xennet_disconnect_backend()
1412 xennet_end_access(queue->tx_ring_ref, queue->tx.sring); in xennet_disconnect_backend()
1413 xennet_end_access(queue->rx_ring_ref, queue->rx.sring); in xennet_disconnect_backend()
1415 queue->tx_ring_ref = GRANT_INVALID_REF; in xennet_disconnect_backend()
1416 queue->rx_ring_ref = GRANT_INVALID_REF; in xennet_disconnect_backend()
1417 queue->tx.sring = NULL; in xennet_disconnect_backend()
1418 queue->rx.sring = NULL; in xennet_disconnect_backend()
1460 static int setup_netfront_single(struct netfront_queue *queue) in setup_netfront_single() argument
1464 err = xenbus_alloc_evtchn(queue->info->xbdev, &queue->tx_evtchn); in setup_netfront_single()
1468 err = bind_evtchn_to_irqhandler(queue->tx_evtchn, in setup_netfront_single()
1470 0, queue->info->netdev->name, queue); in setup_netfront_single()
1473 queue->rx_evtchn = queue->tx_evtchn; in setup_netfront_single()
1474 queue->rx_irq = queue->tx_irq = err; in setup_netfront_single()
1479 xenbus_free_evtchn(queue->info->xbdev, queue->tx_evtchn); in setup_netfront_single()
1480 queue->tx_evtchn = 0; in setup_netfront_single()
1485 static int setup_netfront_split(struct netfront_queue *queue) in setup_netfront_split() argument
1489 err = xenbus_alloc_evtchn(queue->info->xbdev, &queue->tx_evtchn); in setup_netfront_split()
1492 err = xenbus_alloc_evtchn(queue->info->xbdev, &queue->rx_evtchn); in setup_netfront_split()
1496 snprintf(queue->tx_irq_name, sizeof(queue->tx_irq_name), in setup_netfront_split()
1497 "%s-tx", queue->name); in setup_netfront_split()
1498 err = bind_evtchn_to_irqhandler(queue->tx_evtchn, in setup_netfront_split()
1500 0, queue->tx_irq_name, queue); in setup_netfront_split()
1503 queue->tx_irq = err; in setup_netfront_split()
1505 snprintf(queue->rx_irq_name, sizeof(queue->rx_irq_name), in setup_netfront_split()
1506 "%s-rx", queue->name); in setup_netfront_split()
1507 err = bind_evtchn_to_irqhandler(queue->rx_evtchn, in setup_netfront_split()
1509 0, queue->rx_irq_name, queue); in setup_netfront_split()
1512 queue->rx_irq = err; in setup_netfront_split()
1517 unbind_from_irqhandler(queue->tx_irq, queue); in setup_netfront_split()
1518 queue->tx_irq = 0; in setup_netfront_split()
1520 xenbus_free_evtchn(queue->info->xbdev, queue->rx_evtchn); in setup_netfront_split()
1521 queue->rx_evtchn = 0; in setup_netfront_split()
1523 xenbus_free_evtchn(queue->info->xbdev, queue->tx_evtchn); in setup_netfront_split()
1524 queue->tx_evtchn = 0; in setup_netfront_split()
1530 struct netfront_queue *queue, unsigned int feature_split_evtchn) in setup_netfront() argument
1537 queue->tx_ring_ref = GRANT_INVALID_REF; in setup_netfront()
1538 queue->rx_ring_ref = GRANT_INVALID_REF; in setup_netfront()
1539 queue->rx.sring = NULL; in setup_netfront()
1540 queue->tx.sring = NULL; in setup_netfront()
1549 FRONT_RING_INIT(&queue->tx, txs, XEN_PAGE_SIZE); in setup_netfront()
1554 queue->tx_ring_ref = gref; in setup_netfront()
1563 FRONT_RING_INIT(&queue->rx, rxs, XEN_PAGE_SIZE); in setup_netfront()
1568 queue->rx_ring_ref = gref; in setup_netfront()
1571 err = setup_netfront_split(queue); in setup_netfront()
1577 err = setup_netfront_single(queue); in setup_netfront()
1588 gnttab_end_foreign_access_ref(queue->rx_ring_ref, 0); in setup_netfront()
1592 gnttab_end_foreign_access_ref(queue->tx_ring_ref, 0); in setup_netfront()
1603 static int xennet_init_queue(struct netfront_queue *queue) in xennet_init_queue() argument
1608 spin_lock_init(&queue->tx_lock); in xennet_init_queue()
1609 spin_lock_init(&queue->rx_lock); in xennet_init_queue()
1611 setup_timer(&queue->rx_refill_timer, rx_refill_timeout, in xennet_init_queue()
1612 (unsigned long)queue); in xennet_init_queue()
1614 snprintf(queue->name, sizeof(queue->name), "%s-q%u", in xennet_init_queue()
1615 queue->info->netdev->name, queue->id); in xennet_init_queue()
1618 queue->tx_skb_freelist = 0; in xennet_init_queue()
1620 skb_entry_set_link(&queue->tx_skbs[i], i+1); in xennet_init_queue()
1621 queue->grant_tx_ref[i] = GRANT_INVALID_REF; in xennet_init_queue()
1622 queue->grant_tx_page[i] = NULL; in xennet_init_queue()
1627 queue->rx_skbs[i] = NULL; in xennet_init_queue()
1628 queue->grant_rx_ref[i] = GRANT_INVALID_REF; in xennet_init_queue()
1633 &queue->gref_tx_head) < 0) { in xennet_init_queue()
1641 &queue->gref_rx_head) < 0) { in xennet_init_queue()
1650 gnttab_free_grant_references(queue->gref_tx_head); in xennet_init_queue()
1655 static int write_queue_xenstore_keys(struct netfront_queue *queue, in write_queue_xenstore_keys() argument
1662 struct xenbus_device *dev = queue->info->xbdev; in write_queue_xenstore_keys()
1678 dev->nodename, queue->id); in write_queue_xenstore_keys()
1685 queue->tx_ring_ref); in write_queue_xenstore_keys()
1692 queue->rx_ring_ref); in write_queue_xenstore_keys()
1701 if (queue->tx_evtchn == queue->rx_evtchn) { in write_queue_xenstore_keys()
1704 "event-channel", "%u", queue->tx_evtchn); in write_queue_xenstore_keys()
1712 "event-channel-tx", "%u", queue->tx_evtchn); in write_queue_xenstore_keys()
1719 "event-channel-rx", "%u", queue->rx_evtchn); in write_queue_xenstore_keys()
1744 struct netfront_queue *queue = &info->queues[i]; in xennet_destroy_queues() local
1747 napi_disable(&queue->napi); in xennet_destroy_queues()
1748 del_timer_sync(&queue->rx_refill_timer); in xennet_destroy_queues()
1749 netif_napi_del(&queue->napi); in xennet_destroy_queues()
1772 struct netfront_queue *queue = &info->queues[i]; in xennet_create_queues() local
1774 queue->id = i; in xennet_create_queues()
1775 queue->info = info; in xennet_create_queues()
1777 ret = xennet_init_queue(queue); in xennet_create_queues()
1785 netif_napi_add(queue->info->netdev, &queue->napi, in xennet_create_queues()
1788 napi_enable(&queue->napi); in xennet_create_queues()
1812 struct netfront_queue *queue = NULL; in talk_to_netback() local
1847 queue = &info->queues[i]; in talk_to_netback()
1848 err = setup_netfront(dev, queue, feature_split_evtchn); in talk_to_netback()
1890 queue = &info->queues[i]; in talk_to_netback()
1891 err = write_queue_xenstore_keys(queue, &xbt, 1); /* hierarchical */ in talk_to_netback()
1965 struct netfront_queue *queue = NULL; in xennet_connect() local
1997 queue = &np->queues[j]; in xennet_connect()
1999 notify_remote_via_irq(queue->tx_irq); in xennet_connect()
2000 if (queue->tx_irq != queue->rx_irq) in xennet_connect()
2001 notify_remote_via_irq(queue->rx_irq); in xennet_connect()
2003 spin_lock_irq(&queue->tx_lock); in xennet_connect()
2004 xennet_tx_buf_gc(queue); in xennet_connect()
2005 spin_unlock_irq(&queue->tx_lock); in xennet_connect()
2007 spin_lock_bh(&queue->rx_lock); in xennet_connect()
2008 xennet_alloc_rx_buffers(queue); in xennet_connect()
2009 spin_unlock_bh(&queue->rx_lock); in xennet_connect()