summaryrefslogtreecommitdiffstats
path: root/src/mon/MonmapMonitor.cc
diff options
context:
space:
mode:
authorJoao Eduardo Luis <joao@redhat.com>2015-02-25 19:40:33 +0100
committerJoao Eduardo Luis <joao@suse.de>2015-07-16 19:03:39 +0200
commit2526347515ff269b224b5c2937e5cfb4491b56a4 (patch)
treee3fb16f69d3f159c58c8872faf8f7257a4954fdb /src/mon/MonmapMonitor.cc
parentmon: optracker (1): support MonOpRequestRef (diff)
downloadceph-2526347515ff269b224b5c2937e5cfb4491b56a4.tar.xz
ceph-2526347515ff269b224b5c2937e5cfb4491b56a4.zip
mon: optracker (2): remove all unecessary message put()
Signed-off-by: Joao Eduardo Luis <joao@redhat.com>
Diffstat (limited to 'src/mon/MonmapMonitor.cc')
-rw-r--r--src/mon/MonmapMonitor.cc6
1 files changed, 0 insertions, 6 deletions
diff --git a/src/mon/MonmapMonitor.cc b/src/mon/MonmapMonitor.cc
index c204447361e..03d58745c8c 100644
--- a/src/mon/MonmapMonitor.cc
+++ b/src/mon/MonmapMonitor.cc
@@ -137,7 +137,6 @@ bool MonmapMonitor::preprocess_query(MonOpRequestRef op)
return preprocess_join(op);
default:
assert(0);
- m->put();
return true;
}
}
@@ -270,7 +269,6 @@ bool MonmapMonitor::prepare_update(MonOpRequestRef op)
return prepare_join(op);
default:
assert(0);
- m->put();
}
return false;
@@ -400,18 +398,15 @@ bool MonmapMonitor::preprocess_join(MonOpRequestRef op)
if (!session ||
!session->is_capable("mon", MON_CAP_W | MON_CAP_X)) {
dout(10) << " insufficient caps" << dendl;
- join->put();
return true;
}
if (pending_map.contains(join->name) && !pending_map.get_addr(join->name).is_blank_ip()) {
dout(10) << " already have " << join->name << dendl;
- join->put();
return true;
}
if (pending_map.contains(join->addr) && pending_map.get_name(join->addr) == join->name) {
dout(10) << " already have " << join->addr << dendl;
- join->put();
return true;
}
return false;
@@ -426,7 +421,6 @@ bool MonmapMonitor::prepare_join(MonOpRequestRef op)
pending_map.remove(pending_map.get_name(join->addr));
pending_map.add(join->name, join->addr);
pending_map.last_changed = ceph_clock_now(g_ceph_context);
- join->put();
return true;
}