Lines Matching refs:fpq
1205 struct fuse_pqueue *fpq = &fud->pq; in fuse_dev_do_read() local
1280 spin_lock(&fpq->lock); in fuse_dev_do_read()
1285 if (!fpq->connected) { in fuse_dev_do_read()
1290 list_add(&req->list, &fpq->io); in fuse_dev_do_read()
1291 spin_unlock(&fpq->lock); in fuse_dev_do_read()
1298 spin_lock(&fpq->lock); in fuse_dev_do_read()
1300 if (!fpq->connected) { in fuse_dev_do_read()
1313 list_move_tail(&req->list, &fpq->processing[hash]); in fuse_dev_do_read()
1316 spin_unlock(&fpq->lock); in fuse_dev_do_read()
1328 spin_unlock(&fpq->lock); in fuse_dev_do_read()
1805 static struct fuse_req *request_find(struct fuse_pqueue *fpq, u64 unique) in request_find() argument
1810 list_for_each_entry(req, &fpq->processing[hash], list) { in request_find()
1850 struct fuse_pqueue *fpq = &fud->pq; in fuse_dev_do_write() local
1879 spin_lock(&fpq->lock); in fuse_dev_do_write()
1881 if (fpq->connected) in fuse_dev_do_write()
1882 req = request_find(fpq, oh.unique & ~FUSE_INT_REQ_BIT); in fuse_dev_do_write()
1886 spin_unlock(&fpq->lock); in fuse_dev_do_write()
1893 spin_unlock(&fpq->lock); in fuse_dev_do_write()
1909 list_move(&req->list, &fpq->io); in fuse_dev_do_write()
1912 spin_unlock(&fpq->lock); in fuse_dev_do_write()
1923 spin_lock(&fpq->lock); in fuse_dev_do_write()
1925 if (!fpq->connected) in fuse_dev_do_write()
1931 spin_unlock(&fpq->lock); in fuse_dev_do_write()
2138 struct fuse_pqueue *fpq = &fud->pq; in fuse_abort_conn() local
2140 spin_lock(&fpq->lock); in fuse_abort_conn()
2141 fpq->connected = 0; in fuse_abort_conn()
2142 list_for_each_entry_safe(req, next, &fpq->io, list) { in fuse_abort_conn()
2154 list_splice_tail_init(&fpq->processing[i], in fuse_abort_conn()
2156 spin_unlock(&fpq->lock); in fuse_abort_conn()
2198 struct fuse_pqueue *fpq = &fud->pq; in fuse_dev_release() local
2202 spin_lock(&fpq->lock); in fuse_dev_release()
2203 WARN_ON(!list_empty(&fpq->io)); in fuse_dev_release()
2205 list_splice_init(&fpq->processing[i], &to_end); in fuse_dev_release()
2206 spin_unlock(&fpq->lock); in fuse_dev_release()