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 b08fdaa7f300143faed0a3f3f2a7a9f54c6009be..ca80dd1c5be3e4984e057976e9547cdee95b05f3 100644 (file)
--- 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 d837a4496ae3fafc426dd6a3424cf325c360be79..6be1a0a95392cb5ea1325ca686dc2dcb8e86952f 100644 (file)
--- 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 */
 
   /**