Select Git revision
instancemanager.cpp
Code owners
Assign users and groups as approvers for specific file changes. Learn more.
instancemanager.cpp 6.66 KiB
/*
* Copyright (C) 2019-2024 Savoir-faire Linux Inc.
* Author: Andreas Traczyk <andreas.traczyk@savoirfairelinux.com>
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include "instancemanager.h"
#include "mainapplication.h"
#include <QCryptographicHash>
#include <QLocalSocket>
#include <QLocalServer>
#include <QSharedMemory>
#include <QSystemSemaphore>
static QString
generateKeyHash(const QString& key, const QString& salt)
{
QByteArray data;
data.append(key.toUtf8());
data.append(salt.toUtf8());
data = QCryptographicHash::hash(data, QCryptographicHash::Sha1).toHex();
return data;
}
class InstanceManager::Impl : public QObject
{
Q_OBJECT
Q_DISABLE_COPY(Impl)
public:
Impl(const QString& key, MainApplication* mainApp)
: QObject(nullptr)
, mainAppInstance_(mainApp)
, key_(key)
, memLockKey_(generateKeyHash(key, "_memLockKey"))
, sharedmemKey_(generateKeyHash(key, "_sharedmemKey"))
, sharedMem_(sharedmemKey_)
, memLock_(memLockKey_, 1)
{}
~Impl() = default;
bool tryToRun(const QByteArray& startUri)
{
if (isAnotherRunning()) {
// This is a secondary instance, connect to the primary
// instance to trigger a restore then die.
if (connectToLocal()) {
// Okay we connected. Send the start uri if not empty.
if (startUri.size()) {
qDebug() << "Sending start URI to secondary instance." << startUri;
socket_->write(startUri);
socket_->waitForBytesWritten();
}
// Now this instance can die.
return false;
}