QtIFW

/**************************************************************************

**

** 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$

**

**************************************************************************/

​

#include "protocol.h"

#include <QIODevice>

​

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);

    }

}

​