1 files changed, 150 insertions, 0 deletions
diff --git a/src/libs/codemodelbackendipc/connectionserver.cpp b/src/libs/codemodelbackendipc/connectionserver.cpp
new file mode 100644
index 0000000000..fc59286439
--- /dev/null
+++ b/src/libs/codemodelbackendipc/connectionserver.cpp
@@ -0,0 +1,150 @@
+/****************************************************************************
+**
+** Copyright (C) 2015 The Qt Company Ltd.
+** Contact: http://www.qt.io/licensing
+**
+** This file is part of Qt Creator.
+**
+** Commercial License Usage
+** Licensees holding valid commercial Qt licenses may use this file in
+** accordance with the commercial license agreement provided with the
+** Software or, alternatively, in accordance with the terms contained in
+** a written agreement between you and Digia.  For licensing terms and
+** conditions see http://www.qt.io/licensing.  For further information
+** use the contact form at http://www.qt.io/contact-us.
+**
+** GNU Lesser General Public License Usage
+** Alternatively, this file may be used under the terms of the GNU Lesser
+** General Public License version 2.1 or version 3 as published by the Free
+** Software Foundation and appearing in the file LICENSE.LGPLv21 and
+** LICENSE.LGPLv3 included in the packaging of this file.  Please review the
+** following information to ensure the GNU Lesser General Public License
+** requirements will be met: https://www.gnu.org/licenses/lgpl.html and
+** http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.
+**
+** In addition, as a special exception, Digia gives you certain additional
+** rights.  These rights are described in the Digia Qt LGPL Exception
+** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.
+**
+****************************************************************************/
+
+#include "connectionserver.h"
+
+#include <QLocalSocket>
+#include <QCoreApplication>
+#include <QTimer>
+
+#include <ipcserverinterface.h>
+
+#include <cstdlib>
+
+namespace CodeModelBackEnd {
+
+QString ConnectionServer::connectionName;
+
+ConnectionServer::ConnectionServer(const QString &connectionName)
+    : aliveTimerId(startTimer(5000))
+{
+    this->connectionName = connectionName;
+
+    connect(&localServer, &QLocalServer::newConnection, this, &ConnectionServer::handleNewConnection);
+    std::atexit(&ConnectionServer::removeServer);
+#if defined(Q_OS_LINUX)
+    std::at_quick_exit(&ConnectionServer::removeServer);
+#endif
+    std::set_terminate(&ConnectionServer::removeServer);
+}
+
+ConnectionServer::~ConnectionServer()
+{
+    removeServer();
+}
+
+void ConnectionServer::start()
+{
+    QLocalServer::removeServer(connectionName);
+    localServer.listen(connectionName);
+}
+
+void ConnectionServer::setIpcServer(IpcServerInterface *ipcServer)
+{
+    this->ipcServer = ipcServer;
+
+}
+
+int ConnectionServer::clientProxyCount() const
+{
+    return ipcClientProxies.size();
+}
+
+void ConnectionServer::timerEvent(QTimerEvent *timerEvent)
+{
+    if (aliveTimerId == timerEvent->timerId())
+        sendAliveCommand();
+}
+
+void ConnectionServer::handleNewConnection()
+{
+    QLocalSocket *localSocket(nextPendingConnection());
+
+    ipcClientProxies.emplace_back(ipcServer, localSocket);
+
+    ipcServer->addClient(&ipcClientProxies.back());
+
+    localSockets.push_back(localSocket);
+
+    emit newConnection();
+}
+
+void ConnectionServer::sendAliveCommand()
+{
+    ipcServer->client()->alive();
+}
+
+void ConnectionServer::handleSocketDisconnect()
+{
+    QLocalSocket *senderLocalSocket = static_cast<QLocalSocket*>(sender());
+
+    removeClientProxyWithLocalSocket(senderLocalSocket);
+    localSockets.erase(std::remove_if(localSockets.begin(),
+                                      localSockets.end(),
+                                      [senderLocalSocket](QLocalSocket *localSocketInList) { return localSocketInList == senderLocalSocket;}));
+
+    delayedExitApplicationIfNoSockedIsConnected();
+}
+
+void ConnectionServer::removeClientProxyWithLocalSocket(QLocalSocket *localSocket)
+{
+    ipcClientProxies.erase(std::remove_if(ipcClientProxies.begin(),
+                                          ipcClientProxies.end(),
+                                          [localSocket](const IpcClientProxy &client) { return client.isUsingThatIoDevice(localSocket);}));
+}
+
+QLocalSocket *ConnectionServer::nextPendingConnection()
+{
+    QLocalSocket *localSocket = localServer.nextPendingConnection();
+
+    connect(localSocket, &QLocalSocket::disconnected, this, &ConnectionServer::handleSocketDisconnect);
+
+    return localSocket;
+}
+
+void ConnectionServer::removeServer()
+{
+    QLocalServer::removeServer(connectionName);
+}
+
+void ConnectionServer::delayedExitApplicationIfNoSockedIsConnected()
+{
+    if (localSockets.size() == 0)
+        QTimer::singleShot(60000, this, &ConnectionServer::exitApplicationIfNoSockedIsConnected);
+}
+
+void ConnectionServer::exitApplicationIfNoSockedIsConnected()
+{
+    if (localSockets.size() == 0)
+        QCoreApplication::exit();
+}
+
+} // namespace CodeModelBackEnd
+