mirror of
https://github.com/swift-project/pilotclient.git
synced 2026-04-23 05:45:35 +08:00
committed by
Mathew Sutcliffe
parent
660798e43c
commit
f2602a8915
@@ -42,6 +42,7 @@
|
|||||||
#include <QEventLoop>
|
#include <QEventLoop>
|
||||||
#include <QFile>
|
#include <QFile>
|
||||||
#include <QFileInfo>
|
#include <QFileInfo>
|
||||||
|
#include <QHttpMultiPart>
|
||||||
#include <QNetworkReply>
|
#include <QNetworkReply>
|
||||||
#include <QNetworkRequest>
|
#include <QNetworkRequest>
|
||||||
#include <QProcess>
|
#include <QProcess>
|
||||||
|
|||||||
@@ -98,16 +98,15 @@ namespace BlackCore
|
|||||||
{
|
{
|
||||||
static const CLogCategoryList cats(CLogCategoryList(this).join({ CLogCategory::swiftDbWebservice()}));
|
static const CLogCategoryList cats(CLogCategoryList(this).join({ CLogCategory::swiftDbWebservice()}));
|
||||||
QScopedPointer<QNetworkReply, QScopedPointerDeleteLater> nwReply(nwReplyPtr);
|
QScopedPointer<QNetworkReply, QScopedPointerDeleteLater> nwReply(nwReplyPtr);
|
||||||
m_pendingReply = nullptr;
|
|
||||||
QUrl url(nwReply->url());
|
|
||||||
QString urlString(url.toString());
|
|
||||||
|
|
||||||
if (m_shutdown)
|
if (m_shutdown)
|
||||||
{
|
{
|
||||||
nwReply->abort();
|
nwReply->abort();
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
m_pendingReply = nullptr;
|
||||||
|
const QUrl url(nwReply->url());
|
||||||
|
const QString urlString(url.toString());
|
||||||
if (nwReply->error() == QNetworkReply::NoError)
|
if (nwReply->error() == QNetworkReply::NoError)
|
||||||
{
|
{
|
||||||
const QString dataFileData(nwReply->readAll().trimmed());
|
const QString dataFileData(nwReply->readAll().trimmed());
|
||||||
@@ -128,7 +127,7 @@ namespace BlackCore
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
QString error = nwReply->errorString();
|
const QString error = nwReply->errorString();
|
||||||
nwReply->close(); // close asap
|
nwReply->close(); // close asap
|
||||||
const CStatusMessageList msgs( {CStatusMessage(cats, CStatusMessage::SeverityError, "HTTP error: " + error)});
|
const CStatusMessageList msgs( {CStatusMessage(cats, CStatusMessage::SeverityError, "HTTP error: " + error)});
|
||||||
emit publishedModels(CAircraftModelList(), CAircraftModelList(), msgs, false, false);
|
emit publishedModels(CAircraftModelList(), CAircraftModelList(), msgs, false, false);
|
||||||
@@ -147,7 +146,7 @@ namespace BlackCore
|
|||||||
bool CDatabaseWriter::isReplyOverdue() const
|
bool CDatabaseWriter::isReplyOverdue() const
|
||||||
{
|
{
|
||||||
if (m_replyPendingSince < 0 || !m_pendingReply) { return false; }
|
if (m_replyPendingSince < 0 || !m_pendingReply) { return false; }
|
||||||
qint64 ms = QDateTime::currentMSecsSinceEpoch() - m_replyPendingSince;
|
const qint64 ms = QDateTime::currentMSecsSinceEpoch() - m_replyPendingSince;
|
||||||
return ms > 7500;
|
return ms > 7500;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -36,7 +36,7 @@ namespace BlackCore
|
|||||||
//! Constructor
|
//! Constructor
|
||||||
CDatabaseWriter(const BlackMisc::Network::CUrl &baseUrl, QObject *parent);
|
CDatabaseWriter(const BlackMisc::Network::CUrl &baseUrl, QObject *parent);
|
||||||
|
|
||||||
//! Write models to DB
|
//! Write model to DB
|
||||||
BlackMisc::CStatusMessageList asyncPublishModel(const BlackMisc::Simulation::CAircraftModel &model);
|
BlackMisc::CStatusMessageList asyncPublishModel(const BlackMisc::Simulation::CAircraftModel &model);
|
||||||
|
|
||||||
//! Write models to DB
|
//! Write models to DB
|
||||||
@@ -45,6 +45,9 @@ namespace BlackCore
|
|||||||
//! Shutdown
|
//! Shutdown
|
||||||
void gracefulShutdown();
|
void gracefulShutdown();
|
||||||
|
|
||||||
|
//! Shutting down?
|
||||||
|
bool isShuttingDown() const { return m_shutdown; }
|
||||||
|
|
||||||
signals:
|
signals:
|
||||||
//! Published models, the response to \sa asyncPublishModels
|
//! Published models, the response to \sa asyncPublishModels
|
||||||
void publishedModels(const BlackMisc::Simulation::CAircraftModelList &modelsPublished,
|
void publishedModels(const BlackMisc::Simulation::CAircraftModelList &modelsPublished,
|
||||||
|
|||||||
@@ -83,7 +83,7 @@ namespace BlackMisc
|
|||||||
|
|
||||||
void CUrl::setQuery(const QString &query)
|
void CUrl::setQuery(const QString &query)
|
||||||
{
|
{
|
||||||
QString q(stripQueryString(query));
|
const QString q(stripQueryString(query));
|
||||||
m_query = q;
|
m_query = q;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -94,7 +94,7 @@ namespace BlackMisc
|
|||||||
|
|
||||||
QString CUrl::appendQuery(const QString &queryToAppend)
|
QString CUrl::appendQuery(const QString &queryToAppend)
|
||||||
{
|
{
|
||||||
QString q(stripQueryString(queryToAppend));
|
const QString q(stripQueryString(queryToAppend));
|
||||||
if (q.isEmpty()) { return m_query; }
|
if (q.isEmpty()) { return m_query; }
|
||||||
if (!hasQuery())
|
if (!hasQuery())
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user