fsvq               58 fs/fuse/virtio_fs.c static int virtio_fs_enqueue_req(struct virtio_fs_vq *fsvq,
fsvq               74 fs/fuse/virtio_fs.c static inline void inc_in_flight_req(struct virtio_fs_vq *fsvq)
fsvq               76 fs/fuse/virtio_fs.c 	fsvq->in_flight++;
fsvq               80 fs/fuse/virtio_fs.c static inline void dec_in_flight_req(struct virtio_fs_vq *fsvq)
fsvq               82 fs/fuse/virtio_fs.c 	WARN_ON(fsvq->in_flight <= 0);
fsvq               83 fs/fuse/virtio_fs.c 	fsvq->in_flight--;
fsvq              109 fs/fuse/virtio_fs.c static void virtio_fs_drain_queue(struct virtio_fs_vq *fsvq)
fsvq              111 fs/fuse/virtio_fs.c 	WARN_ON(fsvq->in_flight < 0);
fsvq              115 fs/fuse/virtio_fs.c 		spin_lock(&fsvq->lock);
fsvq              116 fs/fuse/virtio_fs.c 		if (!fsvq->in_flight) {
fsvq              117 fs/fuse/virtio_fs.c 			spin_unlock(&fsvq->lock);
fsvq              120 fs/fuse/virtio_fs.c 		spin_unlock(&fsvq->lock);
fsvq              125 fs/fuse/virtio_fs.c 	flush_work(&fsvq->done_work);
fsvq              126 fs/fuse/virtio_fs.c 	flush_delayed_work(&fsvq->dispatch_work);
fsvq              131 fs/fuse/virtio_fs.c 	struct virtio_fs_vq *fsvq;
fsvq              135 fs/fuse/virtio_fs.c 		fsvq = &fs->vqs[i];
fsvq              136 fs/fuse/virtio_fs.c 		virtio_fs_drain_queue(fsvq);
fsvq              142 fs/fuse/virtio_fs.c 	struct virtio_fs_vq *fsvq;
fsvq              146 fs/fuse/virtio_fs.c 		fsvq = &fs->vqs[i];
fsvq              147 fs/fuse/virtio_fs.c 		spin_lock(&fsvq->lock);
fsvq              148 fs/fuse/virtio_fs.c 		fsvq->connected = true;
fsvq              149 fs/fuse/virtio_fs.c 		spin_unlock(&fsvq->lock);
fsvq              203 fs/fuse/virtio_fs.c 		struct virtio_fs_vq *fsvq = &fs->vqs[i];
fsvq              205 fs/fuse/virtio_fs.c 		if (!fsvq->fud)
fsvq              208 fs/fuse/virtio_fs.c 		fuse_dev_free(fsvq->fud);
fsvq              209 fs/fuse/virtio_fs.c 		fsvq->fud = NULL;
fsvq              240 fs/fuse/virtio_fs.c 	struct virtio_fs_vq *fsvq = container_of(work, struct virtio_fs_vq,
fsvq              242 fs/fuse/virtio_fs.c 	struct virtqueue *vq = fsvq->vq;
fsvq              245 fs/fuse/virtio_fs.c 	spin_lock(&fsvq->lock);
fsvq              254 fs/fuse/virtio_fs.c 			dec_in_flight_req(fsvq);
fsvq              257 fs/fuse/virtio_fs.c 	spin_unlock(&fsvq->lock);
fsvq              263 fs/fuse/virtio_fs.c 	struct virtio_fs_vq *fsvq = container_of(work, struct virtio_fs_vq,
fsvq              265 fs/fuse/virtio_fs.c 	struct fuse_conn *fc = fsvq->fud->fc;
fsvq              270 fs/fuse/virtio_fs.c 		spin_lock(&fsvq->lock);
fsvq              271 fs/fuse/virtio_fs.c 		req = list_first_entry_or_null(&fsvq->end_reqs, struct fuse_req,
fsvq              274 fs/fuse/virtio_fs.c 			spin_unlock(&fsvq->lock);
fsvq              279 fs/fuse/virtio_fs.c 		spin_unlock(&fsvq->lock);
fsvq              285 fs/fuse/virtio_fs.c 		spin_lock(&fsvq->lock);
fsvq              286 fs/fuse/virtio_fs.c 		req = list_first_entry_or_null(&fsvq->queued_reqs,
fsvq              289 fs/fuse/virtio_fs.c 			spin_unlock(&fsvq->lock);
fsvq              293 fs/fuse/virtio_fs.c 		spin_unlock(&fsvq->lock);
fsvq              295 fs/fuse/virtio_fs.c 		ret = virtio_fs_enqueue_req(fsvq, req, true);
fsvq              298 fs/fuse/virtio_fs.c 				spin_lock(&fsvq->lock);
fsvq              299 fs/fuse/virtio_fs.c 				list_add_tail(&req->list, &fsvq->queued_reqs);
fsvq              300 fs/fuse/virtio_fs.c 				schedule_delayed_work(&fsvq->dispatch_work,
fsvq              302 fs/fuse/virtio_fs.c 				spin_unlock(&fsvq->lock);
fsvq              306 fs/fuse/virtio_fs.c 			spin_lock(&fsvq->lock);
fsvq              307 fs/fuse/virtio_fs.c 			dec_in_flight_req(fsvq);
fsvq              308 fs/fuse/virtio_fs.c 			spin_unlock(&fsvq->lock);
fsvq              319 fs/fuse/virtio_fs.c 	struct virtio_fs_vq *fsvq = container_of(work, struct virtio_fs_vq,
fsvq              321 fs/fuse/virtio_fs.c 	struct virtqueue *vq = fsvq->vq;
fsvq              329 fs/fuse/virtio_fs.c 		spin_lock(&fsvq->lock);
fsvq              330 fs/fuse/virtio_fs.c 		forget = list_first_entry_or_null(&fsvq->queued_reqs,
fsvq              333 fs/fuse/virtio_fs.c 			spin_unlock(&fsvq->lock);
fsvq              338 fs/fuse/virtio_fs.c 		if (!fsvq->connected) {
fsvq              339 fs/fuse/virtio_fs.c 			dec_in_flight_req(fsvq);
fsvq              340 fs/fuse/virtio_fs.c 			spin_unlock(&fsvq->lock);
fsvq              355 fs/fuse/virtio_fs.c 						&fsvq->queued_reqs);
fsvq              356 fs/fuse/virtio_fs.c 				schedule_delayed_work(&fsvq->dispatch_work,
fsvq              361 fs/fuse/virtio_fs.c 				dec_in_flight_req(fsvq);
fsvq              364 fs/fuse/virtio_fs.c 			spin_unlock(&fsvq->lock);
fsvq              369 fs/fuse/virtio_fs.c 		spin_unlock(&fsvq->lock);
fsvq              448 fs/fuse/virtio_fs.c 	struct virtio_fs_vq *fsvq = container_of(work, struct virtio_fs_vq,
fsvq              450 fs/fuse/virtio_fs.c 	struct fuse_pqueue *fpq = &fsvq->fud->pq;
fsvq              451 fs/fuse/virtio_fs.c 	struct fuse_conn *fc = fsvq->fud->fc;
fsvq              452 fs/fuse/virtio_fs.c 	struct virtqueue *vq = fsvq->vq;
fsvq              462 fs/fuse/virtio_fs.c 	spin_lock(&fsvq->lock);
fsvq              472 fs/fuse/virtio_fs.c 	spin_unlock(&fsvq->lock);
fsvq              505 fs/fuse/virtio_fs.c 		spin_lock(&fsvq->lock);
fsvq              506 fs/fuse/virtio_fs.c 		dec_in_flight_req(fsvq);
fsvq              507 fs/fuse/virtio_fs.c 		spin_unlock(&fsvq->lock);
fsvq              514 fs/fuse/virtio_fs.c 	struct virtio_fs_vq *fsvq = vq_to_fsvq(vq);
fsvq              516 fs/fuse/virtio_fs.c 	dev_dbg(&vq->vdev->dev, "%s %s\n", __func__, fsvq->name);
fsvq              518 fs/fuse/virtio_fs.c 	schedule_work(&fsvq->done_work);
fsvq              643 fs/fuse/virtio_fs.c 	struct virtio_fs_vq *fsvq;
fsvq              647 fs/fuse/virtio_fs.c 		fsvq = &fs->vqs[i];
fsvq              648 fs/fuse/virtio_fs.c 		spin_lock(&fsvq->lock);
fsvq              649 fs/fuse/virtio_fs.c 		fsvq->connected = false;
fsvq              650 fs/fuse/virtio_fs.c 		spin_unlock(&fsvq->lock);
fsvq              717 fs/fuse/virtio_fs.c 	struct virtio_fs_vq *fsvq;
fsvq              726 fs/fuse/virtio_fs.c 	fsvq = &fs->vqs[VQ_HIPRIO];
fsvq              745 fs/fuse/virtio_fs.c 	spin_lock(&fsvq->lock);
fsvq              747 fs/fuse/virtio_fs.c 	if (!fsvq->connected) {
fsvq              749 fs/fuse/virtio_fs.c 		spin_unlock(&fsvq->lock);
fsvq              753 fs/fuse/virtio_fs.c 	vq = fsvq->vq;
fsvq              761 fs/fuse/virtio_fs.c 			list_add_tail(&forget->list, &fsvq->queued_reqs);
fsvq              762 fs/fuse/virtio_fs.c 			schedule_delayed_work(&fsvq->dispatch_work,
fsvq              764 fs/fuse/virtio_fs.c 			inc_in_flight_req(fsvq);
fsvq              770 fs/fuse/virtio_fs.c 		spin_unlock(&fsvq->lock);
fsvq              774 fs/fuse/virtio_fs.c 	inc_in_flight_req(fsvq);
fsvq              777 fs/fuse/virtio_fs.c 	spin_unlock(&fsvq->lock);
fsvq              875 fs/fuse/virtio_fs.c static int virtio_fs_enqueue_req(struct virtio_fs_vq *fsvq,
fsvq              932 fs/fuse/virtio_fs.c 	spin_lock(&fsvq->lock);
fsvq              934 fs/fuse/virtio_fs.c 	if (!fsvq->connected) {
fsvq              935 fs/fuse/virtio_fs.c 		spin_unlock(&fsvq->lock);
fsvq              940 fs/fuse/virtio_fs.c 	vq = fsvq->vq;
fsvq              943 fs/fuse/virtio_fs.c 		spin_unlock(&fsvq->lock);
fsvq              948 fs/fuse/virtio_fs.c 	fpq = &fsvq->fud->pq;
fsvq              957 fs/fuse/virtio_fs.c 		inc_in_flight_req(fsvq);
fsvq              960 fs/fuse/virtio_fs.c 	spin_unlock(&fsvq->lock);
fsvq              984 fs/fuse/virtio_fs.c 	struct virtio_fs_vq *fsvq;
fsvq             1001 fs/fuse/virtio_fs.c 	fsvq = &fs->vqs[queue_id];
fsvq             1002 fs/fuse/virtio_fs.c 	ret = virtio_fs_enqueue_req(fsvq, req, false);
fsvq             1009 fs/fuse/virtio_fs.c 			spin_lock(&fsvq->lock);
fsvq             1010 fs/fuse/virtio_fs.c 			list_add_tail(&req->list, &fsvq->queued_reqs);
fsvq             1011 fs/fuse/virtio_fs.c 			inc_in_flight_req(fsvq);
fsvq             1012 fs/fuse/virtio_fs.c 			schedule_delayed_work(&fsvq->dispatch_work,
fsvq             1014 fs/fuse/virtio_fs.c 			spin_unlock(&fsvq->lock);
fsvq             1021 fs/fuse/virtio_fs.c 		spin_lock(&fsvq->lock);
fsvq             1022 fs/fuse/virtio_fs.c 		list_add_tail(&req->list, &fsvq->end_reqs);
fsvq             1023 fs/fuse/virtio_fs.c 		schedule_delayed_work(&fsvq->dispatch_work, 0);
fsvq             1024 fs/fuse/virtio_fs.c 		spin_unlock(&fsvq->lock);
fsvq             1069 fs/fuse/virtio_fs.c 		struct virtio_fs_vq *fsvq = &fs->vqs[i];
fsvq             1071 fs/fuse/virtio_fs.c 		fsvq->fud = fuse_dev_alloc();
fsvq             1072 fs/fuse/virtio_fs.c 		if (!fsvq->fud)
fsvq             1084 fs/fuse/virtio_fs.c 		struct virtio_fs_vq *fsvq = &fs->vqs[i];
fsvq             1088 fs/fuse/virtio_fs.c 		fuse_dev_install(fsvq->fud, fc);
fsvq             1108 fs/fuse/virtio_fs.c 	struct virtio_fs_vq *fsvq;
fsvq             1115 fs/fuse/virtio_fs.c 	fsvq = &vfs->vqs[VQ_HIPRIO];
fsvq             1118 fs/fuse/virtio_fs.c 	spin_lock(&fsvq->lock);
fsvq             1119 fs/fuse/virtio_fs.c 	fsvq->connected = false;
fsvq             1120 fs/fuse/virtio_fs.c 	spin_unlock(&fsvq->lock);