diff options
Diffstat (limited to 'cpp/src/qpid/cluster/OutputInterceptor.h')
| -rw-r--r-- | cpp/src/qpid/cluster/OutputInterceptor.h | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/cpp/src/qpid/cluster/OutputInterceptor.h b/cpp/src/qpid/cluster/OutputInterceptor.h index ea603dbe06..7d6c718b82 100644 --- a/cpp/src/qpid/cluster/OutputInterceptor.h +++ b/cpp/src/qpid/cluster/OutputInterceptor.h @@ -49,28 +49,28 @@ class OutputInterceptor : public sys::ConnectionOutputHandler { size_t getBuffered() const; // Delivery point for doOutput requests. - void deliverDoOutput(size_t requested); + void deliverDoOutput(uint32_t limit); // Intercept doOutput requests on Connection. bool doOutput(); void closeOutput(); + uint32_t getSendMax() const { return sendMax; } + void setSendMax(uint32_t sendMax_) { sendMax=sendMax_; } + cluster::Connection& parent; private: typedef sys::Mutex::ScopedLock Locker; - void sendDoOutput(size_t); + void sendDoOutput(size_t newLimit); mutable sys::Mutex lock; bool closing; sys::ConnectionOutputHandler* next; - size_t sent; - size_t estimate; - size_t minimum; - bool moreOutput; - bool doingOutput; static NoOpConnectionOutputHandler discardHandler; + uint32_t sendMax, sent; + bool sentDoOutput; }; }} // namespace qpid::cluster |
