Searched refs:fpq (Results 1 – 10 of 10) 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()108 spin_unlock(&fpq->lock); in fuse_check_timeout()113 spin_unlock(&fpq->lock); in fuse_check_timeout()1461 spin_lock(&fpq->lock); in fuse_dev_do_read()1466 if (!fpq->connected) { in fuse_dev_do_read()1479 spin_lock(&fpq->lock); in fuse_dev_do_read()2142 if (fpq->connected) in fuse_dev_do_write()2186 if (!fpq->connected) in fuse_dev_do_write()[all …]
160 fuse_fpq_processing_expired(fc, queue->fpq.processing)) { in fuse_uring_request_expired()196 kfree(queue->fpq.processing); in fuse_uring_destruct()280 queue->fpq.processing = pq; in fuse_uring_create_queue()281 fuse_pqueue_init(&queue->fpq); in fuse_uring_create_queue()286 kfree(queue->fpq.processing); in fuse_uring_create_queue()740 struct fuse_pqueue *fpq = &queue->fpq; in fuse_uring_add_to_pq() local745 list_move_tail(&req->list, &fpq->processing[hash]); in fuse_uring_add_to_pq()868 struct fuse_pqueue *fpq; in fuse_uring_commit_fetch() local881 fpq = &queue->fpq; in fuse_uring_commit_fetch()892 req = fuse_request_find(fpq, commit_id); in fuse_uring_commit_fetch()
765 struct fuse_pqueue *fpq = &fsvq->fud->pq; in virtio_fs_request_complete() local794 spin_lock(&fpq->lock); in virtio_fs_request_complete()796 spin_unlock(&fpq->lock); in virtio_fs_request_complete()817 struct fuse_pqueue *fpq = &fsvq->fud->pq; in virtio_fs_requests_done_work() local830 spin_lock(&fpq->lock); in virtio_fs_requests_done_work()832 spin_unlock(&fpq->lock); in virtio_fs_requests_done_work()1391 struct fuse_pqueue *fpq; in virtio_fs_enqueue_req() local1447 fpq = &fsvq->fud->pq; in virtio_fs_enqueue_req()1448 spin_lock(&fpq->lock); in virtio_fs_enqueue_req()1449 list_add_tail(&req->list, fpq->processing); in virtio_fs_enqueue_req()[all …]
50 struct fuse_req *fuse_request_find(struct fuse_pqueue *fpq, u64 unique);
97 struct fuse_pqueue fpq; member
944 void fuse_pqueue_init(struct fuse_pqueue *fpq) in fuse_pqueue_init() argument948 spin_lock_init(&fpq->lock); in fuse_pqueue_init()950 INIT_LIST_HEAD(&fpq->processing[i]); in fuse_pqueue_init()951 INIT_LIST_HEAD(&fpq->io); in fuse_pqueue_init()952 fpq->connected = 1; in fuse_pqueue_init()
1293 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