diff options
Diffstat (limited to 'src/core/preforkprocessbackendfactory.cpp')
| -rw-r--r-- | src/core/preforkprocessbackendfactory.cpp | 208 |
1 files changed, 208 insertions, 0 deletions
diff --git a/src/core/preforkprocessbackendfactory.cpp b/src/core/preforkprocessbackendfactory.cpp new file mode 100644 index 0000000..b2336d3 --- /dev/null +++ b/src/core/preforkprocessbackendfactory.cpp @@ -0,0 +1,208 @@ +/**************************************************************************** +** +** Copyright (C) 2012 Nokia Corporation and/or its subsidiary(-ies). +** All rights reserved. +** Contact: Nokia Corporation (qt-info@nokia.com) +** +** $QT_BEGIN_LICENSE:LGPL$ +** GNU Lesser General Public License Usage +** This file may be used under the terms of the GNU Lesser General Public +** License version 2.1 as published by the Free Software Foundation and +** appearing in the file LICENSE.LGPL included in the packaging of this +** file. Please review the following information to ensure the GNU Lesser +** General Public License version 2.1 requirements will be met: +** http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. +** +** In addition, as a special exception, Nokia gives you certain additional +** rights. These rights are described in the Nokia Qt LGPL Exception +** version 1.1, included in the file LGPL_EXCEPTION.txt in this package. +** +** GNU General Public License Usage +** Alternatively, this file may be used under the terms of the GNU General +** Public License version 3.0 as published by the Free Software Foundation +** and appearing in the file LICENSE.GPL included in the packaging of this +** file. Please review the following information to ensure the GNU General +** Public License version 3.0 requirements will be met: +** http://www.gnu.org/copyleft/gpl.html. +** +** Other Usage +** Alternatively, this file may be used in accordance with the terms and +** conditions contained in a signed written agreement between you and Nokia. +** +** +** +** +** +** $QT_END_LICENSE$ +** +****************************************************************************/ + +#include "preforkprocessbackendfactory.h" +#include "prefork.h" +#include "remoteprocessbackend.h" +#include "remoteprotocol.h" + +#include <QDebug> +#include <QJsonDocument> +#include <QSocketNotifier> +//#include <QFileInfo> +#include <QtEndian> + +QT_BEGIN_NAMESPACE_PROCESSMANAGER + +const int kPreforkTimerInterval = 1000; + +/*! + \class PreforkProcessBackendFactory + \brief The PreforkProcessBackendFactory connects to a preforked client +*/ + +/*! + \property index + Index into the prefork instance of which process this should be + connected to. +*/ + +/*! + Construct a PreforkProcessBackendFactory with optional \a parent. + The \a info ProcessInfo is used to start the prefork process. +*/ + +PreforkProcessBackendFactory::PreforkProcessBackendFactory(QObject *parent) + : RemoteProcessBackendFactory(parent) + , m_index(-1) + , m_in(NULL) + , m_out(NULL) +{ +} + +/*! + Destroy this and child objects. +*/ + +PreforkProcessBackendFactory::~PreforkProcessBackendFactory() +{ + const PreforkChildData *data = Prefork::instance()->at(m_index); + if (data) { + QJsonObject message; + message.insert(RemoteProtocol::remote(), RemoteProtocol::stop()); + m_outbuf.append(QJsonDocument(message).toBinaryData()); + + while (m_outbuf.size()) { + int n = ::write(data->stdin, m_outbuf.data(), m_outbuf.size()); + if (n == -1) + qFatal("Failed to write to stdout"); + if (n < m_outbuf.size()) + m_outbuf = m_outbuf.mid(n); + else + m_outbuf.clear(); + } + } +} + +/*! + Return the process index + */ + +int PreforkProcessBackendFactory::index() const +{ + return m_index; +} + +/*! + Set the prefork index to \a index + */ + +void PreforkProcessBackendFactory::setIndex(int index) +{ + Prefork *prefork = Prefork::instance(); + Q_ASSERT(prefork); + + if (index >= 0 && index < prefork->size()) { + m_index = index; + const PreforkChildData *data = prefork->at(index); + + if (m_in) + delete m_in; + if (m_out) + delete m_out; + + m_in = new QSocketNotifier(data->stdout, QSocketNotifier::Read, this); + m_out = new QSocketNotifier(data->stdin, QSocketNotifier::Write, this); + connect(m_in, SIGNAL(activated(int)), SLOT(inReady(int))); + connect(m_out, SIGNAL(activated(int)), SLOT(outReady(int))); + m_in->setEnabled(true); + m_out->setEnabled(false); + emit indexChanged(); + } + else + qWarning() << Q_FUNC_INFO << "index out of range"; +} + + +bool PreforkProcessBackendFactory::send(const QJsonObject& message) +{ + m_outbuf.append(QJsonDocument(message).toBinaryData()); + m_out->setEnabled(true); + return true; +} + +void PreforkProcessBackendFactory::inReady(int fd) +{ + m_in->setEnabled(false); + const int bufsize = 1024; + uint oldSize = m_inbuf.size(); + m_inbuf.resize(oldSize + bufsize); + int n = ::read(fd, m_inbuf.data()+oldSize, bufsize); + if (n > 0) + m_inbuf.resize(oldSize+n); + else + m_inbuf.resize(oldSize); + + while (m_inbuf.size() >= 12) { + if (QJsonDocument::BinaryFormatTag != *((uint *) m_inbuf.data())) + qFatal("ERROR in receive buffer: %s", m_inbuf.data()); + qint32 message_size = qFromLittleEndian(((qint32 *)m_inbuf.data())[2]) + 8; + if (m_inbuf.size() < message_size) + break; + QByteArray msg = m_inbuf.left(message_size); + m_inbuf = m_inbuf.mid(message_size); + receive(QJsonDocument::fromBinaryData(msg).object()); + } + m_in->setEnabled(true); +} + +void PreforkProcessBackendFactory::outReady(int fd) +{ + m_out->setEnabled(false); + if (m_outbuf.size()) { + int n = ::write(fd, m_outbuf.data(), m_outbuf.size()); + if (n == -1) { + qDebug() << "Failed to write to stdout"; + exit(-1); + } + if (n < m_outbuf.size()) + m_outbuf = m_outbuf.mid(n); + else + m_outbuf.clear(); + } + if (m_outbuf.size()) + m_out->setEnabled(true); +} + +/*! + Return the preforked process + */ + +QList<Q_PID> PreforkProcessBackendFactory::internalProcesses() +{ + QList<Q_PID> list; + const PreforkChildData *data = Prefork::instance()->at(m_index); + if (data) + list << data->pid; + return list; +} + +#include "moc_preforkprocessbackendfactory.cpp" + +QT_END_NAMESPACE_PROCESSMANAGER |