Source
xxxxxxxxxx
Returns \c false if the packet in the device buffer is yet incomplete, \c true otherwise.
/**************************************************************************
**
** Copyright (C) 2017 The Qt Company Ltd.
** Contact: https://www.qt.io/licensing/
**
** This file is part of the Qt Installer Framework.
**
** $QT_BEGIN_LICENSE:GPL-EXCEPT$
** Commercial License Usage
** Licensees holding valid commercial Qt licenses may use this file in
** accordance with the commercial license agreement provided with the
** Software or, alternatively, in accordance with the terms contained in
** a written agreement between you and The Qt Company. For licensing terms
** and conditions see https://www.qt.io/terms-conditions. For further
** information use the contact form at https://www.qt.io/contact-us.
**
** GNU General Public License Usage
** Alternatively, this file may be used under the terms of the GNU
** General Public License version 3 as published by the Free Software
** Foundation with exceptions as appearing in the file LICENSE.GPL3-EXCEPT
** included in the packaging of this file. Please review the following
** information to ensure the GNU General Public License requirements will
** be met: https://www.gnu.org/licenses/gpl-3.0.html.
**
** $QT_END_LICENSE$
**
**************************************************************************/
namespace QInstaller {
typedef qint32 PackageSize;
/*!
Write a packet containing \a command and \a data to \a device.
\note Both client and server need to have the same endianness.
*/
void sendPacket(QIODevice *device, const QByteArray &command, const QByteArray &data)
{
// use aliasing for writing payload size into bytes
char payloadBytes[sizeof(PackageSize)];
PackageSize *payloadSize = reinterpret_cast<PackageSize*>(&payloadBytes);
*payloadSize = command.size() + sizeof(char) + data.size();
QByteArray packet;
packet.reserve(sizeof(PackageSize) + *payloadSize);
packet.append(payloadBytes, sizeof(PackageSize));
packet.append(command);
packet.append('\0');
packet.append(data);
forever {
const int bytesWritten = device->write(packet);
Q_ASSERT(bytesWritten >= 0);
if (bytesWritten == packet.size())
break;
packet.remove(0, bytesWritten);
}
}