datasender.cpp

Go to the documentation of this file.

/*
 * Copyright (C) 2018-2024 QuasarApp.
 * Distributed under the lgplv3 software license, see the accompanying
 * Everyone is permitted to copy and distribute verbatim copies
 * of this license document, but changing it is not allowed.
*/
 
 
#include "datasender.h"
#include <QAbstractSocket>
#include <quasarapp.h>
#include <QThread>
 
namespace QH {
 
DataSender::DataSender(QThread *thread):
    Async(thread ) {
 
}
 
bool DataSender::sendData(const QByteArray &array, void *target, bool await) const {
    return asyncLauncher(std::bind(&DataSender::sendPackagePrivate, this, array, target), await);
}
 
bool QH::DataSender::sendPackagePrivate(QByteArray array, void *target) const {
    auto ptr = static_cast<QAbstractSocket*>(target);
 
    if (!(ptr && ptr->isValid() && ptr->isWritable())) {
        QuasarAppUtils::Params::log("Send raw data error. Socket is invalid", QuasarAppUtils::Error);
        return false;
    }
 
    int wrote = 0;
 
    while (wrote < array.length() && ptr->isWritable()) {
        wrote += ptr->write(array.mid(wrote, array.length()));
    }
 
    if (!ptr->flush()) {
        QuasarAppUtils::Params::log("Send raw data error. data not flushed", QuasarAppUtils::Error);
 
        return false;
    }
 
    if (array.size() != wrote) {
        QuasarAppUtils::Params::log("not writed data to socket", QuasarAppUtils::Error);
        return false;
    }
 
    return true;
}
 
}