1182 	struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_do_read()  local
1257 	spin_lock(&fpq->lock);  in fuse_dev_do_read()
1258 	list_add(&req->list, &fpq->io);  in fuse_dev_do_read()
1259 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1266 	spin_lock(&fpq->lock);  in fuse_dev_do_read()
1268 	if (!fpq->connected) {  in fuse_dev_do_read()
1281 	list_move_tail(&req->list, &fpq->processing[hash]);  in fuse_dev_do_read()
1284 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1296 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1783 static struct fuse_req *request_find(struct fuse_pqueue *fpq, u64 unique)  in request_find()  argument
1788 	list_for_each_entry(req, &fpq->processing[hash], list) {  in request_find()
1828 	struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_do_write()  local
1857 	spin_lock(&fpq->lock);  in fuse_dev_do_write()
1859 	if (fpq->connected)  in fuse_dev_do_write()
1860 		req = request_find(fpq, oh.unique & ~FUSE_INT_REQ_BIT);  in fuse_dev_do_write()
1864 		spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1871 		spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1887 	list_move(&req->list, &fpq->io);  in fuse_dev_do_write()
1890 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1901 	spin_lock(&fpq->lock);  in fuse_dev_do_write()
1903 	if (!fpq->connected)  in fuse_dev_do_write()
1909 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
2106 			struct fuse_pqueue *fpq = &fud->pq;  in fuse_abort_conn()  local
2108 			spin_lock(&fpq->lock);  in fuse_abort_conn()
2109 			fpq->connected = 0;  in fuse_abort_conn()
2110 			list_for_each_entry_safe(req, next, &fpq->io, list) {  in fuse_abort_conn()
2122 				list_splice_tail_init(&fpq->processing[i],  in fuse_abort_conn()
2124 			spin_unlock(&fpq->lock);  in fuse_abort_conn()
2166 		struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_release()  local
2170 		spin_lock(&fpq->lock);  in fuse_dev_release()
2171 		WARN_ON(!list_empty(&fpq->io));  in fuse_dev_release()
2173 			list_splice_init(&fpq->processing[i], &to_end);  in fuse_dev_release()
2174 		spin_unlock(&fpq->lock);  in fuse_dev_release()