diff options
Diffstat (limited to 'cpp/src/qpid/SessionState.h')
| -rw-r--r-- | cpp/src/qpid/SessionState.h | 6 |
1 files changed, 6 insertions, 0 deletions
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; |
