1241 	struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_do_read()  local
1292 	spin_lock(&fpq->lock);  in fuse_dev_do_read()
1293 	list_add(&req->list, &fpq->io);  in fuse_dev_do_read()
1294 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1301 	spin_lock(&fpq->lock);  in fuse_dev_do_read()
1303 	if (!fpq->connected) {  in fuse_dev_do_read()
1315 	list_move_tail(&req->list, &fpq->processing);  in fuse_dev_do_read()
1316 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1328 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1825 static struct fuse_req *request_find(struct fuse_pqueue *fpq, u64 unique)  in request_find()  argument
1829 	list_for_each_entry(req, &fpq->processing, list) {  in request_find()
1871 	struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_do_write()  local
1899 	spin_lock(&fpq->lock);  in fuse_dev_do_write()
1901 	if (!fpq->connected)  in fuse_dev_do_write()
1904 	req = request_find(fpq, oh.unique);  in fuse_dev_do_write()
1910 		spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1926 	list_move(&req->list, &fpq->io);  in fuse_dev_do_write()
1929 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1937 	spin_lock(&fpq->lock);  in fuse_dev_do_write()
1939 	if (!fpq->connected)  in fuse_dev_do_write()
1945 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1952 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
2141 			struct fuse_pqueue *fpq = &fud->pq;  in fuse_abort_conn()  local
2143 			spin_lock(&fpq->lock);  in fuse_abort_conn()
2144 			fpq->connected = 0;  in fuse_abort_conn()
2145 			list_for_each_entry_safe(req, next, &fpq->io, list) {  in fuse_abort_conn()
2155 			list_splice_init(&fpq->processing, &to_end2);  in fuse_abort_conn()
2156 			spin_unlock(&fpq->lock);  in fuse_abort_conn()
2192 		struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_release()  local
2194 		WARN_ON(!list_empty(&fpq->io));  in fuse_dev_release()
2195 		end_requests(fc, &fpq->processing);  in fuse_dev_release()