Lines Matching defs:fpq
1210 struct fuse_pqueue *fpq = &fud->pq;
1285 spin_lock(&fpq->lock);
1287 * Must not put request on fpq->io queue after having been shut down by
1290 if (!fpq->connected) {
1295 list_add(&req->list, &fpq->io);
1296 spin_unlock(&fpq->lock);
1303 spin_lock(&fpq->lock);
1305 if (!fpq->connected) {
1318 list_move_tail(&req->list, &fpq->processing[hash]);
1321 spin_unlock(&fpq->lock);
1333 spin_unlock(&fpq->lock);
1810 static struct fuse_req *request_find(struct fuse_pqueue *fpq, u64 unique)
1815 list_for_each_entry(req, &fpq->processing[hash], list) {
1855 struct fuse_pqueue *fpq = &fud->pq;
1884 spin_lock(&fpq->lock);
1886 if (fpq->connected)
1887 req = request_find(fpq, oh.unique & ~FUSE_INT_REQ_BIT);
1891 spin_unlock(&fpq->lock);
1898 spin_unlock(&fpq->lock);
1914 list_move(&req->list, &fpq->io);
1917 spin_unlock(&fpq->lock);
1928 spin_lock(&fpq->lock);
1930 if (!fpq->connected)
1936 spin_unlock(&fpq->lock);
2143 struct fuse_pqueue *fpq = &fud->pq;
2145 spin_lock(&fpq->lock);
2146 fpq->connected = 0;
2147 list_for_each_entry_safe(req, next, &fpq->io, list) {
2159 list_splice_tail_init(&fpq->processing[i],
2161 spin_unlock(&fpq->lock);
2203 struct fuse_pqueue *fpq = &fud->pq;
2207 spin_lock(&fpq->lock);
2208 WARN_ON(!list_empty(&fpq->io));
2210 list_splice_init(&fpq->processing[i], &to_end);
2211 spin_unlock(&fpq->lock);