Searched refs:fpq (Results 1 – 9 of 9) sorted by relevance
80 struct fuse_pqueue *fpq; in fuse_check_timeout() local104 fpq = &fud->pq; in fuse_check_timeout()105 spin_lock(&fpq->lock); in fuse_check_timeout()106 if (fuse_request_expired(fc, &fpq->io) || in fuse_check_timeout()107 fuse_fpq_processing_expired(fc, fpq->processing)) { in fuse_check_timeout()108 spin_unlock(&fpq->lock); in fuse_check_timeout()113 spin_unlock(&fpq->lock); in fuse_check_timeout()1408 struct fuse_pqueue *fpq = &fud->pq; in fuse_dev_do_read() local1483 spin_lock(&fpq->lock); in fuse_dev_do_read()1488 if (!fpq->connected) { in fuse_dev_do_read()[all …]
214 kfree(queue->fpq.processing); in fuse_uring_destruct()298 queue->fpq.processing = pq; in fuse_uring_create_queue()299 fuse_pqueue_init(&queue->fpq); in fuse_uring_create_queue()304 kfree(queue->fpq.processing); in fuse_uring_create_queue()761 struct fuse_pqueue *fpq = &queue->fpq; in fuse_uring_add_to_pq() local766 list_move_tail(&req->list, &fpq->processing[hash]); in fuse_uring_add_to_pq()889 struct fuse_pqueue *fpq; in fuse_uring_commit_fetch() local902 fpq = &queue->fpq; in fuse_uring_commit_fetch()913 req = fuse_request_find(fpq, commit_id); in fuse_uring_commit_fetch()
59 struct fuse_req *fuse_request_find(struct fuse_pqueue *fpq, u64 unique);
814 struct fuse_pqueue *fpq = &fsvq->fud->pq; in virtio_fs_requests_done_work() local827 spin_lock(&fpq->lock); in virtio_fs_requests_done_work()829 spin_unlock(&fpq->lock); in virtio_fs_requests_done_work()1388 struct fuse_pqueue *fpq; in virtio_fs_enqueue_req() local1444 fpq = &fsvq->fud->pq; in virtio_fs_enqueue_req()1446 spin_lock(&fpq->lock); in virtio_fs_enqueue_req()1447 list_add_tail(&req->list, &fpq->processing[hash]); in virtio_fs_enqueue_req()1448 spin_unlock(&fpq->lock); in virtio_fs_enqueue_req()
958 void fuse_pqueue_init(struct fuse_pqueue *fpq) in fuse_pqueue_init() argument962 spin_lock_init(&fpq->lock); in fuse_pqueue_init()964 INIT_LIST_HEAD(&fpq->processing[i]); in fuse_pqueue_init()965 INIT_LIST_HEAD(&fpq->io); in fuse_pqueue_init()966 fpq->connected = 1; in fuse_pqueue_init()
1329 void fuse_pqueue_init(struct fuse_pqueue *fpq);
29 struct fpq { struct48 struct fpq fpqueue[16]; argument
357 } fpq[16]; member
924 } fpq[16]; member