Home
last modified time | relevance | path

Searched refs:fpq (Results 1 – 7 of 7) sorted by relevance

/fs/fuse/
A Ddev.c81 struct fuse_pqueue *fpq; in fuse_check_timeout() local
105 fpq = &fud->pq; in fuse_check_timeout()
106 spin_lock(&fpq->lock); in fuse_check_timeout()
114 spin_unlock(&fpq->lock); in fuse_check_timeout()
1463 spin_lock(&fpq->lock); in fuse_dev_do_read()
1468 if (!fpq->connected) { in fuse_dev_do_read()
1481 spin_lock(&fpq->lock); in fuse_dev_do_read()
1483 if (!fpq->connected) { in fuse_dev_do_read()
2168 if (fpq->connected) in fuse_dev_do_write()
2212 if (!fpq->connected) in fuse_dev_do_write()
[all …]
A Ddev_uring.c212 kfree(queue->fpq.processing); in fuse_uring_destruct()
296 queue->fpq.processing = pq; in fuse_uring_create_queue()
297 fuse_pqueue_init(&queue->fpq); in fuse_uring_create_queue()
302 kfree(queue->fpq.processing); in fuse_uring_create_queue()
756 struct fuse_pqueue *fpq = &queue->fpq; in fuse_uring_add_to_pq() local
761 list_move_tail(&req->list, &fpq->processing[hash]); in fuse_uring_add_to_pq()
884 struct fuse_pqueue *fpq; in fuse_uring_commit_fetch() local
897 fpq = &queue->fpq; in fuse_uring_commit_fetch()
908 req = fuse_request_find(fpq, commit_id); in fuse_uring_commit_fetch()
A Dvirtio_fs.c764 struct fuse_pqueue *fpq = &fsvq->fud->pq; in virtio_fs_request_complete() local
793 spin_lock(&fpq->lock); in virtio_fs_request_complete()
795 spin_unlock(&fpq->lock); in virtio_fs_request_complete()
816 struct fuse_pqueue *fpq = &fsvq->fud->pq; in virtio_fs_requests_done_work() local
829 spin_lock(&fpq->lock); in virtio_fs_requests_done_work()
831 spin_unlock(&fpq->lock); in virtio_fs_requests_done_work()
1390 struct fuse_pqueue *fpq; in virtio_fs_enqueue_req() local
1446 fpq = &fsvq->fud->pq; in virtio_fs_enqueue_req()
1447 spin_lock(&fpq->lock); in virtio_fs_enqueue_req()
1448 list_add_tail(&req->list, fpq->processing); in virtio_fs_enqueue_req()
[all …]
A Dfuse_dev_i.h50 struct fuse_req *fuse_request_find(struct fuse_pqueue *fpq, u64 unique);
A Ddev_uring_i.h97 struct fuse_pqueue fpq; member
A Dinode.c943 void fuse_pqueue_init(struct fuse_pqueue *fpq) in fuse_pqueue_init() argument
947 spin_lock_init(&fpq->lock); in fuse_pqueue_init()
949 INIT_LIST_HEAD(&fpq->processing[i]); in fuse_pqueue_init()
950 INIT_LIST_HEAD(&fpq->io); in fuse_pqueue_init()
951 fpq->connected = 1; in fuse_pqueue_init()
A Dfuse_i.h1286 void fuse_pqueue_init(struct fuse_pqueue *fpq);

Completed in 36 milliseconds