Minor refactoring of execution layer

Set sync bit when session is in sync mode



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@580380 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 7 insertions, 3 deletions

diff --git a/cpp/src/qpid/client/ExecutionHandler.h b/cpp/src/qpid/client/ExecutionHandler.h
index 5f9cdff9d2..a3a3cde390 100644
--- a/cpp/src/qpid/client/ExecutionHandler.h
+++ b/cpp/src/qpid/client/ExecutionHandler.h
@@ -41,15 +41,16 @@ class ExecutionHandler :
     public ChainableFrameHandler,
     public Execution
 {
-    framing::Window incoming;
-    framing::Window outgoing;
+    framing::SequenceNumber incomingCounter;
+    framing::AccumulatedAck incomingCompletionStatus;
+    framing::SequenceNumber outgoingCounter;
+    framing::AccumulatedAck outgoingCompletionStatus;
     framing::FrameSet::shared_ptr arriving;
     Correlator correlation;
     CompletionTracker completion;
     Demux demux;
     framing::ProtocolVersion version;
     uint64_t maxFrameSize;
-    framing::AccumulatedAck completionStatus;
 
     void complete(uint32_t mark, const framing::SequenceNumberSet& range);    
     void flush();
@@ -77,6 +78,9 @@ public:
     void syncTo(const framing::SequenceNumber& point);
     void flushTo(const framing::SequenceNumber& point);
 
+    bool isComplete(const framing::SequenceNumber& id);
+    bool isCompleteUpTo(const framing::SequenceNumber& id);
+
     void setMaxFrameSize(uint64_t size) { maxFrameSize = size; }
     Correlator& getCorrelator() { return correlation; }
     CompletionTracker& getCompletionTracker() { return completion; }