RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-24 11:37:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

crimson/net: throw bad_peer_address when reconnect address doesn't match

Browse Source 
Signed-off-by: Yingxin Cheng <yingxin.cheng@intel.com>
This commit is contained in:
Yingxin Cheng 2019-08-08 17:14:47 +08:00
parent c41c44b2e9
commit 5491bc48ae
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/crimson/net/ProtocolV2.cc
View File

@ -1337,13 +1337,14 @@ ProtocolV2::server_reconnect()
reconnect.msg_seq());
// can peer_addrs be changed on-the-fly?
if (conn.peer_addr != reconnect.addrs().front()) {
logger().error("{} peer identifies as {}, while conn.peer_addr={}",
conn, reconnect.addrs().front(), conn.peer_addr);
ceph_assert(false);
}
// TODO: change peer_addr to entity_addrvec_t
ceph_assert(conn.peer_addr == conn.target_addr);
if (conn.peer_addr != reconnect.addrs().front()) {
logger().error("{} peer identifies as {}, while conn.peer_addr={},"
" reconnect failed",
conn, reconnect.addrs().front(), conn.peer_addr);
throw std::system_error(
make_error_code(ceph::net::error::bad_peer_address));
}
peer_global_seq = reconnect.global_seq();
SocketConnectionRef existing_conn = messenger.lookup_conn(conn.peer_addr);