From: Samuel Just <sam.just@inktank.com>
Date: Mon, 22 Apr 2013 21:06:22 +0000 (-0700)
Subject: Messenger: add interface to get oldest queued message arrival time
X-Git-Tag: v0.61~111^2~1
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=49eeaeba3fc39b531d474375154c9cd3c2c373c6;p=ceph.git

Messenger: add interface to get oldest queued message arrival time

Signed-off-by: Samuel Just <sam.just@inktank.com>
---

diff --git a/src/msg/Messenger.h b/src/msg/Messenger.h
index b08fdaa7f300..ca80dd1c5be3 100644
--- a/src/msg/Messenger.h
+++ b/src/msg/Messenger.h
@@ -207,6 +207,13 @@ public:
    * but not yet dispatched.
    */
   virtual int get_dispatch_queue_len() = 0;
+
+  /**
+   * Get age of oldest undelivered message
+   * (0 if the queue is empty)
+   */
+  virtual double get_dispatch_queue_max_age(utime_t now) = 0;
+
   /**
    * @} // Accessors
    */
@@ -660,6 +667,7 @@ public:
     }
     return false;
   }
+
   /**
    * @} // Dispatcher Interfacing
    */
diff --git a/src/msg/SimpleMessenger.h b/src/msg/SimpleMessenger.h
index d837a4496ae3..6be1a0a95392 100644
--- a/src/msg/SimpleMessenger.h
+++ b/src/msg/SimpleMessenger.h
@@ -110,6 +110,13 @@ public:
   int get_dispatch_queue_len() {
     return dispatch_queue.get_queue_len();
   }
+  /**
+   * Get age of oldest undelivered message
+   * (0 if the queue is empty)
+   */
+  double get_dispatch_queue_max_age(utime_t now) {
+    return dispatch_queue.get_max_age(now);
+  }
   /** @} Accessors */
 
   /**