1199 	struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_do_read()  local
1274 	spin_lock(&fpq->lock);  in fuse_dev_do_read()
1279 	if (!fpq->connected) {  in fuse_dev_do_read()
1284 	list_add(&req->list, &fpq->io);  in fuse_dev_do_read()
1285 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1292 	spin_lock(&fpq->lock);  in fuse_dev_do_read()
1294 	if (!fpq->connected) {  in fuse_dev_do_read()
1307 	list_move_tail(&req->list, &fpq->processing[hash]);  in fuse_dev_do_read()
1310 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1322 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1799 static struct fuse_req *request_find(struct fuse_pqueue *fpq, u64 unique)  in request_find()  argument
1804 	list_for_each_entry(req, &fpq->processing[hash], list) {  in request_find()
1844 	struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_do_write()  local
1873 	spin_lock(&fpq->lock);  in fuse_dev_do_write()
1875 	if (fpq->connected)  in fuse_dev_do_write()
1876 		req = request_find(fpq, oh.unique & ~FUSE_INT_REQ_BIT);  in fuse_dev_do_write()
1880 		spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1887 		spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1903 	list_move(&req->list, &fpq->io);  in fuse_dev_do_write()
1906 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
1917 	spin_lock(&fpq->lock);  in fuse_dev_do_write()
1919 	if (!fpq->connected)  in fuse_dev_do_write()
1925 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
2128 			struct fuse_pqueue *fpq = &fud->pq;  in fuse_abort_conn()  local
2130 			spin_lock(&fpq->lock);  in fuse_abort_conn()
2131 			fpq->connected = 0;  in fuse_abort_conn()
2132 			list_for_each_entry_safe(req, next, &fpq->io, list) {  in fuse_abort_conn()
2144 				list_splice_tail_init(&fpq->processing[i],  in fuse_abort_conn()
2146 			spin_unlock(&fpq->lock);  in fuse_abort_conn()
2188 		struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_release()  local
2192 		spin_lock(&fpq->lock);  in fuse_dev_release()
2193 		WARN_ON(!list_empty(&fpq->io));  in fuse_dev_release()
2195 			list_splice_init(&fpq->processing[i], &to_end);  in fuse_dev_release()
2196 		spin_unlock(&fpq->lock);  in fuse_dev_release()