Searched refs:vq (Results 1 - 25 of 102) sorted by relevance

12345

/drivers/media/usb/em28xx/
H A Dem28xx-v4l.h18 int em28xx_start_analog_streaming(struct vb2_queue *vq, unsigned int count);
19 void em28xx_stop_vbi_streaming(struct vb2_queue *vq);
H A Dem28xx-vbi.c34 static int vbi_queue_setup(struct vb2_queue *vq, const struct v4l2_format *fmt, argument
38 struct em28xx *dev = vb2_get_drv_priv(vq);
/drivers/virtio/
H A Dvirtio_ring.c32 dev_err(&(_vq)->vq.vdev->dev, \
33 "%s:"fmt, (_vq)->vq.name, ##args); \
41 (_vq)->vq.name, (_vq)->in_use); \
49 dev_err(&_vq->vq.vdev->dev, \
50 "%s:"fmt, (_vq)->vq.name, ##args); \
53 #define START_USE(vq)
54 #define END_USE(vq)
59 struct virtqueue vq; member in struct:vring_virtqueue
85 bool (*notify)(struct virtqueue *vq);
100 #define to_vvq(_vq) container_of(_vq, struct vring_virtqueue, vq)
131 struct vring_virtqueue *vq = to_vvq(_vq); local
304 virtqueue_add_outbuf(struct virtqueue *vq, struct scatterlist *sg, unsigned int num, void *data, gfp_t gfp) argument
326 virtqueue_add_inbuf(struct virtqueue *vq, struct scatterlist *sg, unsigned int num, void *data, gfp_t gfp) argument
348 struct vring_virtqueue *vq = to_vvq(_vq); local
390 struct vring_virtqueue *vq = to_vvq(_vq); local
416 virtqueue_kick(struct virtqueue *vq) argument
424 detach_buf(struct vring_virtqueue *vq, unsigned int head) argument
449 more_used(const struct vring_virtqueue *vq) argument
472 struct vring_virtqueue *vq = to_vvq(_vq); local
538 struct vring_virtqueue *vq = to_vvq(_vq); local
558 struct vring_virtqueue *vq = to_vvq(_vq); local
586 struct vring_virtqueue *vq = to_vvq(_vq); local
626 struct vring_virtqueue *vq = to_vvq(_vq); local
661 struct vring_virtqueue *vq = to_vvq(_vq); local
687 struct vring_virtqueue *vq = to_vvq(_vq); local
715 struct vring_virtqueue *vq; local
764 vring_del_virtqueue(struct virtqueue *vq) argument
800 struct vring_virtqueue *vq = to_vvq(_vq); local
808 struct vring_virtqueue *vq = to_vvq(_vq); local
823 struct vring_virtqueue *vq = to_vvq(_vq); local
[all...]
H A Dvirtio_mmio.c129 struct virtqueue *vq; member in struct:virtio_mmio_vq_info
222 static bool vm_notify(struct virtqueue *vq) argument
224 struct virtio_mmio_device *vm_dev = to_virtio_mmio_device(vq->vdev);
228 writel(vq->index, vm_dev->base + VIRTIO_MMIO_QUEUE_NOTIFY);
253 ret |= vring_interrupt(irq, info->vq);
262 static void vm_del_vq(struct virtqueue *vq) argument
264 struct virtio_mmio_device *vm_dev = to_virtio_mmio_device(vq->vdev);
265 struct virtio_mmio_vq_info *info = vq->priv;
267 unsigned int index = vq->index;
273 vring_del_virtqueue(vq);
287 struct virtqueue *vq, *n; local
297 vm_setup_vq(struct virtio_device *vdev, unsigned index, void (*callback)(struct virtqueue *vq), const char *name) argument
303 struct virtqueue *vq; local
[all...]
H A Dvirtio_pci.c57 /* Vectors allocated, excluding per-vq vectors if any */
60 /* Whether we have vector per vq */
75 struct virtqueue *vq; member in struct:virtio_pci_vq_info
197 static bool vp_notify(struct virtqueue *vq) argument
199 struct virtio_pci_device *vp_dev = to_vp_device(vq->vdev);
203 iowrite16(vq->index, vp_dev->ioaddr + VIRTIO_PCI_QUEUE_NOTIFY);
226 if (vring_interrupt(irq, info->vq) == IRQ_HANDLED)
385 void (*callback)(struct virtqueue *vq),
391 struct virtqueue *vq; local
425 vq
384 setup_vq(struct virtio_device *vdev, unsigned index, void (*callback)(struct virtqueue *vq), const char *name, u16 msix_vec) argument
464 vp_del_vq(struct virtqueue *vq) argument
497 struct virtqueue *vq, *n; local
624 vp_set_vq_affinity(struct virtqueue *vq, int cpu) argument
[all...]
H A Dvirtio_balloon.c96 static void balloon_ack(struct virtqueue *vq) argument
98 struct virtio_balloon *vb = vq->vdev->priv;
103 static void tell_host(struct virtio_balloon *vb, struct virtqueue *vq) argument
111 virtqueue_add_outbuf(vq, &sg, 1, vb, GFP_KERNEL);
112 virtqueue_kick(vq);
115 wait_event(vb->acked, virtqueue_get_buf(vq, &len));
239 static void stats_request(struct virtqueue *vq) argument
241 struct virtio_balloon *vb = vq->vdev->priv;
249 struct virtqueue *vq; local
256 vq
[all...]
/drivers/vhost/
H A Dvhost.c36 #define vhost_used_event(vq) ((u16 __user *)&vq->avail->ring[vq->num])
37 #define vhost_avail_event(vq) ((u16 __user *)&vq->used->ring[vq->num])
178 struct vhost_virtqueue *vq)
180 vq->num = 1;
181 vq->desc = NULL;
182 vq
177 vhost_vq_reset(struct vhost_dev *dev, struct vhost_virtqueue *vq) argument
253 vhost_vq_free_iovecs(struct vhost_virtqueue *vq) argument
266 struct vhost_virtqueue *vq; local
297 struct vhost_virtqueue *vq; local
549 vq_access_ok(struct vhost_virtqueue *vq, unsigned int num, struct vring_desc __user *desc, struct vring_avail __user *avail, struct vring_used __user *used) argument
572 vq_log_access_ok(struct vhost_virtqueue *vq, void __user *log_base) argument
586 vhost_vq_access_ok(struct vhost_virtqueue *vq) argument
639 struct vhost_virtqueue *vq; local
862 struct vhost_virtqueue *vq; local
976 vhost_log_write(struct vhost_virtqueue *vq, struct vhost_log *log, unsigned int log_num, u64 len) argument
1001 vhost_update_used_flags(struct vhost_virtqueue *vq) argument
1020 vhost_update_avail_event(struct vhost_virtqueue *vq, u16 avail_event) argument
1039 vhost_init_used(struct vhost_virtqueue *vq) argument
1053 translate_desc(struct vhost_virtqueue *vq, u64 addr, u32 len, struct iovec iov[], int iov_size) argument
1108 get_indirect(struct vhost_virtqueue *vq, struct iovec iov[], unsigned int iov_size, unsigned int *out_num, unsigned int *in_num, struct vhost_log *log, unsigned int *log_num, struct vring_desc *indirect) argument
1204 vhost_get_vq_desc(struct vhost_virtqueue *vq, struct iovec iov[], unsigned int iov_size, unsigned int *out_num, unsigned int *in_num, struct vhost_log *log, unsigned int *log_num) argument
1328 vhost_discard_vq_desc(struct vhost_virtqueue *vq, int n) argument
1336 vhost_add_used(struct vhost_virtqueue *vq, unsigned int head, int len) argument
1344 __vhost_add_used_n(struct vhost_virtqueue *vq, struct vring_used_elem *heads, unsigned count) argument
1389 vhost_add_used_n(struct vhost_virtqueue *vq, struct vring_used_elem *heads, unsigned count) argument
1423 vhost_notify(struct vhost_dev *dev, struct vhost_virtqueue *vq) argument
1460 vhost_signal(struct vhost_dev *dev, struct vhost_virtqueue *vq) argument
1469 vhost_add_used_and_signal(struct vhost_dev *dev, struct vhost_virtqueue *vq, unsigned int head, int len) argument
1479 vhost_add_used_and_signal_n(struct vhost_dev *dev, struct vhost_virtqueue *vq, struct vring_used_elem *heads, unsigned count) argument
1489 vhost_enable_notify(struct vhost_dev *dev, struct vhost_virtqueue *vq) argument
1527 vhost_disable_notify(struct vhost_dev *dev, struct vhost_virtqueue *vq) argument
[all...]
H A Dnet.c81 struct vhost_virtqueue *vq; member in struct:vhost_net_ubuf_ref
85 struct vhost_virtqueue vq; member in struct:vhost_net_virtqueue
100 * Protected by vq mutex. Writers must also take device mutex. */
109 * Protected by tx vq lock. */
112 * Protected by tx vq lock. */
114 /* Flush in progress. Protected by tx vq lock. */
120 static void vhost_net_enable_zcopy(int vq) argument
122 vhost_net_zcopy_mask |= 0x1 << vq;
126 vhost_net_ubuf_alloc(struct vhost_virtqueue *vq, bool zcopy) argument
137 ubufs->vq
280 vhost_zerocopy_signal_used(struct vhost_net *net, struct vhost_virtqueue *vq) argument
309 struct vhost_virtqueue *vq = ubufs->vq; local
337 struct vhost_virtqueue *vq = &nvq->vq; local
490 get_rx_bufs(struct vhost_virtqueue *vq, struct vring_used_elem *heads, int datalen, unsigned *iovcount, struct vhost_log *log, unsigned *log_num, unsigned int quota) argument
557 struct vhost_virtqueue *vq = &nvq->vq; local
673 struct vhost_virtqueue *vq = container_of(work, struct vhost_virtqueue, local
682 struct vhost_virtqueue *vq = container_of(work, struct vhost_virtqueue, local
745 vhost_net_disable_vq(struct vhost_net *n, struct vhost_virtqueue *vq) argument
756 vhost_net_enable_vq(struct vhost_net *n, struct vhost_virtqueue *vq) argument
771 vhost_net_stop_vq(struct vhost_net *n, struct vhost_virtqueue *vq) argument
907 struct vhost_virtqueue *vq; local
[all...]
H A Dtest.c40 struct vhost_virtqueue *vq = &n->vqs[VHOST_TEST_VQ]; local
46 mutex_lock(&vq->mutex);
47 private = vq->private_data;
49 mutex_unlock(&vq->mutex);
53 vhost_disable_notify(&n->dev, vq);
56 head = vhost_get_vq_desc(vq, vq->iov,
57 ARRAY_SIZE(vq->iov),
64 if (head == vq->num) {
65 if (unlikely(vhost_enable_notify(&n->dev, vq))) {
95 struct vhost_virtqueue *vq = container_of(work, struct vhost_virtqueue, local
126 vhost_test_stop_vq(struct vhost_test *n, struct vhost_virtqueue *vq) argument
171 struct vhost_virtqueue *vq; local
244 struct vhost_virtqueue *vq; local
[all...]
H A Dscsi.c181 struct vhost_virtqueue vq; member in struct:vhost_scsi_virtqueue
189 * Indicate current inflight in use, protected by vq->mutex.
209 bool vs_events_missed; /* any missed events, protected by vq->mutex */
210 int vs_events_nr; /* num of pending events, protected by vq->mutex */
240 struct vhost_virtqueue *vq; local
244 vq = &vs->vqs[i].vq;
246 mutex_lock(&vq->mutex);
259 mutex_unlock(&vq->mutex);
264 tcm_vhost_get_inflight(struct vhost_virtqueue *vq) argument
565 struct vhost_virtqueue *vq = &vs->vqs[VHOST_SCSI_VQ_EVT].vq; local
604 struct vhost_virtqueue *vq = &vs->vqs[VHOST_SCSI_VQ_EVT].vq; local
655 struct vhost_virtqueue *vq = &vs->vqs[VHOST_SCSI_VQ_EVT].vq; local
684 int ret, vq; local
724 vhost_scsi_get_tag(struct vhost_virtqueue *vq, struct tcm_vhost_tpg *tpg, unsigned char *cdb, u64 scsi_tag, u16 lun, u8 task_attr, u32 exp_data_len, int data_direction) argument
948 vhost_scsi_send_bad_target(struct vhost_scsi *vs, struct vhost_virtqueue *vq, int head, unsigned out) argument
967 vhost_scsi_handle_vq(struct vhost_scsi *vs, struct vhost_virtqueue *vq) argument
1248 struct vhost_virtqueue *vq = container_of(work, struct vhost_virtqueue, local
1264 struct vhost_virtqueue *vq = container_of(work, struct vhost_virtqueue, local
1319 struct vhost_virtqueue *vq; local
1423 struct vhost_virtqueue *vq; local
1507 struct vhost_virtqueue *vq; local
1605 struct vhost_virtqueue *vq = &vs->vqs[VHOST_SCSI_VQ_EVT].vq; local
1717 struct vhost_virtqueue *vq; local
[all...]
H A Dvhost.h138 int vhost_vq_access_ok(struct vhost_virtqueue *vq);
159 int vhost_log_write(struct vhost_virtqueue *vq, struct vhost_log *log,
162 #define vq_err(vq, fmt, ...) do { \
164 if ((vq)->error_ctx) \
165 eventfd_signal((vq)->error_ctx, 1);\
175 static inline int vhost_has_feature(struct vhost_virtqueue *vq, int bit) argument
177 return vq->acked_features & (1 << bit);
/drivers/s390/kvm/
H A Dkvm_virtio.c169 static bool kvm_notify(struct virtqueue *vq) argument
172 struct kvm_vqconfig *config = vq->priv;
186 void (*callback)(struct virtqueue *vq),
191 struct virtqueue *vq; local
208 vq = vring_new_virtqueue(index, config->num, KVM_S390_VIRTIO_RING_ALIGN,
211 if (!vq) {
220 config->token = (u64) vq;
222 vq->priv = config;
223 return vq;
232 static void kvm_del_vq(struct virtqueue *vq) argument
184 kvm_find_vq(struct virtio_device *vdev, unsigned index, void (*callback)(struct virtqueue *vq), const char *name) argument
244 struct virtqueue *vq, *n; local
394 struct virtqueue *vq; local
[all...]
H A Dvirtio_ccw.c90 struct virtqueue *vq; member in struct:virtio_ccw_vq_info
144 static void drop_airq_indicator(struct virtqueue *vq, struct airq_info *info) argument
150 if (vq == (void *)airq_iv_get_ptr(info->aiv, i)) {
260 drop_airq_indicator(info->vq, vcdev->airq_info);
361 static bool virtio_ccw_kvm_notify(struct virtqueue *vq) argument
363 struct virtio_ccw_vq_info *info = vq->priv;
367 vcdev = to_vc_device(info->vq->vdev);
369 info->cookie = do_kvm_notify(schid, vq->index, info->cookie);
387 static void virtio_ccw_del_vq(struct virtqueue *vq, struct ccw1 *ccw) argument
389 struct virtio_ccw_device *vcdev = to_vc_device(vq
429 struct virtqueue *vq, *n; local
452 struct virtqueue *vq = NULL; local
869 struct virtqueue *vq; local
890 struct virtqueue *vq; local
[all...]
/drivers/char/hw_random/
H A Dvirtio-rng.c32 struct virtqueue *vq; member in struct:virtrng_info
43 static void random_recv_done(struct virtqueue *vq) argument
45 struct virtrng_info *vi = vq->vdev->priv;
48 if (!virtqueue_get_buf(vi->vq, &vi->data_avail))
62 virtqueue_add_inbuf(vi->vq, &sg, 1, buf, GFP_KERNEL);
64 virtqueue_kick(vi->vq);
128 vi->vq = virtio_find_single_vq(vdev, random_recv_done, "input");
129 if (IS_ERR(vi->vq)) {
130 err = PTR_ERR(vi->vq);
/drivers/lguest/
H A Dlguest_device.c232 static bool lg_notify(struct virtqueue *vq) argument
238 struct lguest_vq_info *lvq = vq->priv;
259 void (*callback)(struct virtqueue *vq),
264 struct virtqueue *vq; local
303 vq = vring_new_virtqueue(index, lvq->config.num, LGUEST_VRING_ALIGN, vdev,
305 if (!vq) {
324 dev_name(&vdev->dev), vq);
332 vq->priv = lvq;
333 return vq;
338 vring_del_virtqueue(vq);
257 lg_find_vq(struct virtio_device *vdev, unsigned index, void (*callback)(struct virtqueue *vq), const char *name) argument
348 lg_del_vq(struct virtqueue *vq) argument
364 struct virtqueue *vq, *n; local
[all...]
/drivers/remoteproc/
H A Dremoteproc_virtio.c33 static bool rproc_virtio_notify(struct virtqueue *vq) argument
35 struct rproc_vring *rvring = vq->priv;
39 dev_dbg(&rproc->dev, "kicking vq index: %d\n", notifyid);
61 dev_dbg(&rproc->dev, "vq index %d is interrupted\n", notifyid);
64 if (!rvring || !rvring->vq)
67 return vring_interrupt(0, rvring->vq);
73 void (*callback)(struct virtqueue *vq),
80 struct virtqueue *vq; local
107 * Create the new vq, and tell virtio we're not interested in
110 vq
71 rp_find_vq(struct virtio_device *vdev, unsigned id, void (*callback)(struct virtqueue *vq), const char *name) argument
126 struct virtqueue *vq, *n; local
[all...]
/drivers/media/v4l2-core/
H A Dv4l2-mem2mem.c359 struct vb2_queue *vq; local
361 vq = v4l2_m2m_get_vq(m2m_ctx, reqbufs->type);
362 return vb2_reqbufs(vq, reqbufs);
374 struct vb2_queue *vq; local
378 vq = v4l2_m2m_get_vq(m2m_ctx, buf->type);
379 ret = vb2_querybuf(vq, buf);
382 if (buf->memory == V4L2_MEMORY_MMAP && !V4L2_TYPE_IS_OUTPUT(vq->type)) {
383 if (V4L2_TYPE_IS_MULTIPLANAR(vq->type)) {
403 struct vb2_queue *vq; local
406 vq
422 struct vb2_queue *vq; local
436 struct vb2_queue *vq; local
450 struct vb2_queue *vq; local
462 struct vb2_queue *vq; local
616 struct vb2_queue *vq; local
[all...]
/drivers/scsi/
H A Dvirtio_scsi.c62 /* Protects vq */
65 struct virtqueue *vq; member in struct:virtio_scsi_vq
102 /* Get some buffers ready for event vq */
219 struct virtqueue *vq = virtscsi_vq->vq; local
223 virtqueue_disable_cb(vq);
224 while ((buf = virtqueue_get_buf(vq, &len)) != NULL)
227 if (unlikely(virtqueue_is_broken(vq)))
229 } while (!virtqueue_enable_cb(vq));
233 static void virtscsi_req_done(struct virtqueue *vq) argument
261 virtscsi_ctrl_done(struct virtqueue *vq) argument
405 virtscsi_event_done(struct virtqueue *vq) argument
420 virtscsi_add_cmd(struct virtqueue *vq, struct virtio_scsi_cmd *cmd, size_t req_size, size_t resp_size) argument
465 virtscsi_kick_cmd(struct virtio_scsi_vq *vq, struct virtio_scsi_cmd *cmd, size_t req_size, size_t resp_size) argument
567 struct virtio_scsi_vq *vq; local
856 virtscsi_init_vq(struct virtio_scsi_vq *virtscsi_vq, struct virtqueue *vq) argument
[all...]
/drivers/media/usb/au0828/
H A Dau0828-vbi.c38 free_buffer(struct videobuf_queue *vq, struct au0828_buffer *buf) argument
40 struct au0828_fh *fh = vq->priv_data;
114 vbi_queue(struct videobuf_queue *vq, struct videobuf_buffer *vb) argument
119 struct au0828_fh *fh = vq->priv_data;
/drivers/media/platform/vivid/
H A Dvivid-vbi-out.c30 static int vbi_out_queue_setup(struct vb2_queue *vq, const struct v4l2_format *fmt, argument
34 struct vivid_dev *dev = vb2_get_drv_priv(vq);
36 unsigned size = vq->type == V4L2_BUF_TYPE_SLICED_VBI_OUTPUT ?
45 if (vq->num_buffers + *nbuffers < 2)
46 *nbuffers = 2 - vq->num_buffers;
92 static int vbi_out_start_streaming(struct vb2_queue *vq, unsigned count) argument
94 struct vivid_dev *dev = vb2_get_drv_priv(vq);
117 static void vbi_out_stop_streaming(struct vb2_queue *vq) argument
119 struct vivid_dev *dev = vb2_get_drv_priv(vq);
H A Dvivid-vbi-cap.c138 static int vbi_cap_queue_setup(struct vb2_queue *vq, const struct v4l2_format *fmt, argument
142 struct vivid_dev *dev = vb2_get_drv_priv(vq);
144 unsigned size = vq->type == V4L2_BUF_TYPE_SLICED_VBI_CAPTURE ?
153 if (vq->num_buffers + *nbuffers < 2)
154 *nbuffers = 2 - vq->num_buffers;
200 static int vbi_cap_start_streaming(struct vb2_queue *vq, unsigned count) argument
202 struct vivid_dev *dev = vb2_get_drv_priv(vq);
225 static void vbi_cap_stop_streaming(struct vb2_queue *vq) argument
227 struct vivid_dev *dev = vb2_get_drv_priv(vq);
/drivers/net/
H A Dvirtio_net.c68 struct virtqueue *vq; member in struct:send_queue
80 struct virtqueue *vq; member in struct:receive_queue
162 static int vq2txq(struct virtqueue *vq) argument
164 return (vq->index - 1) / 2;
172 static int vq2rxq(struct virtqueue *vq) argument
174 return vq->index / 2;
214 static void skb_xmit_done(struct virtqueue *vq) argument
216 struct virtnet_info *vi = vq->vdev->priv;
219 virtqueue_disable_cb(vq);
222 netif_wake_subqueue(vi->dev, vq2txq(vq));
1486 struct virtqueue *vq = vi->sq[i].vq; local
1492 struct virtqueue *vq = vi->rq[i].vq; local
[all...]
/drivers/misc/mic/card/
H A Dmic_virtio.c190 static bool mic_notify(struct virtqueue *vq) argument
192 struct mic_vdev *mvdev = vq->priv;
198 static void mic_del_vq(struct virtqueue *vq, int n) argument
200 struct mic_vdev *mvdev = to_micvdev(vq->vdev);
201 struct vring *vr = (struct vring *)(vq + 1);
204 vring_del_virtqueue(vq);
212 struct virtqueue *vq, *n; local
217 list_for_each_entry_safe(vq, n, &vdev->vqs, list)
218 mic_del_vq(vq, idx++);
228 void (*callback)(struct virtqueue *vq),
226 mic_find_vq(struct virtio_device *vdev, unsigned index, void (*callback)(struct virtqueue *vq), const char *name) argument
234 struct virtqueue *vq; local
373 struct virtqueue *vq; local
[all...]
/drivers/media/usb/cx231xx/
H A Dcx231xx-vbi.c169 vbi_buffer_setup(struct videobuf_queue *vq, unsigned int *count, argument
172 struct cx231xx_fh *fh = vq->priv_data;
190 static void free_buffer(struct videobuf_queue *vq, struct cx231xx_buffer *buf) argument
192 struct cx231xx_fh *fh = vq->priv_data;
217 vbi_buffer_prepare(struct videobuf_queue *vq, struct videobuf_buffer *vb, argument
220 struct cx231xx_fh *fh = vq->priv_data;
240 rc = videobuf_iolock(vq, &buf->vb, NULL);
261 free_buffer(vq, buf);
266 vbi_buffer_queue(struct videobuf_queue *vq, struct videobuf_buffer *vb) argument
270 struct cx231xx_fh *fh = vq
279 vbi_buffer_release(struct videobuf_queue *vq, struct videobuf_buffer *vb) argument
[all...]
/drivers/media/pci/saa7134/
H A Dsaa7134-empress.c51 static int start_streaming(struct vb2_queue *vq, unsigned int count) argument
53 struct saa7134_dmaqueue *dmaq = vq->drv_priv;
58 err = saa7134_ts_start_streaming(vq, count);
79 static void stop_streaming(struct vb2_queue *vq) argument
81 struct saa7134_dmaqueue *dmaq = vq->drv_priv;
84 saa7134_ts_stop_streaming(vq);

Completed in 385 milliseconds

12345