diff options
Diffstat (limited to 'src/mon/Monitor.cc')
| -rw-r--r-- | src/mon/Monitor.cc | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mon/Monitor.cc b/src/mon/Monitor.cc index 360fcc55328..20733acba8d 100644 --- a/src/mon/Monitor.cc +++ b/src/mon/Monitor.cc @@ -499,13 +499,13 @@ void Monitor::handle_subscribe(MMonSubscribe *m) utime_t until = g_clock.now(); until += g_conf.mon_subscribe_interval; - for (map<nstring,version_t>::iterator p = m->what.begin(); + for (map<nstring,MMonSubscribe::sub_rec>::iterator p = m->what.begin(); p != m->what.end(); p++) { if (p->first == "osdmap") - osdmon()->subscribe(m->get_source_inst(), p->second, until); + osdmon()->subscribe(m->get_source_inst(), p->second.have, p->second.onetime ? utime_t() : until); else if (p->first == "mdsmap") - mdsmon()->subscribe(m->get_source_inst(), p->second, until); + mdsmon()->subscribe(m->get_source_inst(), p->second.have, p->second.onetime ? utime_t() : until); else dout(10) << " ignoring sub for '" << p->first << "'" << dendl; } |