blob: 2851b9e7fa0d15470f86bee46a7b14189c034e71 (
plain)
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
|
#include "multiprocess.h"
#include "utility.h"
#include <QLocalSocket>
#include <log.h>
#include <report.h>
static const char s_Key[] = "mo-43d1a3ad-eeb0-4818-97c9-eda5216c29b5";
static const int s_Timeout = 5000;
using MOBase::reportError;
MOMultiProcess::MOMultiProcess(bool allowMultiple, QObject* parent)
: QObject(parent), m_Ephemeral(false), m_OwnsSM(false)
{
m_SharedMem.setKey(s_Key);
if (!m_SharedMem.create(1)) {
if (m_SharedMem.error() == QSharedMemory::AlreadyExists) {
if (!allowMultiple) {
m_SharedMem.attach();
m_Ephemeral = true;
}
}
if ((m_SharedMem.error() != QSharedMemory::NoError) &&
(m_SharedMem.error() != QSharedMemory::AlreadyExists)) {
throw MOBase::MyException(tr("SHM error: %1").arg(m_SharedMem.errorString()));
}
} else {
m_OwnsSM = true;
}
if (m_OwnsSM) {
connect(&m_Server, SIGNAL(newConnection()), this, SLOT(receiveMessage()),
Qt::QueuedConnection);
// has to be called before listen
m_Server.setSocketOptions(QLocalServer::WorldAccessOption);
m_Server.listen(s_Key);
}
}
void MOMultiProcess::sendMessage(const QString& message)
{
if (m_OwnsSM) {
// nobody there to receive the message
return;
}
QLocalSocket socket(this);
bool connected = false;
for (int i = 0; i < 2 && !connected; ++i) {
if (i > 0) {
Sleep(250);
}
// other process may be just starting up
socket.connectToServer(s_Key, QIODevice::WriteOnly);
connected = socket.waitForConnected(s_Timeout);
}
if (!connected) {
reportError(
tr("failed to connect to running process: %1").arg(socket.errorString()));
return;
}
socket.write(message.toUtf8());
if (!socket.waitForBytesWritten(s_Timeout)) {
if (socket.bytesToWrite()) {
reportError(tr("failed to communicate with running process: %1")
.arg(socket.errorString()));
}
}
socket.disconnectFromServer();
socket.waitForDisconnected();
}
void MOMultiProcess::receiveMessage()
{
QLocalSocket* socket = m_Server.nextPendingConnection();
if (!socket) {
return;
}
if (!socket->waitForReadyRead(s_Timeout)) {
// check if there are bytes available; if so, it probably means the data was
// already received by the time waitForReadyRead() was called and the
// connection has been closed
const auto av = socket->bytesAvailable();
if (av <= 0) {
MOBase::log::error("failed to receive data from secondary process: {}",
socket->errorString());
reportError(tr("failed to receive data from secondary process: %1")
.arg(socket->errorString()));
return;
}
}
QString message = QString::fromUtf8(socket->readAll().constData());
emit messageSent(message);
socket->disconnectFromServer();
}
|
