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

msg/Messenger: remove get_connection() and send_message()

Browse Source 
Signed-off-by: Sage Weil <sage@redhat.com>
This commit is contained in:
Sage Weil 2019-01-14 14:17:47 -06:00
parent 9284680f89
commit aa3d6f6667
2 changed files with 2 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/msg/Messenger.h
View File

@ -445,10 +445,6 @@ public:
*
* @return 0 on success, or -errno on failure.
*/
virtual int send_message(Message *m, const entity_inst_t& dest) {
return send_to(m, dest.name.type(), entity_addrvec_t(dest.addr));
}
virtual int send_to(
Message *m,
int type,
@ -485,12 +481,6 @@ public:
*
* @param dest The entity to get a connection for.
*/
virtual ConnectionRef get_connection(const entity_inst_t& dest) {
// temporary
return connect_to(dest.name.type(),
entity_addrvec_t(dest.addr));
}
virtual ConnectionRef connect_to(
int type, const entity_addrvec_t& dest) = 0;
ConnectionRef connect_to_mon(const entity_addrvec_t& dest) {

7
src/msg/simple/SimpleMessenger.h
View File

@ -135,16 +135,13 @@ public:
* @defgroup Messaging
* @{
*/
int send_message(Message *m, const entity_inst_t& dest) override {
return _send_message(m, dest);
}
int send_to(
Message *m,
int type,
const entity_addrvec_t& addr) override {
// temporary
return send_message(m, entity_inst_t(entity_name_t(type, -1),
addr.legacy_addr()));
return _send_message(m, entity_inst_t(entity_name_t(type, -1),
addr.legacy_addr()));
}
int send_message(Message *m, Connection *con) {