From 25e8202f69969711cbd4d55a761169ae2b6d57a3 Mon Sep 17 00:00:00 2001
From: Sage Weil <sage@newdream.net>
Date: Thu, 3 Dec 2009 15:50:21 -0800
Subject: [PATCH] ceph: fix message leaks

---
 src/ceph.cc | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/ceph.cc b/src/ceph.cc
index cc476f9934127..6ac28fa54e316 100644
--- a/src/ceph.cc
+++ b/src/ceph.cc
@@ -96,6 +96,7 @@ void handle_observe(MMonObserve *observe)
   lock.Lock();
   registered.insert(observe->machine_id);  
   lock.Unlock();
+  delete observe;
 }
 
 void handle_notify(MMonObserveNotify *notify)
@@ -223,6 +224,8 @@ void handle_notify(MMonObserveNotify *notify)
   }
 
   map_ver[notify->machine_id] = notify->ver;
+
+  delete notify;
 }
 
 static void send_observe_requests();
@@ -299,7 +302,7 @@ void handle_ack(MMonCommandAck *ack)
     which++;
     which = which % LAST;
 
-    if(ack->version > last_seen_version)
+    if (ack->version > last_seen_version)
       last_seen_version = ack->version;
 
     string w = ack->cmd[0];
@@ -336,6 +339,7 @@ void handle_ack(MMonCommandAck *ack)
     }
     lock.Unlock();
   }
+  delete ack;
 }
 
 void send_command()
-- 
2.39.5