64 lines
2.0 KiB
Plaintext
64 lines
2.0 KiB
Plaintext
|
#include "DOtherSide/DOtherSideSingleInstance.h"
|
||
|
|
|
||
|
|
#include <QLocalServer>
|
||
|
|
#include <QLocalSocket>
|
||
|
|
|
||
|
|
namespace {
|
||
|
|
const int ReadWriteTimeoutMs = 1000;
|
||
|
|
}
|
||
|
|
|
||
|
|
SingleInstance::SingleInstance(const QString &uniqueName, const QString &eventStr, QObject *parent)
|
||
|
|
: QObject(parent)
|
||
|
|
, m_localServer(new QLocalServer(this))
|
||
|
|
{
|
||
|
|
QString socketName = uniqueName;
|
||
|
|
|
||
|
|
#ifndef Q_OS_WIN
|
||
|
|
socketName = QString("/tmp/%1").arg(socketName);
|
||
|
|
#endif
|
||
|
|
|
||
|
|
QLocalSocket localSocket;
|
||
|
|
localSocket.connectToServer(socketName);
|
||
|
|
|
||
|
|
// the first instance start will be delayed by this timeout (ms) to ensure there are no other instances.
|
||
|
|
// note: this is an ad-hoc timeout value selected based on prior experience.
|
||
|
|
if (!localSocket.waitForConnected(100)) {
|
||
|
|
connect(m_localServer, &QLocalServer::newConnection, this, &SingleInstance::handleNewConnection);
|
||
|
|
// on *nix a crashed process will leave /tmp/xyz file preventing to start a new server.
|
||
|
|
// therefore, if we were unable to connect, then we assume the server died and we need to clean up.
|
||
|
|
// p.s. on Windows, this function does nothing.
|
||
|
|
QLocalServer::removeServer(socketName);
|
||
|
|
if (!m_localServer->listen(socketName)) {
|
||
|
|
qWarning() << "QLocalServer::listen(" << socketName << ") failed";
|
||
|
|
}
|
||
|
|
} else if (!eventStr.isEmpty()) {
|
||
|
|
localSocket.write(eventStr.toUtf8() + '\n');
|
||
|
|
localSocket.waitForBytesWritten(ReadWriteTimeoutMs);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
SingleInstance::~SingleInstance()
|
||
|
|
{
|
||
|
|
if (m_localServer->isListening()) {
|
||
|
|
m_localServer->close();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
bool SingleInstance::isFirstInstance() const
|
||
|
|
{
|
||
|
|
return m_localServer->isListening();
|
||
|
|
}
|
||
|
|
|
||
|
|
void SingleInstance::handleNewConnection()
|
||
|
|
{
|
||
|
|
emit secondInstanceDetected();
|
||
|
|
|
||
|
|
auto socket = m_localServer->nextPendingConnection();
|
||
|
|
if (socket->waitForReadyRead(ReadWriteTimeoutMs) && socket->canReadLine()) {
|
||
|
|
auto event = socket->readLine();
|
||
|
|
emit eventReceived(QString::fromUtf8(event));
|
||
|
|
}
|
||
|
|
|
||
|
|
socket->deleteLater();
|
||
|
|
}
|