X-Git-Url: https://git.proxmox.com/?a=blobdiff_plain;f=ceph%2Fsrc%2Fmon%2FMonClient.cc;h=25c58b0b1cefcc92f9c11d723a0ba4a8761ea418;hb=f91f0fd59dc16d284d230f8953e42d49a893715d;hp=139c18eb1dbab540f7853a0b74047723655f9afa;hpb=91f1cf44a5d7f2447155ea575d309309fbbe6f73;p=ceph.git diff --git a/ceph/src/mon/MonClient.cc b/ceph/src/mon/MonClient.cc index 139c18eb1..25c58b0b1 100644 --- a/ceph/src/mon/MonClient.cc +++ b/ceph/src/mon/MonClient.cc @@ -420,6 +420,8 @@ void MonClient::handle_monmap(MMonMap *m) } } + cct->set_mon_addrs(monmap); + sub.got("monmap", monmap.get_epoch()); map_cond.notify_all(); want_monmap = false; @@ -1321,7 +1323,8 @@ void MonClient::start_mon_command(const std::vector& cmd, r->poutbl = outbl; r->prs = outs; r->onfinish = onfinish; - if (cct->_conf->rados_mon_op_timeout > 0) { + auto timeout = cct->_conf.get_val("rados_mon_op_timeout"); + if (timeout.count() > 0) { class C_CancelMonCommand : public Context { uint64_t tid; @@ -1333,7 +1336,7 @@ void MonClient::start_mon_command(const std::vector& cmd, } }; r->ontimeout = new C_CancelMonCommand(r->tid, this); - timer.add_event_after(cct->_conf->rados_mon_op_timeout, r->ontimeout); + timer.add_event_after(static_cast(timeout.count()), r->ontimeout); } mon_commands[r->tid] = r; _send_command(r);