1227 	struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_do_read()  local
1302 	spin_lock(&fpq->lock);  in fuse_dev_do_read()
1307 	if (!fpq->connected) {  in fuse_dev_do_read()
1312 	list_add(&req->list, &fpq->io);  in fuse_dev_do_read()
1313 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1320 	spin_lock(&fpq->lock);  in fuse_dev_do_read()
1322 	if (!fpq->connected) {  in fuse_dev_do_read()
1335 	list_move_tail(&req->list, &fpq->processing[hash]);  in fuse_dev_do_read()
1338 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1350 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1827 static struct fuse_req *request_find(struct fuse_pqueue *fpq, u64 unique)  in request_find()  argument
1832 	list_for_each_entry(req, &fpq->processing[hash], list) {  in request_find()
1872 	struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_do_write()  local
1901 	spin_lock(&fpq->lock);  in fuse_dev_do_write()
1903 	if (fpq->connected)  in fuse_dev_do_write()
1904 		req = request_find(fpq, oh.unique & ~FUSE_INT_REQ_BIT);  in fuse_dev_do_write()
1908 		spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1915 		spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1931 	list_move(&req->list, &fpq->io);  in fuse_dev_do_write()
1934 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1953 	spin_lock(&fpq->lock);  in fuse_dev_do_write()
1955 	if (!fpq->connected)  in fuse_dev_do_write()
1961 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
2168 			struct fuse_pqueue *fpq = &fud->pq;  in fuse_abort_conn()  local
2170 			spin_lock(&fpq->lock);  in fuse_abort_conn()
2171 			fpq->connected = 0;  in fuse_abort_conn()
2172 			list_for_each_entry_safe(req, next, &fpq->io, list) {  in fuse_abort_conn()
2184 				list_splice_tail_init(&fpq->processing[i],  in fuse_abort_conn()
2186 			spin_unlock(&fpq->lock);  in fuse_abort_conn()
2228 		struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_release()  local
2232 		spin_lock(&fpq->lock);  in fuse_dev_release()
2233 		WARN_ON(!list_empty(&fpq->io));  in fuse_dev_release()
2235 			list_splice_init(&fpq->processing[i], &to_end);  in fuse_dev_release()
2236 		spin_unlock(&fpq->lock);  in fuse_dev_release()