Lines Matching refs:fpq
1257 struct fuse_pqueue *fpq = &fud->pq; in fuse_dev_do_read() local
1332 spin_lock(&fpq->lock); in fuse_dev_do_read()
1337 if (!fpq->connected) { in fuse_dev_do_read()
1342 list_add(&req->list, &fpq->io); in fuse_dev_do_read()
1343 spin_unlock(&fpq->lock); in fuse_dev_do_read()
1350 spin_lock(&fpq->lock); in fuse_dev_do_read()
1352 if (!fpq->connected) { in fuse_dev_do_read()
1365 list_move_tail(&req->list, &fpq->processing[hash]); in fuse_dev_do_read()
1368 spin_unlock(&fpq->lock); in fuse_dev_do_read()
1380 spin_unlock(&fpq->lock); in fuse_dev_do_read()
1855 struct fuse_pqueue *fpq = &fud->pq; in fuse_resend() local
1857 spin_lock(&fpq->lock); in fuse_resend()
1859 list_splice_tail_init(&fpq->processing[i], &to_queue); in fuse_resend()
1860 spin_unlock(&fpq->lock); in fuse_resend()
1925 static struct fuse_req *request_find(struct fuse_pqueue *fpq, u64 unique) in request_find() argument
1930 list_for_each_entry(req, &fpq->processing[hash], list) { in request_find()
1970 struct fuse_pqueue *fpq = &fud->pq; in fuse_dev_do_write() local
1999 spin_lock(&fpq->lock); in fuse_dev_do_write()
2001 if (fpq->connected) in fuse_dev_do_write()
2002 req = request_find(fpq, oh.unique & ~FUSE_INT_REQ_BIT); in fuse_dev_do_write()
2006 spin_unlock(&fpq->lock); in fuse_dev_do_write()
2013 spin_unlock(&fpq->lock); in fuse_dev_do_write()
2029 list_move(&req->list, &fpq->io); in fuse_dev_do_write()
2032 spin_unlock(&fpq->lock); in fuse_dev_do_write()
2043 spin_lock(&fpq->lock); in fuse_dev_do_write()
2045 if (!fpq->connected) in fuse_dev_do_write()
2051 spin_unlock(&fpq->lock); in fuse_dev_do_write()
2258 struct fuse_pqueue *fpq = &fud->pq; in fuse_abort_conn() local
2260 spin_lock(&fpq->lock); in fuse_abort_conn()
2261 fpq->connected = 0; in fuse_abort_conn()
2262 list_for_each_entry_safe(req, next, &fpq->io, list) { in fuse_abort_conn()
2274 list_splice_tail_init(&fpq->processing[i], in fuse_abort_conn()
2276 spin_unlock(&fpq->lock); in fuse_abort_conn()
2318 struct fuse_pqueue *fpq = &fud->pq; in fuse_dev_release() local
2322 spin_lock(&fpq->lock); in fuse_dev_release()
2323 WARN_ON(!list_empty(&fpq->io)); in fuse_dev_release()
2325 list_splice_init(&fpq->processing[i], &to_end); in fuse_dev_release()
2326 spin_unlock(&fpq->lock); in fuse_dev_release()