summaryrefslogtreecommitdiff
path: root/src/multiprocess.cpp
diff options
context:
space:
mode:
authorMikaël Capelle <capelle.mikael@gmail.com>2022-05-17 11:47:01 +0200
committerMikaël Capelle <capelle.mikael@gmail.com>2023-07-09 17:20:40 +0200
commitd13f6bb870cdda71257f665367be8ef9fca86255 (patch)
tree52e214718478f1e52856572f5aa1a2ac58537f9f /src/multiprocess.cpp
parent86bb01ba9eac879d3685c439ac9da0028bc4bc80 (diff)
Apply clang-format.
Diffstat (limited to 'src/multiprocess.cpp')
-rw-r--r--src/multiprocess.cpp34
1 files changed, 18 insertions, 16 deletions
diff --git a/src/multiprocess.cpp b/src/multiprocess.cpp
index 7da2468d..fb7f8d4d 100644
--- a/src/multiprocess.cpp
+++ b/src/multiprocess.cpp
@@ -1,16 +1,16 @@
#include "multiprocess.h"
#include "utility.h"
-#include <report.h>
-#include <log.h>
#include <QLocalSocket>
+#include <log.h>
+#include <report.h>
-static const char s_Key[] = "mo-43d1a3ad-eeb0-4818-97c9-eda5216c29b5";
+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)
+MOMultiProcess::MOMultiProcess(bool allowMultiple, QObject* parent)
+ : QObject(parent), m_Ephemeral(false), m_OwnsSM(false)
{
m_SharedMem.setKey(s_Key);
@@ -31,15 +31,15 @@ MOMultiProcess::MOMultiProcess(bool allowMultiple, QObject *parent) :
}
if (m_OwnsSM) {
- connect(&m_Server, SIGNAL(newConnection()), this, SLOT(receiveMessage()), Qt::QueuedConnection);
+ 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)
+void MOMultiProcess::sendMessage(const QString& message)
{
if (m_OwnsSM) {
// nobody there to receive the message
@@ -48,7 +48,7 @@ void MOMultiProcess::sendMessage(const QString &message)
QLocalSocket socket(this);
bool connected = false;
- for(int i = 0; i < 2 && !connected; ++i) {
+ for (int i = 0; i < 2 && !connected; ++i) {
if (i > 0) {
Sleep(250);
}
@@ -59,13 +59,15 @@ void MOMultiProcess::sendMessage(const QString &message)
}
if (!connected) {
- reportError(tr("failed to connect to running process: %1").arg(socket.errorString()));
+ reportError(
+ tr("failed to connect to running process: %1").arg(socket.errorString()));
return;
}
socket.write(message.toUtf8());
if (!socket.waitForBytesWritten(s_Timeout)) {
- reportError(tr("failed to communicate with running process: %1").arg(socket.errorString()));
+ reportError(
+ tr("failed to communicate with running process: %1").arg(socket.errorString()));
return;
}
@@ -75,7 +77,7 @@ void MOMultiProcess::sendMessage(const QString &message)
void MOMultiProcess::receiveMessage()
{
- QLocalSocket *socket = m_Server.nextPendingConnection();
+ QLocalSocket* socket = m_Server.nextPendingConnection();
if (!socket) {
return;
}
@@ -87,11 +89,11 @@ void MOMultiProcess::receiveMessage()
const auto av = socket->bytesAvailable();
if (av <= 0) {
- MOBase::log::error(
- "failed to receive data from secondary process: {}",
- socket->errorString());
+ 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()));
+ reportError(tr("failed to receive data from secondary process: %1")
+ .arg(socket->errorString()));
return;
}
}