Lines Matching refs:fpq
1210 struct fuse_pqueue *fpq = &fud->pq; in fuse_dev_do_read() local
1285 spin_lock(&fpq->lock); in fuse_dev_do_read()
1290 if (!fpq->connected) { in fuse_dev_do_read()
1295 list_add(&req->list, &fpq->io); in fuse_dev_do_read()
1296 spin_unlock(&fpq->lock); in fuse_dev_do_read()
1303 spin_lock(&fpq->lock); in fuse_dev_do_read()
1305 if (!fpq->connected) { in fuse_dev_do_read()
1318 list_move_tail(&req->list, &fpq->processing[hash]); in fuse_dev_do_read()
1321 spin_unlock(&fpq->lock); in fuse_dev_do_read()
1333 spin_unlock(&fpq->lock); in fuse_dev_do_read()
1810 static struct fuse_req *request_find(struct fuse_pqueue *fpq, u64 unique) in request_find() argument
1815 list_for_each_entry(req, &fpq->processing[hash], list) { in request_find()
1855 struct fuse_pqueue *fpq = &fud->pq; in fuse_dev_do_write() local
1884 spin_lock(&fpq->lock); in fuse_dev_do_write()
1886 if (fpq->connected) in fuse_dev_do_write()
1887 req = request_find(fpq, oh.unique & ~FUSE_INT_REQ_BIT); in fuse_dev_do_write()
1891 spin_unlock(&fpq->lock); in fuse_dev_do_write()
1898 spin_unlock(&fpq->lock); in fuse_dev_do_write()
1914 list_move(&req->list, &fpq->io); in fuse_dev_do_write()
1917 spin_unlock(&fpq->lock); in fuse_dev_do_write()
1928 spin_lock(&fpq->lock); in fuse_dev_do_write()
1930 if (!fpq->connected) in fuse_dev_do_write()
1936 spin_unlock(&fpq->lock); in fuse_dev_do_write()
2143 struct fuse_pqueue *fpq = &fud->pq; in fuse_abort_conn() local
2145 spin_lock(&fpq->lock); in fuse_abort_conn()
2146 fpq->connected = 0; in fuse_abort_conn()
2147 list_for_each_entry_safe(req, next, &fpq->io, list) { in fuse_abort_conn()
2159 list_splice_tail_init(&fpq->processing[i], in fuse_abort_conn()
2161 spin_unlock(&fpq->lock); in fuse_abort_conn()
2203 struct fuse_pqueue *fpq = &fud->pq; in fuse_dev_release() local
2207 spin_lock(&fpq->lock); in fuse_dev_release()
2208 WARN_ON(!list_empty(&fpq->io)); in fuse_dev_release()
2210 list_splice_init(&fpq->processing[i], &to_end); in fuse_dev_release()
2211 spin_unlock(&fpq->lock); in fuse_dev_release()