80 	struct fuse_pqueue *fpq;  in fuse_check_timeout()  local
104 		fpq = &fud->pq;  in fuse_check_timeout()
105 		spin_lock(&fpq->lock);  in fuse_check_timeout()
106 		if (fuse_request_expired(fc, &fpq->io) ||  in fuse_check_timeout()
107 		    fuse_fpq_processing_expired(fc, fpq->processing)) {  in fuse_check_timeout()
108 			spin_unlock(&fpq->lock);  in fuse_check_timeout()
113 		spin_unlock(&fpq->lock);  in fuse_check_timeout()
1408 	struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_do_read()  local
1483 	spin_lock(&fpq->lock);  in fuse_dev_do_read()
1488 	if (!fpq->connected) {  in fuse_dev_do_read()
1493 	list_add(&req->list, &fpq->io);  in fuse_dev_do_read()
1494 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1501 	spin_lock(&fpq->lock);  in fuse_dev_do_read()
1503 	if (!fpq->connected) {  in fuse_dev_do_read()
1516 	list_move_tail(&req->list, &fpq->processing[hash]);  in fuse_dev_do_read()
1519 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
1531 	spin_unlock(&fpq->lock);  in fuse_dev_do_read()
2007 		struct fuse_pqueue *fpq = &fud->pq;  in fuse_resend()  local
2009 		spin_lock(&fpq->lock);  in fuse_resend()
2011 			list_splice_tail_init(&fpq->processing[i], &to_queue);  in fuse_resend()
2012 		spin_unlock(&fpq->lock);  in fuse_resend()
2132 struct fuse_req *fuse_request_find(struct fuse_pqueue *fpq, u64 unique)  in fuse_request_find()  argument
2137 	list_for_each_entry(req, &fpq->processing[hash], list) {  in fuse_request_find()
2184 	struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_do_write()  local
2213 	spin_lock(&fpq->lock);  in fuse_dev_do_write()
2215 	if (fpq->connected)  in fuse_dev_do_write()
2216 		req = fuse_request_find(fpq, oh.unique & ~FUSE_INT_REQ_BIT);  in fuse_dev_do_write()
2220 		spin_unlock(&fpq->lock);  in fuse_dev_do_write()
2227 		spin_unlock(&fpq->lock);  in fuse_dev_do_write()
2243 	list_move(&req->list, &fpq->io);  in fuse_dev_do_write()
2246 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
2257 	spin_lock(&fpq->lock);  in fuse_dev_do_write()
2259 	if (!fpq->connected)  in fuse_dev_do_write()
2265 	spin_unlock(&fpq->lock);  in fuse_dev_do_write()
2473 			struct fuse_pqueue *fpq = &fud->pq;  in fuse_abort_conn()  local
2475 			spin_lock(&fpq->lock);  in fuse_abort_conn()
2476 			fpq->connected = 0;  in fuse_abort_conn()
2477 			list_for_each_entry_safe(req, next, &fpq->io, list) {  in fuse_abort_conn()
2489 				list_splice_tail_init(&fpq->processing[i],  in fuse_abort_conn()
2491 			spin_unlock(&fpq->lock);  in fuse_abort_conn()
2541 		struct fuse_pqueue *fpq = &fud->pq;  in fuse_dev_release()  local
2545 		spin_lock(&fpq->lock);  in fuse_dev_release()
2546 		WARN_ON(!list_empty(&fpq->io));  in fuse_dev_release()
2548 			list_splice_init(&fpq->processing[i], &to_end);  in fuse_dev_release()
2549 		spin_unlock(&fpq->lock);  in fuse_dev_release()