1/****************************************************************************
2**
3** Copyright (C) 2015 The Qt Company Ltd and/or its subsidiary(-ies).
4** Contact: http://www.qt-project.org/legal
5**
6** This file is part of the QtSystems module of the Qt Toolkit.
7**
8** $QT_BEGIN_LICENSE:LGPL21$
9** Commercial License Usage
10** Licensees holding valid commercial Qt licenses may use this file in
11** accordance with the commercial license agreement provided with the
12** Software or, alternatively, in accordance with the terms contained in
13** a written agreement between you and The Qt Company. For licensing terms
14** and conditions see http://www.qt.io/terms-conditions. For further
15** information use the contact form at http://www.qt.io/contact-us.
16**
17** GNU Lesser General Public License Usage
18** Alternatively, this file may be used under the terms of the GNU Lesser
19** General Public License version 2.1 or version 3 as published by the Free
20** Software Foundation and appearing in the file LICENSE.LGPLv21 and
21** LICENSE.LGPLv3 included in the packaging of this file. Please review the
22** following information to ensure the GNU Lesser General Public License
23** requirements will be met: https://www.gnu.org/licenses/lgpl.html and
24** http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.
25**
26** As a special exception, The Qt Company gives you certain additional
27** rights. These rights are described in The Qt Company LGPL Exception
28** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.
29**
30** $QT_END_LICENSE$
31**
32****************************************************************************/
33
34#include "ipcendpoint_p.h"
35
36#include "qservicedebuglog_p.h"
37
38#include <QEventLoop>
39#include <QTimer>
40
41QT_BEGIN_NAMESPACE
42/*!
43 QServiceIpcEndPoint
44*/
45QServiceIpcEndPoint::QServiceIpcEndPoint(QObject* parent)
46 : QObject( parent )
47{
48}
49
50QServiceIpcEndPoint::~QServiceIpcEndPoint()
51{
52 qServiceLog() << "event" << "delete"
53 << "class" << "QServiceIpcEndPoint"
54 << "name" << objectName();
55 incoming.clear();
56}
57
58bool QServiceIpcEndPoint::packageAvailable() const
59{
60 return !incoming.isEmpty();
61}
62
63QServicePackage QServiceIpcEndPoint::nextPackage()
64{
65 if (!incoming.isEmpty())
66 return incoming.dequeue();
67 return QServicePackage();
68}
69
70void QServiceIpcEndPoint::writePackage(QServicePackage newPackage)
71{
72 flushPackage(out: newPackage);
73}
74
75void QServiceIpcEndPoint::getSecurityCredentials(QServiceClientCredentials &)
76{
77}
78
79void QServiceIpcEndPoint::terminateConnection()
80{
81 qWarning() << "SFW Terminate connection called on base class, should be reimplemented to do something";
82}
83
84int QServiceIpcEndPoint::waitForData()
85{
86 QEventLoop loop;
87 QTimer timer;
88 timer.setSingleShot(true);
89 connect(sender: &timer, SIGNAL(timeout()), receiver: &loop, SLOT(quit()));
90 connect(sender: this, SIGNAL(packageReceived()), receiver: &loop, SLOT(quit()));
91
92 timer.start(msec: 30000);
93 loop.exec();
94 return 0;
95}
96
97void QServiceIpcEndPoint::waitingDone()
98{
99 emit packageReceived();
100}
101
102#include "moc_ipcendpoint_p.cpp"
103QT_END_NAMESPACE
104

source code of qtsystems/src/serviceframework/ipc/ipcendpoint.cpp