diff options
Diffstat (limited to 'qpid/cpp/src/qpid/cluster/WriteEstimate.h')
-rw-r--r-- | qpid/cpp/src/qpid/cluster/WriteEstimate.h | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/qpid/cpp/src/qpid/cluster/WriteEstimate.h b/qpid/cpp/src/qpid/cluster/WriteEstimate.h index 01ab2a3e34..97b1435fcc 100644 --- a/qpid/cpp/src/qpid/cluster/WriteEstimate.h +++ b/qpid/cpp/src/qpid/cluster/WriteEstimate.h @@ -51,12 +51,17 @@ class WriteEstimate * doOutput request just delivered, not yet executed. Update the estimate. * and estimate how much data to request in the next onOutput * request. 0 means don't send an onOutput request. + * + * @param delivered value in doOutput control. */ - void delivered(size_t sent, size_t buffered); + void delivered(size_t delivered, size_t sent, size_t buffered); + + /** Last estimate delivered, i.e. known to cluster */ + size_t getLastEstimate() const { return estimate; } private: bool growing; - size_t estimate; + size_t estimate, lastEstimate; }; }} // namespace qpid::cluster |