Skip to content

Commit

Permalink
Merge branch 'develop'
Browse files Browse the repository at this point in the history
  • Loading branch information
setvisible committed Sep 23, 2019
2 parents 42fbc4e + 4ceae98 commit 398931d
Show file tree
Hide file tree
Showing 31 changed files with 1,875 additions and 57 deletions.
1 change: 1 addition & 0 deletions 3rd/3rd.pri
Original file line number Diff line number Diff line change
@@ -1 +1,2 @@
include($$PWD/google-gumbo-parser/google-gumbo-parser.pri)
include($$PWD/qtsingleapplication/qtsingleapplication.pri)
6 changes: 1 addition & 5 deletions 3rd/CMakeLists.txt
Original file line number Diff line number Diff line change
@@ -1,6 +1,2 @@
include(${CMAKE_CURRENT_SOURCE_DIR}/3rd/google-gumbo-parser/CMakeLists.txt)


add_library(gumbo_static_lib STATIC
${GUMBO_SOURCES}
)
include(${CMAKE_CURRENT_SOURCE_DIR}/3rd/qtsingleapplication/CMakeLists.txt)
4 changes: 4 additions & 0 deletions 3rd/google-gumbo-parser/CMakeLists.txt
Original file line number Diff line number Diff line change
Expand Up @@ -34,3 +34,7 @@ set(GUMBO_HEADERS
${CMAKE_CURRENT_SOURCE_DIR}/3rd/google-gumbo-parser/0.10.1/src/util.h
${CMAKE_CURRENT_SOURCE_DIR}/3rd/google-gumbo-parser/0.10.1/src/vector.h
)

add_library(gumbo_static_lib STATIC
${GUMBO_SOURCES}
)
11 changes: 11 additions & 0 deletions 3rd/qtsingleapplication/CMakeLists.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
include_directories(${CMAKE_CURRENT_SOURCE_DIR}/3rd/qtsingleapplication/include/)

set(QTSINGLEAPPLICATION_SOURCES
${CMAKE_CURRENT_SOURCE_DIR}/3rd/qtsingleapplication/src/qtlocalpeer.cpp
${CMAKE_CURRENT_SOURCE_DIR}/3rd/qtsingleapplication/src/qtsingleapplication.cpp
)

set(QTSINGLEAPPLICATION_HEADERS
${CMAKE_CURRENT_SOURCE_DIR}/3rd/qtsingleapplication/src/qtlocalpeer.h
${CMAKE_CURRENT_SOURCE_DIR}/3rd/qtsingleapplication/src/qtsingleapplication.h
)
33 changes: 33 additions & 0 deletions 3rd/qtsingleapplication/README.TXT
Original file line number Diff line number Diff line change
@@ -0,0 +1,33 @@
Qt Solutions Component: Single Application

The QtSingleApplication component provides support for
applications that can be only started once per user.



Version history:

2.0: - Version 1.3 ported to Qt 4.

2.1: - Fix compilation problem on Mac.

2.2: - Really fix the Mac compilation problem.
- Mac: fix crash due to wrong object releasing.
- Mac: Fix memory leak.

2.3: - Windows: Force creation of internal widget to make it work
with Qt 4.2.

2.4: - Fix the system for automatic window raising on message
reception. NOTE: minor API change.

2.5: - Mac: Fix isRunning() to work and report correctly.

2.6: - - initialize() is now obsolete, no longer necessary to call
it
- - Fixed race condition where multiple instances migth be started
- - QtSingleCoreApplication variant provided for non-GUI (console)
usage
- Complete reimplementation. Visible changes:
- LGPL release.

1 change: 1 addition & 0 deletions 3rd/qtsingleapplication/include/QtLockedFile
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
#include "../src/qtlockedfile.h"
1 change: 1 addition & 0 deletions 3rd/qtsingleapplication/include/QtSingleApplication
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
#include "../src/qtsingleapplication.h"
17 changes: 17 additions & 0 deletions 3rd/qtsingleapplication/qtsingleapplication.pri
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
# Qt Solutions Component: Single Application
#
# The QtSingleApplication component provides support for
# applications that can be only started once per user.
#
# https://github.com/qtproject/qt-solutions
#

INCLUDEPATH += $$PWD/include

HEADERS += \
$$PWD/src/qtlocalpeer.h \
$$PWD/src/qtsingleapplication.h

