1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
/*******************************************************************************
**
** smolbote: yet another qute browser
** Copyright (C) 2017 Xian Nox
**
** 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 "singleapplication.h"
#include <QLocalServer>
#include <QLocalSocket>
#include <QDataStream>
SingleApplication::SingleApplication(int &argc, char **argv) : QApplication(argc, argv)
{
}
SingleApplication::~SingleApplication()
{
if(m_localServer->isListening()) {
m_localServer->close();
QLocalServer::removeServer(LOCALSERVER_KEY);
}
}
void SingleApplication::bindLocalSocket()
{
m_localServer = new QLocalServer(this);
connect(m_localServer, &QLocalServer::newConnection, this, &SingleApplication::slot_receiveMessage);
// check for running local server by connecting to it
QLocalSocket socket;
socket.connectToServer(LOCALSERVER_KEY);
if(socket.waitForConnected(LOCALSERVER_TIMEOUT)) {
// there is another server
qWarning("Another server is running");
socket.close();
return;
} else {
// no other server
QLocalServer::removeServer(LOCALSERVER_KEY);
if(!m_localServer->listen(LOCALSERVER_KEY)) {
qWarning("Cannot bind local server [%s]", qUtf8Printable(LOCALSERVER_KEY));
}
}
}
bool SingleApplication::isRunning()
{
return !m_localServer->isListening();
}
bool SingleApplication::sendMessage(const QHash<QString, QVariant> ¶ms)
{
QLocalSocket socket;
socket.connectToServer(LOCALSERVER_KEY);
if(socket.waitForConnected(LOCALSERVER_TIMEOUT)) {
QByteArray argumentData;
QDataStream ds(&argumentData, QIODevice::WriteOnly);
ds << params;
socket.write(argumentData);
socket.waitForBytesWritten(LOCALSERVER_TIMEOUT);
return true;
}
return false;
}
void SingleApplication::slot_receiveMessage()
{
QLocalSocket *socket = m_localServer->nextPendingConnection();
if(!socket) {
// null socket --> return
return;
}
socket->waitForReadyRead();
QByteArray argumentData = socket->readAll();
// skip if we got no data
if(argumentData.isEmpty()) {
return;
}
QHash<QString, QVariant> params;
QDataStream ds(argumentData);
ds >> params;
socket->deleteLater();
emit messageAvailable(params);
}
|
