summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/OutputInterceptor.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/cluster/OutputInterceptor.h')
-rw-r--r--cpp/src/qpid/cluster/OutputInterceptor.h14
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