Immediately start reading if there is data available

2 files changed, 10 insertions, 2 deletions

diff --git a/synchronizer/listener.cpp b/synchronizer/listener.cpp
index 36fa6ea..d9ee46d 100644
--- a/synchronizer/listener.cpp
+++ b/synchronizer/listener.cpp
@@ -124,6 +124,9 @@ void Listener::acceptConnection()
             this, &Listener::clientDropped);
     m_checkConnectionsTimer->stop();
 
+    if (socket->bytesAvailable()) {
+        readFromSocket(socket);
+    }
 }
 
 void Listener::clientDropped()
@@ -156,13 +159,17 @@ void Listener::checkConnections()
     m_checkConnectionsTimer->start();
 }
 
-void Listener::readFromSocket()
+void Listener::onDataAvailable()
 {
     QLocalSocket *socket = qobject_cast<QLocalSocket *>(sender());
     if (!socket) {
         return;
     }
+    readFromSocket(socket);
+}
 
+void Listener::readFromSocket(QLocalSocket *socket)
+{
     Trace() << "Reading from socket...";
     for (Client &client: m_connections) {
         if (client.socket == socket) {
diff --git a/synchronizer/listener.h b/synchronizer/listener.h
index 2577673..e03c310 100644
--- a/synchronizer/listener.h
+++ b/synchronizer/listener.h
@@ -73,7 +73,7 @@ private Q_SLOTS:
     void acceptConnection();
     void clientDropped();
     void checkConnections();
-    void readFromSocket();
+    void onDataAvailable();
     void processClientBuffers();
     void refreshRevision();
     void quit();
@@ -85,6 +85,7 @@ private:
     void sendCommandCompleted(QLocalSocket *socket, uint messageId);
     void updateClientsWithRevision();
     void loadResource();
+    void readFromSocket(QLocalSocket *socket);
 
     QLocalServer *m_server;
     QVector<Client> m_connections;