Skip to content

Commit 899f7e5

Browse files
committed
QLockFile migration
1 parent d53cb39 commit 899f7e5

File tree

6 files changed

+6
-757
lines changed

6 files changed

+6
-757
lines changed

src/app/qtlocalpeer/qtlocalpeer.cpp

Lines changed: 3 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -80,45 +80,24 @@
8080
#include <QLocalServer>
8181
#include <QLocalSocket>
8282

83-
namespace QtLP_Private
84-
{
85-
#include "qtlockedfile.cpp"
86-
87-
#if defined(Q_OS_WIN)
88-
#include "qtlockedfile_win.cpp"
89-
#else
90-
#include "qtlockedfile_unix.cpp"
91-
#endif
92-
}
93-
9483
const QByteArray ACK = QByteArrayLiteral("ack");
9584

9685
QtLocalPeer::QtLocalPeer(const QString &path, QObject *parent)
9786
: QObject(parent)
9887
, m_socketName(path + u"/ipc-socket")
9988
, m_server(new QLocalServer(this))
89+
, m_lockFile(path + u"/lockfile")
10090
{
10191
m_server->setSocketOptions(QLocalServer::UserAccessOption);
102-
103-
m_lockFile.setFileName(path + u"/lockfile");
104-
m_lockFile.open(QIODevice::ReadWrite);
105-
}
106-
107-
QtLocalPeer::~QtLocalPeer()
108-
{
109-
if (!isClient())
110-
{
111-
m_lockFile.unlock();
112-
m_lockFile.remove();
113-
}
92+
m_lockFile.setStaleLockTime(0);
11493
}
11594

11695
bool QtLocalPeer::isClient()
11796
{
11897
if (m_lockFile.isLocked())
11998
return false;
12099

121-
if (!m_lockFile.lock(QtLP_Private::QtLockedFile::WriteLock, false))
100+
if (!m_lockFile.tryLock())
122101
return true;
123102

124103
bool res = m_server->listen(m_socketName);

src/app/qtlocalpeer/qtlocalpeer.h

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -68,10 +68,10 @@
6868

6969
#pragma once
7070

71+
#include <QLockFile>
72+
#include <QObject>
7173
#include <QString>
7274

73-
#include "qtlockedfile.h"
74-
7575
class QLocalServer;
7676

7777
class QtLocalPeer final : public QObject
@@ -81,7 +81,6 @@ class QtLocalPeer final : public QObject
8181

8282
public:
8383
QtLocalPeer(const QString &path, QObject *parent = nullptr);
84-
~QtLocalPeer() override;
8584

8685
bool isClient();
8786
bool sendMessage(const QString &message, int timeout);
@@ -95,5 +94,5 @@ private slots:
9594
private:
9695
QString m_socketName;
9796
QLocalServer *m_server = nullptr;
98-
QtLP_Private::QtLockedFile m_lockFile;
97+
QLockFile m_lockFile;
9998
};

src/app/qtlocalpeer/qtlockedfile.cpp

Lines changed: 0 additions & 209 deletions
This file was deleted.

0 commit comments

Comments
 (0)