From: Greg Farnum Date: Thu, 15 Apr 2010 20:08:51 +0000 (-0700) Subject: msgr: remove unnecessary clone variable from submit_message X-Git-Tag: v0.22~625^2~18 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=a9800e73357b68d090acdf6a9b7cf4539c5f4202;p=ceph.git msgr: remove unnecessary clone variable from submit_message --- diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc index 90de97e5358f..e432c6ee042c 100644 --- a/src/msg/SimpleMessenger.cc +++ b/src/msg/SimpleMessenger.cc @@ -2258,8 +2258,6 @@ void SimpleMessenger::submit_message(Message *m, const entity_inst_t& dest, bool assert(m->nref.test() == 1); //this is just to make sure that a changeset //is working properly; if you start using the refcounting more and have multiple //people hanging on to a message, ditch the assert! - // lookup - entity_addr_t dest_proc_addr = dest_addr; lock.Lock(); @@ -2279,9 +2277,9 @@ void SimpleMessenger::submit_message(Message *m, const entity_inst_t& dest, bool else { // remote. Pipe *pipe = 0; - if (rank_pipe.count( dest_proc_addr )) { + if (rank_pipe.count( dest_addr )) { // connected? - pipe = rank_pipe[ dest_proc_addr ]; + pipe = rank_pipe[ dest_addr ]; pipe->pipe_lock.Lock(); if (pipe->state == Pipe::STATE_CLOSED) { dout(20) << "submit_message " << *m << " remote, " << dest_addr << ", ignoring old closed pipe." << dendl; @@ -2302,7 +2300,7 @@ void SimpleMessenger::submit_message(Message *m, const entity_inst_t& dest, bool } else { dout(20) << "submit_message " << *m << " remote, " << dest_addr << ", new pipe." << dendl; // not connected. - pipe = connect_rank(dest_proc_addr, dest.name.type()); + pipe = connect_rank(dest_addr, dest.name.type()); pipe->send(m); } }