aboutsummaryrefslogtreecommitdiffstats
path: root/net/ceph/osd_client.c
diff options
context:
space:
mode:
Diffstat (limited to 'net/ceph/osd_client.c')
-rw-r--r--net/ceph/osd_client.c9
1 files changed, 4 insertions, 5 deletions
diff --git a/net/ceph/osd_client.c b/net/ceph/osd_client.c
index ad78705a4aff..c178c770acb4 100644
--- a/net/ceph/osd_client.c
+++ b/net/ceph/osd_client.c
@@ -140,10 +140,9 @@ void ceph_osdc_release_request(struct kref *kref)
140 if (req->r_request) 140 if (req->r_request)
141 ceph_msg_put(req->r_request); 141 ceph_msg_put(req->r_request);
142 if (req->r_con_filling_msg) { 142 if (req->r_con_filling_msg) {
143 dout("release_request revoking pages %p from con %p\n", 143 dout("%s revoking pages %p from con %p\n", __func__,
144 req->r_pages, req->r_con_filling_msg); 144 req->r_pages, req->r_con_filling_msg);
145 ceph_con_revoke_message(req->r_con_filling_msg, 145 ceph_msg_revoke_incoming(req->r_reply);
146 req->r_reply);
147 req->r_con_filling_msg->ops->put(req->r_con_filling_msg); 146 req->r_con_filling_msg->ops->put(req->r_con_filling_msg);
148 } 147 }
149 if (req->r_reply) 148 if (req->r_reply)
@@ -2022,9 +2021,9 @@ static struct ceph_msg *get_reply(struct ceph_connection *con,
2022 } 2021 }
2023 2022
2024 if (req->r_con_filling_msg) { 2023 if (req->r_con_filling_msg) {
2025 dout("get_reply revoking msg %p from old con %p\n", 2024 dout("%s revoking msg %p from old con %p\n", __func__,
2026 req->r_reply, req->r_con_filling_msg); 2025 req->r_reply, req->r_con_filling_msg);
2027 ceph_con_revoke_message(req->r_con_filling_msg, req->r_reply); 2026 ceph_msg_revoke_incoming(req->r_reply);
2028 req->r_con_filling_msg->ops->put(req->r_con_filling_msg); 2027 req->r_con_filling_msg->ops->put(req->r_con_filling_msg);
2029 req->r_con_filling_msg = NULL; 2028 req->r_con_filling_msg = NULL;
2030 } 2029 }