diff options
Diffstat (limited to 'net/ceph/osd_client.c')
-rw-r--r-- | net/ceph/osd_client.c | 9 |
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 | } |