SOURCES += \
$$PWD/src/qtlocalpeer.cpp \
$$PWD/src/qtsingleapplication.cpp
213 changes: 213 additions & 0 deletions 3rd/qtsingleapplication/src/qtlocalpeer.cpp
Original file line number Diff line number Diff line change
@@ -0,0 +1,213 @@
/****************************************************************************
**
** Copyright (C) 2013 Digia Plc and/or its subsidiary(-ies).
** Contact: http://www.qt-project.org/legal
**
** This file is part of the Qt Solutions component.
**
** $QT_BEGIN_LICENSE:BSD$
** You may use this file under the terms of the BSD license as follows:
**
** "Redistribution and use in source and binary forms, with or without
** modification, are permitted provided that the following conditions are
** met:
** * Redistributions of source code must retain the above copyright
** notice, this list of conditions and the following disclaimer.
** * Redistributions in binary form must reproduce the above copyright
** notice, this list of conditions and the following disclaimer in
** the documentation and/or other materials provided with the
** distribution.
** * Neither the name of Digia Plc and its Subsidiary(-ies) nor the names
** of its contributors may be used to endorse or promote products derived
** from this software without specific prior written permission.
**
**
** THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
** "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
** LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
** A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
** OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
** SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
** LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
** DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
** THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
** (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
** OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE."
**
** $QT_END_LICENSE$
**
****************************************************************************/


#include "qtlocalpeer.h"
#include <QCoreApplication>
#include <QDataStream>
#include <QTime>

#if defined(Q_OS_WIN)
#include <QLibrary>
#include <qt_windows.h>
typedef BOOL(WINAPI*PProcessIdToSessionId)(DWORD,DWORD*);
static PProcessIdToSessionId pProcessIdToSessionId = 0;
#endif
#if defined(Q_OS_UNIX)
#include <sys/types.h>
#include <time.h>
#include <unistd.h>
#endif

namespace QtLP_Private {
#include "qtlockedfile.cpp"
#if defined(Q_OS_WIN)
#include "qtlockedfile_win.cpp"
#else
#include "qtlockedfile_unix.cpp"
#endif
}

const char* QtLocalPeer::ack = "ack";

QtLocalPeer::QtLocalPeer(QObject* parent, const QString &appId)
: QObject(parent), id(appId)
{
QString prefix = id;
if (id.isEmpty()) {
id = QCoreApplication::applicationFilePath();
#if defined(Q_OS_WIN)
id = id.toLower();
#endif
prefix = id.section(QLatin1Char('/'), -1);
}
prefix.remove(QRegExp("[^a-zA-Z]"));
prefix.truncate(6);

QByteArray idc = id.toUtf8();
quint16 idNum = qChecksum(idc.constData(), idc.size());
socketName = QLatin1String("qtsingleapp-") + prefix
+ QLatin1Char('-') + QString::number(idNum, 16);

#if defined(Q_OS_WIN)
if (!pProcessIdToSessionId) {
QLibrary lib("kernel32");
pProcessIdToSessionId = (PProcessIdToSessionId)lib.resolve("ProcessIdToSessionId");
}
if (pProcessIdToSessionId) {
DWORD sessionId = 0;
pProcessIdToSessionId(GetCurrentProcessId(), &sessionId);
socketName += QLatin1Char('-') + QString::number(sessionId, 16);
}
#else
socketName += QLatin1Char('-') + QString::number(::getuid(), 16);
#endif

server = new QLocalServer(this);
QString lockName = QDir(QDir::tempPath()).absolutePath()
+ QLatin1Char('/') + socketName
+ QLatin1String("-lockfile");
lockFile.setFileName(lockName);
lockFile.open(QIODevice::ReadWrite);
}



bool QtLocalPeer::isClient()
{
if (lockFile.isLocked())
return false;

if (!lockFile.lock(QtLP_Private::QtLockedFile::WriteLock, false))
return true;

bool res = server->listen(socketName);
#if defined(Q_OS_UNIX) && (QT_VERSION >= QT_VERSION_CHECK(4,5,0))
// ### Workaround
if (!res && server->serverError() == QAbstractSocket::AddressInUseError) {
QFile::remove(QDir::cleanPath(QDir::tempPath())+QLatin1Char('/')+socketName);
res = server->listen(socketName);
}
#endif
if (!res)
qWarning("QtSingleCoreApplication: listen on local socket failed, %s", qPrintable(server->errorString()));
QObject::connect(server, SIGNAL(newConnection()), SLOT(receiveConnection()));
return false;
}


