_start_hunting();
if (rank >= 0) {
- _add_conn(rank, global_id);
+ _add_conn(rank);
} else {
- _add_conns(global_id);
+ _add_conns();
}
// throw out old queued messages
}
}
-void MonClient::_add_conn(unsigned rank, uint64_t global_id)
+void MonClient::_add_conn(unsigned rank)
{
auto peer = monmap.get_addrs(rank);
auto conn = messenger->connect_to_mon(peer);
<< dendl;
}
-void MonClient::_add_conns(uint64_t global_id)
+void MonClient::_add_conns()
{
// collect the next batch of candidates who are listed right next to the ones
// already tried
n = ranks.size();
}
for (unsigned i = 0; i < n; i++) {
- _add_conn(ranks[i], global_id);
+ _add_conn(ranks[i]);
tried.insert(ranks[i]);
}
}
void _finish_hunting(int auth_err);
void _finish_auth(int auth_err);
void _reopen_session(int rank = -1);
- void _add_conn(unsigned rank, uint64_t global_id);
+ void _add_conn(unsigned rank);
+ void _add_conns();
void _un_backoff();
- void _add_conns(uint64_t global_id);
void _send_mon_message(MessageRef m);
std::map<entity_addrvec_t, MonConnection>::iterator _find_pending_con(