return monmap.fsid;
}
- entity_addr_t get_mon_addr(unsigned i) const {
+ entity_addrvec_t get_mon_addrs(unsigned i) const {
Mutex::Locker l(monc_lock);
if (i < monmap.size())
- return monmap.get_addr(i);
- return entity_addr_t();
- }
- entity_inst_t get_mon_inst(unsigned i) const {
- Mutex::Locker l(monc_lock);
- if (i < monmap.size())
- return monmap.get_inst(i);
- return entity_inst_t();
+ return monmap.get_addrs(i);
+ return entity_addrvec_t();
}
int get_num_mon() const {
Mutex::Locker l(monc_lock);
if (rand() % 10 == 0) {
//cerr << "mark_down " << t << std::endl;
dout(0) << "mark_down " << t << dendl;
- messenger->mark_down(mc.get_mon_addr(t));
+ messenger->mark_down_addrs(mc.get_mon_addrs(t));
}
//cerr << "pinging " << t << std::endl;
dout(0) << "pinging " << t << dendl;
- messenger->send_message(new MPing, mc.get_mon_inst(t));
+ messenger->send_to_mon(new MPing, mc.get_mon_addrs(t));
cerr << isend << "\t" << ++sent << "\t" << received << "\r";
}
test_lock.Unlock();