mirror of
https://github.com/qTox/qTox.git
synced 2024-03-22 14:00:36 +08:00
67e9aeec63
The qTox Project is not associated with the Tox Project in any way, with the exception of "qTox" using the Tox Projet's "toxcore" collection of libraries. In particular, the Tox Projet does not own copyright over the qTox Project's "qTox" collection of software, source code, and assets. The qTox Project's assets are under the sole copyright of the qTox contributors, and no partiular rights are granted to the Tox Project.
98 lines
2.5 KiB
C++
98 lines
2.5 KiB
C++
/*
|
|
Copyright © 2014-2015 by The qTox Project
|
|
|
|
This file is part of qTox, a Qt-based graphical interface for Tox.
|
|
|
|
qTox is libre 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.
|
|
|
|
qTox 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 qTox. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
|
|
#ifndef IPC_H
|
|
#define IPC_H
|
|
|
|
#include <QSharedMemory>
|
|
#include <QTimer>
|
|
#include <QObject>
|
|
#include <QThread>
|
|
#include <QVector>
|
|
#include <QMap>
|
|
#include <functional>
|
|
#include <ctime>
|
|
|
|
using IPCEventHandler = std::function<bool (const QByteArray&)>;
|
|
|
|
#define IPC_PROTOCOL_VERSION "2"
|
|
|
|
class IPC : public QThread
|
|
{
|
|
Q_OBJECT
|
|
IPC();
|
|
protected:
|
|
static const int EVENT_TIMER_MS = 1000;
|
|
static const int EVENT_GC_TIMEOUT = 5;
|
|
static const int EVENT_QUEUE_SIZE = 32;
|
|
static const int OWNERSHIP_TIMEOUT_S = 5;
|
|
|
|
public:
|
|
~IPC();
|
|
|
|
static IPC& getInstance();
|
|
|
|
struct IPCEvent
|
|
{
|
|
uint32_t dest;
|
|
int32_t sender;
|
|
char name[16];
|
|
char data[128];
|
|
time_t posted;
|
|
time_t processed;
|
|
uint32_t flags;
|
|
bool accepted;
|
|
bool global;
|
|
};
|
|
|
|
struct IPCMemory
|
|
{
|
|
uint64_t globalId;
|
|
// When last event was posted
|
|
time_t lastEvent;
|
|
// When processEvents() ran last time
|
|
time_t lastProcessed;
|
|
IPCEvent events[IPC::EVENT_QUEUE_SIZE];
|
|
};
|
|
|
|
// dest: Settings::getCurrentProfileId() or 0 (main instance).
|
|
time_t postEvent(const QString& name, const QByteArray &data=QByteArray(), uint32_t dest=0);
|
|
bool isCurrentOwner();
|
|
void registerEventHandler(const QString& name, IPCEventHandler handler);
|
|
bool isEventAccepted(time_t time);
|
|
bool waitUntilAccepted(time_t time, int32_t timeout=-1);
|
|
|
|
protected slots:
|
|
void processEvents();
|
|
|
|
protected:
|
|
IPCMemory* global();
|
|
bool runEventHandler(IPCEventHandler handler, const QByteArray& arg);
|
|
// Only called when global memory IS LOCKED, returns 0 if no evnts present
|
|
IPCEvent* fetchEvent();
|
|
|
|
QTimer timer;
|
|
uint64_t globalId;
|
|
QSharedMemory globalMemory;
|
|
QMap<QString, IPCEventHandler> eventHandlers;
|
|
};
|
|
|
|
#endif // IPC_H
|