From 8654fb2db74eacff8ec943d192f80ef1fd512f6e Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 4 Jun 2008 17:24:10 +0000 Subject: Request a timely reqply to session.completed based on configured flush interval. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@663318 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/SessionState.h | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'cpp/src/qpid/SessionState.h') diff --git a/cpp/src/qpid/SessionState.h b/cpp/src/qpid/SessionState.h index 80d218b8bb..10937b7a1e 100644 --- a/cpp/src/qpid/SessionState.h +++ b/cpp/src/qpid/SessionState.h @@ -148,6 +148,11 @@ class SessionState { /** Peer has indicated commands are known completed */ virtual void receiverKnownCompleted(const SequenceSet& commands); + /** True if the next completed control should set the timely-reply argument + * to request a knonw-completed response. + */ + virtual bool receiverNeedKnownCompleted() const; + /** Get the incoming command point */ virtual const SessionPoint& receiverGetExpected() const; @@ -184,6 +189,7 @@ class SessionState { SessionPoint received; // Received to here. Invariant: expected <= received. SequenceSet unknownCompleted; // Received & completed, may not not known-complete by peer. SequenceSet incomplete; // Incomplete received commands. + size_t bytesSinceKnownCompleted; // Bytes sent since we last issued a knownCompleted. } receiver; SessionId id; -- cgit v1.2.1