1237 	struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_do_read()  local
1290 	spin_lock(&fpq->lock);  in fuse_dev_do_read()
1291 	list_add(&req->list, &fpq->io);  in fuse_dev_do_read()
1292 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1299 	spin_lock(&fpq->lock);  in fuse_dev_do_read()
1301 	if (!fpq->connected) {  in fuse_dev_do_read()
1313 	list_move_tail(&req->list, &fpq->processing);  in fuse_dev_do_read()
1314 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1326 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1793 static struct fuse_req *request_find(struct fuse_pqueue *fpq, u64 unique)  in request_find()  argument
1797 	list_for_each_entry(req, &fpq->processing, list) {  in request_find()
1839 	struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_do_write()  local
1867 	spin_lock(&fpq->lock);  in fuse_dev_do_write()
1869 	if (!fpq->connected)  in fuse_dev_do_write()
1872 	req = request_find(fpq, oh.unique);  in fuse_dev_do_write()
1878 		spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1894 	list_move(&req->list, &fpq->io);  in fuse_dev_do_write()
1897 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1905 	spin_lock(&fpq->lock);  in fuse_dev_do_write()
1907 	if (!fpq->connected)  in fuse_dev_do_write()
1913 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1920 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
2111 			struct fuse_pqueue *fpq = &fud->pq;  in fuse_abort_conn()  local
2113 			spin_lock(&fpq->lock);  in fuse_abort_conn()
2114 			fpq->connected = 0;  in fuse_abort_conn()
2115 			list_for_each_entry_safe(req, next, &fpq->io, list) {  in fuse_abort_conn()
2126 			list_splice_tail_init(&fpq->processing, &to_end);  in fuse_abort_conn()
2127 			spin_unlock(&fpq->lock);  in fuse_abort_conn()
2164 		struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_release()  local
2167 		spin_lock(&fpq->lock);  in fuse_dev_release()
2168 		WARN_ON(!list_empty(&fpq->io));  in fuse_dev_release()
2169 		list_splice_init(&fpq->processing, &to_end);  in fuse_dev_release()
2170 		spin_unlock(&fpq->lock);  in fuse_dev_release()