From 87efe7f90fd25fe24819bed7fb261bd47a53ac6e Mon Sep 17 00:00:00 2001 From: Jianpeng Ma Date: Wed, 24 Apr 2019 16:28:45 +0800 Subject: [PATCH] msg/async: no-need set connection for Message. In function decode_message, it already did. Signed-off-by: Jianpeng Ma (cherry picked from commit 7e1fcf82b61bf624fc5a1a8e647f74378ebccf4a) --- src/msg/async/ProtocolV1.cc | 2 -- src/msg/async/ProtocolV2.cc | 2 -- 2 files changed, 4 deletions(-) diff --git a/src/msg/async/ProtocolV1.cc b/src/msg/async/ProtocolV1.cc index 714eff74df8a7..bbf3126d3aaee 100644 --- a/src/msg/async/ProtocolV1.cc +++ b/src/msg/async/ProtocolV1.cc @@ -972,8 +972,6 @@ CtPtr ProtocolV1::handle_message_footer(char *buffer, int r) { } } - message->set_connection(connection); - #if defined(WITH_LTTNG) && defined(WITH_EVENTTRACE) if (message->get_type() == CEPH_MSG_OSD_OP || message->get_type() == CEPH_MSG_OSD_OPREPLY) { diff --git a/src/msg/async/ProtocolV2.cc b/src/msg/async/ProtocolV2.cc index 15c786ce75443..0bf17660b50d6 100644 --- a/src/msg/async/ProtocolV2.cc +++ b/src/msg/async/ProtocolV2.cc @@ -1443,8 +1443,6 @@ CtPtr ProtocolV2::handle_message() { } } - message->set_connection(connection); - #if defined(WITH_LTTNG) && defined(WITH_EVENTTRACE) if (message->get_type() == CEPH_MSG_OSD_OP || message->get_type() == CEPH_MSG_OSD_OPREPLY) { -- 2.39.5