From 49eeaeba3fc39b531d474375154c9cd3c2c373c6 Mon Sep 17 00:00:00 2001 From: Samuel Just Date: Mon, 22 Apr 2013 14:06:22 -0700 Subject: [PATCH] Messenger: add interface to get oldest queued message arrival time Signed-off-by: Samuel Just --- src/msg/Messenger.h | 8 ++++++++ src/msg/SimpleMessenger.h | 7 +++++++ 2 files changed, 15 insertions(+) diff --git a/src/msg/Messenger.h b/src/msg/Messenger.h index b08fdaa7f30..ca80dd1c5be 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 d837a4496ae..6be1a0a9539 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 */ /** -- 2.47.3