Lines Matching refs:fpq
1219 struct fuse_pqueue *fpq = &fud->pq;
1294 spin_lock(&fpq->lock);
1296 * Must not put request on fpq->io queue after having been shut down by
1299 if (!fpq->connected) {
1304 list_add(&req->list, &fpq->io);
1305 spin_unlock(&fpq->lock);
1312 spin_lock(&fpq->lock);
1314 if (!fpq->connected) {
1327 list_move_tail(&req->list, &fpq->processing[hash]);
1330 spin_unlock(&fpq->lock);
1342 spin_unlock(&fpq->lock);
1821 static struct fuse_req *request_find(struct fuse_pqueue *fpq, u64 unique)
1826 list_for_each_entry(req, &fpq->processing[hash], list) {
1866 struct fuse_pqueue *fpq = &fud->pq;
1895 spin_lock(&fpq->lock);
1897 if (fpq->connected)
1898 req = request_find(fpq, oh.unique & ~FUSE_INT_REQ_BIT);
1902 spin_unlock(&fpq->lock);
1909 spin_unlock(&fpq->lock);
1925 list_move(&req->list, &fpq->io);
1928 spin_unlock(&fpq->lock);
1939 spin_lock(&fpq->lock);
1941 if (!fpq->connected)
1947 spin_unlock(&fpq->lock);
2154 struct fuse_pqueue *fpq = &fud->pq;
2156 spin_lock(&fpq->lock);
2157 fpq->connected = 0;
2158 list_for_each_entry_safe(req, next, &fpq->io, list) {
2170 list_splice_tail_init(&fpq->processing[i],
2172 spin_unlock(&fpq->lock);
2214 struct fuse_pqueue *fpq = &fud->pq;
2218 spin_lock(&fpq->lock);
2219 WARN_ON(!list_empty(&fpq->io));
2221 list_splice_init(&fpq->processing[i], &to_end);
2222 spin_unlock(&fpq->lock);