Lines Matching refs:queue

41 static int connect_rings(struct backend_info *be, struct xenvif_queue *queue);
55 struct xenvif_queue *queue = m->private; in xenvif_read_io_ring() local
56 struct xen_netif_tx_back_ring *tx_ring = &queue->tx; in xenvif_read_io_ring()
57 struct xen_netif_rx_back_ring *rx_ring = &queue->rx; in xenvif_read_io_ring()
63 seq_printf(m, "Queue %d\nTX: nr_ents %u\n", queue->id, in xenvif_read_io_ring()
79 queue->pending_prod, in xenvif_read_io_ring()
80 queue->pending_cons, in xenvif_read_io_ring()
81 nr_pending_reqs(queue)); in xenvif_read_io_ring()
83 queue->dealloc_prod, in xenvif_read_io_ring()
84 queue->dealloc_cons, in xenvif_read_io_ring()
85 queue->dealloc_prod - queue->dealloc_cons); in xenvif_read_io_ring()
110 queue->napi.state, queue->napi.weight, in xenvif_read_io_ring()
111 skb_queue_len(&queue->tx_queue), in xenvif_read_io_ring()
112 timer_pending(&queue->credit_timeout), in xenvif_read_io_ring()
113 queue->credit_bytes, in xenvif_read_io_ring()
114 queue->credit_usec, in xenvif_read_io_ring()
115 queue->remaining_credit, in xenvif_read_io_ring()
116 queue->credit_timeout.expires, in xenvif_read_io_ring()
119 dev_queue = netdev_get_tx_queue(queue->vif->dev, queue->id); in xenvif_read_io_ring()
122 queue->rx_queue_len, queue->rx_queue_max, in xenvif_read_io_ring()
123 skb_queue_len(&queue->rx_queue), in xenvif_read_io_ring()
136 struct xenvif_queue *queue = in xenvif_write_io_ring() local
158 xenvif_interrupt(0, (void *)queue); in xenvif_write_io_ring()
161 queue->id); in xenvif_write_io_ring()
170 void *queue = NULL; in xenvif_dump_open() local
173 queue = inode->i_private; in xenvif_dump_open()
174 ret = single_open(filp, xenvif_read_io_ring, queue); in xenvif_dump_open()
667 struct xenvif_queue *queue = &vif->queues[queue_index]; in xen_net_rate_changed() local
669 queue->credit_bytes = credit_bytes; in xen_net_rate_changed()
670 queue->credit_usec = credit_usec; in xen_net_rate_changed()
671 if (!mod_timer_pending(&queue->credit_timeout, jiffies) && in xen_net_rate_changed()
672 queue->remaining_credit > queue->credit_bytes) { in xen_net_rate_changed()
673 queue->remaining_credit = queue->credit_bytes; in xen_net_rate_changed()
751 struct xenvif_queue *queue; in connect() local
787 queue = &be->vif->queues[queue_index]; in connect()
788 queue->vif = be->vif; in connect()
789 queue->id = queue_index; in connect()
790 snprintf(queue->name, sizeof(queue->name), "%s-q%u", in connect()
791 be->vif->dev->name, queue->id); in connect()
793 err = xenvif_init_queue(queue); in connect()
805 queue->credit_bytes = credit_bytes; in connect()
806 queue->remaining_credit = credit_bytes; in connect()
807 queue->credit_usec = credit_usec; in connect()
809 err = connect_rings(be, queue); in connect()
815 xenvif_deinit_queue(queue); in connect()
856 static int connect_rings(struct backend_info *be, struct xenvif_queue *queue) in connect_rings() argument
859 unsigned int num_queues = queue->vif->num_queues; in connect_rings()
890 queue->id); in connect_rings()
920 err = xenvif_connect(queue, tx_ring_ref, rx_ring_ref, in connect_rings()