Draft of ChangeReplay

1 files changed, 15 insertions, 0 deletions

diff --git a/common/listener.cpp b/common/listener.cpp
index 16da770..6e6808a 100644
--- a/common/listener.cpp
+++ b/common/listener.cpp
@@ -114,6 +114,14 @@ void Listener::acceptConnection()
             this, &Listener::clientDropped);
     m_checkConnectionsTimer->stop();
 
+    //If this is the first client, set the lower limit for revision cleanup
+    if (m_connections.size() == 1) {
+        loadResource();
+        if (m_resource) {
+            m_resource->setLowerBoundRevision(0);
+        }
+    }
+
     if (socket->bytesAvailable()) {
         readFromSocket(socket);
     }
@@ -146,6 +154,13 @@ void Listener::clientDropped()
 
 void Listener::checkConnections()
 {
+    //If this was the last client, disengage the lower limit for revision cleanup
+    if (m_connections.isEmpty()) {
+        loadResource();
+        if (m_resource) {
+            m_resource->setLowerBoundRevision(std::numeric_limits<qint64>::max());
+        }
+    }
     m_checkConnectionsTimer->start();
 }