bool QtLocalPeer::sendMessage(const QString &message, int timeout)
{
if (!isClient())
return false;

QLocalSocket socket;
bool connOk = false;
for(int i = 0; i < 2; i++) {
// Try twice, in case the other instance is just starting up
socket.connectToServer(socketName);
connOk = socket.waitForConnected(timeout/2);
if (connOk || i)
break;
int ms = 250;
#if defined(Q_OS_WIN)
Sleep(DWORD(ms));
#else
struct timespec ts = { ms / 1000, (ms % 1000) * 1000 * 1000 };
nanosleep(&ts, NULL);
#endif
}
if (!connOk)
return false;

QByteArray uMsg(message.toUtf8());
QDataStream ds(&socket);
ds.writeBytes(uMsg.constData(), uMsg.size());
bool res = socket.waitForBytesWritten(timeout);
if (res) {
res &= socket.waitForReadyRead(timeout); // wait for ack
if (res)
res &= (socket.read(qstrlen(ack)) == ack);
}
return res;
}


void QtLocalPeer::receiveConnection()
{
QLocalSocket* socket = server->nextPendingConnection();
if (!socket)
return;

while (true) {
if (socket->state() == QLocalSocket::UnconnectedState) {
qWarning("QtLocalPeer: Peer disconnected");
delete socket;
return;
}
if (socket->bytesAvailable() >= qint64(sizeof(quint32)))
break;
socket->waitForReadyRead();
}

QDataStream ds(socket);
QByteArray uMsg;
quint32 remaining;
ds >> remaining;
uMsg.resize(remaining);
int got = 0;
char* uMsgBuf = uMsg.data();
do {
got = ds.readRawData(uMsgBuf, remaining);
remaining -= got;
uMsgBuf += got;
} while (remaining && got >= 0 && socket->waitForReadyRead(2000));
if (got < 0) {
qWarning("QtLocalPeer: Message reception failed %s", socket->errorString().toLatin1().constData());
delete socket;
return;
}
QString message(QString::fromUtf8(uMsg));
socket->write(ack, qstrlen(ack));
socket->waitForBytesWritten(1000);
socket->waitForDisconnected(1000); // make sure client reads ack
delete socket;
emit messageReceived(message); //### (might take a long time to return)
}
77 changes: 77 additions & 0 deletions 3rd/qtsingleapplication/src/qtlocalpeer.h
Original file line number Diff line number Diff line change
@@ -0,0 +1,77 @@
/****************************************************************************
**
** Copyright (C) 2013 Digia Plc and/or its subsidiary(-ies).
** Contact: http://www.qt-project.org/legal
**
** This file is part of the Qt Solutions component.
**
** $QT_BEGIN_LICENSE:BSD$
** You may use this file under the terms of the BSD license as follows:
**
** "Redistribution and use in source and binary forms, with or without
** modification, are permitted provided that the following conditions are
** met:
** * Redistributions of source code must retain the above copyright
** notice, this list of conditions and the following disclaimer.
** * Redistributions in binary form must reproduce the above copyright
** notice, this list of conditions and the following disclaimer in
** the documentation and/or other materials provided with the
** distribution.
** * Neither the name of Digia Plc and its Subsidiary(-ies) nor the names
** of its contributors may be used to endorse or promote products derived
** from this software without specific prior written permission.
**
**
** THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
** "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
** LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
** A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
** OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
** SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
** LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
** DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
** THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
** (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
** OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE."
**
** $QT_END_LICENSE$
**
****************************************************************************/

#ifndef QTLOCALPEER_H
#define QTLOCALPEER_H

#include <QLocalServer>
#include <QLocalSocket>
#include <QDir>

#include "qtlockedfile.h"

class QtLocalPeer : public QObject
{
Q_OBJECT

public:
QtLocalPeer(QObject *parent = 0, const QString &appId = QString());
bool isClient();
bool sendMessage(const QString &message, int timeout);
QString applicationId() const
{ return id; }

Q_SIGNALS:
void messageReceived(const QString &message);

protected Q_SLOTS:
void receiveConnection();

protected:
QString id;
QString socketName;
QLocalServer* server;
QtLP_Private::QtLockedFile lockFile;

private:
static const char* ack;
};

#endif // QTLOCALPEER_H
Loading

0 comments on commit 398931d

Please sign in to comment.