diff options
author | Ivan Solovev <ivan.solovev@qt.io> | 2021-10-21 17:27:08 +0200 |
---|---|---|
committer | Ivan Solovev <ivan.solovev@qt.io> | 2021-11-02 09:46:33 +0200 |
commit | 6db775f6d9d72cf8ee9d66333b8424e74be1e352 (patch) | |
tree | 0a293756b61619a91970d9368a0449b7bf922728 /src/positioning/qnmeasatelliteinfosource.cpp | |
parent | 5a1f44c3d41febca8480c077bd4c34e5a3332cdc (diff) | |
download | qtlocation-6db775f6d9d72cf8ee9d66333b8424e74be1e352.tar.gz |
Turns out that our CI does not support repos without
any tests. This is treated like an error and leads to
integration failure.
This patch fixes it by disabling tests in
coin/module_config.yaml. This config should be fixed
when QtLocation tests are enabled
Task-number: QTBUG-97084
Change-Id: Ib06e865fe2836806bbbee34345f06b471dd48660
Reviewed-by: Qt CI Bot <qt_ci_bot@qt-project.org>
Reviewed-by: Alex Blasche <alexander.blasche@qt.io>
(cherry picked from commit 23f32792ad53e23bbafbff6d7667f0bb0f69fc53)
Diffstat (limited to 'src/positioning/qnmeasatelliteinfosource.cpp')
-rw-r--r-- | src/positioning/qnmeasatelliteinfosource.cpp | 909 |
1 files changed, 0 insertions, 909 deletions
diff --git a/src/positioning/qnmeasatelliteinfosource.cpp b/src/positioning/qnmeasatelliteinfosource.cpp deleted file mode 100644 index a27ac2b0..00000000 --- a/src/positioning/qnmeasatelliteinfosource.cpp +++ /dev/null @@ -1,909 +0,0 @@ -/**************************************************************************** -** -** Copyright (C) 2019 The Qt Company Ltd. -** Contact: https://www.qt.io/licensing/ -** -** This file is part of the QtPositioning module of the Qt Toolkit. -** -** $QT_BEGIN_LICENSE:LGPL$ -** 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 Lesser General Public License Usage -** Alternatively, this file may be used under the terms of the GNU Lesser -** General Public License version 3 as published by the Free Software -** Foundation and appearing in the file LICENSE.LGPL3 included in the -** packaging of this file. Please review the following information to -** ensure the GNU Lesser General Public License version 3 requirements -** will be met: https://www.gnu.org/licenses/lgpl-3.0.html. -** -** GNU General Public License Usage -** Alternatively, this file may be used under the terms of the GNU -** General Public License version 2.0 or (at your option) the GNU General -** Public license version 3 or any later version approved by the KDE Free -** Qt Foundation. The licenses are as published by the Free Software -** Foundation and appearing in the file LICENSE.GPL2 and LICENSE.GPL3 -** 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-2.0.html and -** https://www.gnu.org/licenses/gpl-3.0.html. -** -** $QT_END_LICENSE$ -** -****************************************************************************/ - -#include "qnmeasatelliteinfosource.h" -#include "private/qnmeasatelliteinfosource_p.h" -#include <QtPositioning/private/qgeosatelliteinfo_p.h> -#include <QtPositioning/private/qgeosatelliteinfosource_p.h> -#include <QtPositioning/private/qlocationutils_p.h> - -#include <QIODevice> -#include <QBasicTimer> -#include <QTimerEvent> -#include <QTimer> -#include <array> -#include <QDebug> -#include <QtCore/QtNumeric> - -QT_BEGIN_NAMESPACE - -#if USE_NMEA_PIMPL -class QGeoSatelliteInfoPrivateNmea : public QGeoSatelliteInfoPrivate -{ -public: - QGeoSatelliteInfoPrivateNmea(const QGeoSatelliteInfoPrivate &other); - QGeoSatelliteInfoPrivateNmea(const QGeoSatelliteInfoPrivateNmea &other); - virtual ~QGeoSatelliteInfoPrivateNmea(); - - QList<QByteArray> nmeaSentences; -}; - -QGeoSatelliteInfoPrivateNmea::QGeoSatelliteInfoPrivateNmea(const QGeoSatelliteInfoPrivate &other) - : QGeoSatelliteInfoPrivate(other) -{ -} - -QGeoSatelliteInfoPrivateNmea::QGeoSatelliteInfoPrivateNmea(const QGeoSatelliteInfoPrivateNmea &other) - : QGeoSatelliteInfoPrivate(other) -{ - nmeaSentences = other.nmeaSentences; -} - -QGeoSatelliteInfoPrivateNmea::~QGeoSatelliteInfoPrivateNmea() {} -#else -typedef QGeoSatelliteInfoPrivate QGeoSatelliteInfoPrivateNmea; -#endif - -QNmeaSatelliteInfoSourcePrivate::QNmeaSatelliteInfoSourcePrivate(QNmeaSatelliteInfoSource *parent, QNmeaSatelliteInfoSource::UpdateMode updateMode) - : m_source(parent), - m_updateMode(updateMode) -{ -} - -void QNmeaSatelliteInfoSourcePrivate::notifyNewUpdate() -{ - if (m_pendingUpdate.isValid() && m_pendingUpdate.isFresh()) { - if (m_requestTimer && m_requestTimer->isActive()) { // User called requestUpdate() - m_requestTimer->stop(); - emitUpdated(m_pendingUpdate, true); - } else if (m_invokedStart) { // user called startUpdates() - if (m_updateTimer && m_updateTimer->isActive()) { // update interval > 0 - // for periodic updates, only want the most recent update - if (m_noUpdateLastInterval) { - // if the update was invalid when timerEvent was last called, a valid update - // should be sent ASAP - emitPendingUpdate(); // m_noUpdateLastInterval handled in there. - } - } else { // update interval <= 0, send anything new ASAP - m_noUpdateLastInterval = !emitUpdated(m_pendingUpdate, false); - } - } - } -} - -void QNmeaSatelliteInfoSourcePrivate::processNmeaData(QNmeaSatelliteInfoUpdate &updateInfo) -{ - char buf[1024]; - qint64 size = m_device->readLine(buf, sizeof(buf)); - QList<int> satInUse; - const auto satSystemType = m_source->parseSatellitesInUseFromNmea(buf, size, satInUse); - if (satSystemType != QGeoSatelliteInfo::Undefined) { - const bool res = updateInfo.setSatellitesInUse(satSystemType, satInUse); -#if USE_NMEA_PIMPL - if (res) { - updateInfo.gsa = QByteArray(buf, size); - auto &info = updateInfo.m_satellites[satSystemType]; - if (info.satellitesInUse.size()) { - for (auto &s : info.satellitesInUse) { - static_cast<QGeoSatelliteInfoPrivateNmea *>(QGeoSatelliteInfoPrivate::get(s)) - ->nmeaSentences.append(updateInfo.gsa); - } - for (auto &s : info.satellitesInView) { - static_cast<QGeoSatelliteInfoPrivateNmea *>(QGeoSatelliteInfoPrivate::get(s)) - ->nmeaSentences.append(updateInfo.gsa); - } - } - } -#else - Q_UNUSED(res) -#endif // USE_NMEA_PIMPL - } else { - // Here we have the assumption that multiple parts of GSV sentence - // come one after another. At least this is how it should be. - auto systemType = QGeoSatelliteInfo::Undefined; - const auto parserStatus = m_source->parseSatelliteInfoFromNmea( - buf, size, updateInfo.m_satellitesInViewParsed, systemType); - if (parserStatus == QNmeaSatelliteInfoSource::PartiallyParsed) { - updateInfo.m_satellites[systemType].updatingGSV = true; -#if USE_NMEA_PIMPL - updateInfo.gsv.append(QByteArray(buf, size)); -#endif - } else if (parserStatus == QNmeaSatelliteInfoSource::FullyParsed) { -#if USE_NMEA_PIMPL - updateInfo.gsv.append(QByteArray(buf, size)); - for (int i = 0; i < updateInfo.m_satellitesInViewParsed.size(); i++) { - const QGeoSatelliteInfo &s = updateInfo.m_satellitesInViewParsed.at(i); - QGeoSatelliteInfoPrivateNmea *pimpl = - new QGeoSatelliteInfoPrivateNmea(*QGeoSatelliteInfoPrivate::get(s)); - pimpl->nmeaSentences.append(updateInfo.gsa); - pimpl->nmeaSentences.append(updateInfo.gsv); - updateInfo.m_satellitesInViewParsed.replace(i, QGeoSatelliteInfo(*pimpl)); - } - updateInfo.gsv.clear(); -#endif - updateInfo.setSatellitesInView(systemType, updateInfo.m_satellitesInViewParsed); - } - } -} - -QNmeaSatelliteInfoSourcePrivate::~QNmeaSatelliteInfoSourcePrivate() -{ - delete m_updateTimer; -} - -void QNmeaSatelliteInfoSourcePrivate::startUpdates() -{ - if (m_invokedStart) - return; - - m_satelliteError = QGeoSatelliteInfoSource::NoError; - - m_invokedStart = true; - m_pendingUpdate.clear(); - m_noUpdateLastInterval = false; - - bool initialized = initialize(); - if (!initialized) - return; - - if (m_updateMode == QNmeaSatelliteInfoSource::UpdateMode::RealTimeMode) { - // skip over any buffered data - we only want the newest data. - // Don't do this in requestUpdate. In that case bufferedData is good to have/use. - if (m_device->bytesAvailable()) { - if (m_device->isSequential()) - m_device->readAll(); - else - m_device->seek(m_device->bytesAvailable()); - } - } - - if (m_updateTimer) - m_updateTimer->stop(); - - if (m_source->updateInterval() > 0) { - if (!m_updateTimer) - m_updateTimer = new QBasicTimer; - m_updateTimer->start(m_source->updateInterval(), this); - } - - if (initialized) - prepareSourceDevice(); -} - -void QNmeaSatelliteInfoSourcePrivate::stopUpdates() -{ - m_invokedStart = false; - if (m_updateTimer) - m_updateTimer->stop(); - m_pendingUpdate.clear(); - m_noUpdateLastInterval = false; -} - -void QNmeaSatelliteInfoSourcePrivate::requestUpdate(int msec) -{ - if (m_requestTimer && m_requestTimer->isActive()) - return; - - m_satelliteError = QGeoSatelliteInfoSource::NoError; - - if (msec <= 0 || msec < m_source->minimumUpdateInterval()) { - m_source->setError(QGeoSatelliteInfoSource::UpdateTimeoutError); - return; - } - - if (!m_requestTimer) { - m_requestTimer = new QTimer(this); - connect(m_requestTimer, SIGNAL(timeout()), SLOT(updateRequestTimeout())); - } - - bool initialized = initialize(); - if (!initialized) { - m_source->setError(QGeoSatelliteInfoSource::UpdateTimeoutError); - return; - } - - m_requestTimer->start(msec); - prepareSourceDevice(); -} - -void QNmeaSatelliteInfoSourcePrivate::readyRead() -{ - if (m_nmeaReader) - m_nmeaReader->readAvailableData(); -} - -void QNmeaSatelliteInfoSourcePrivate::emitPendingUpdate() -{ - if (m_pendingUpdate.isValid() && m_pendingUpdate.isFresh()) { - m_updateTimeoutSent = false; - m_noUpdateLastInterval = false; - if (!emitUpdated(m_pendingUpdate, false)) - m_noUpdateLastInterval = true; - // m_pendingUpdate.clear(); // Do not clear, it will be incrementally updated - } else { // invalid or not fresh update - if (m_noUpdateLastInterval && !m_updateTimeoutSent) { - m_updateTimeoutSent = true; - m_source->setError(QGeoSatelliteInfoSource::UpdateTimeoutError); - } - m_noUpdateLastInterval = true; - } -} - -void QNmeaSatelliteInfoSourcePrivate::sourceDataClosed() -{ - if (m_nmeaReader && m_device && m_device->bytesAvailable()) - m_nmeaReader->readAvailableData(); -} - -void QNmeaSatelliteInfoSourcePrivate::updateRequestTimeout() -{ - m_requestTimer->stop(); - m_source->setError(QGeoSatelliteInfoSource::UpdateTimeoutError); -} - -bool QNmeaSatelliteInfoSourcePrivate::openSourceDevice() -{ - if (!m_device) { - qWarning("QNmeaSatelliteInfoSource: no QIODevice data source, call setDevice() first"); - return false; - } - - if (!m_device->isOpen() && !m_device->open(QIODevice::ReadOnly)) { - qWarning("QNmeaSatelliteInfoSource: cannot open QIODevice data source"); - return false; - } - - connect(m_device, SIGNAL(aboutToClose()), SLOT(sourceDataClosed())); - connect(m_device, SIGNAL(readChannelFinished()), SLOT(sourceDataClosed())); - connect(m_device, SIGNAL(destroyed()), SLOT(sourceDataClosed())); - - return true; -} - -bool QNmeaSatelliteInfoSourcePrivate::initialize() -{ - if (m_nmeaReader) - return true; - - if (!openSourceDevice()) - return false; - - if (m_updateMode == QNmeaSatelliteInfoSource::UpdateMode::RealTimeMode) - m_nmeaReader.reset(new QNmeaSatelliteRealTimeReader(this)); - else - m_nmeaReader.reset(new QNmeaSatelliteSimulationReader(this)); - - return true; -} - -void QNmeaSatelliteInfoSourcePrivate::prepareSourceDevice() -{ - // some data may already be available - if (m_updateMode == QNmeaSatelliteInfoSource::UpdateMode::SimulationMode) { - if (m_nmeaReader && m_device->bytesAvailable()) - m_nmeaReader->readAvailableData(); - } - - if (!m_connectedReadyRead) { - connect(m_device, SIGNAL(readyRead()), SLOT(readyRead())); - m_connectedReadyRead = true; - } -} - -bool QNmeaSatelliteInfoSourcePrivate::emitUpdated(QNmeaSatelliteInfoUpdate &update, - bool fromRequestUpdate) -{ - bool emitted = false; - if (!update.isFresh()) - return emitted; - - update.consume(); - bool inUseUpdated = false; - bool inViewUpdated = false; - if (!fromRequestUpdate) { - // we need to send update if information from at least one satellite - // systems has changed - for (auto it = update.m_satellites.cbegin(); it != update.m_satellites.cend(); ++it) { - inUseUpdated |= - it->satellitesInUse != m_lastUpdate.m_satellites[it.key()].satellitesInUse; - inViewUpdated |= - it->satellitesInView != m_lastUpdate.m_satellites[it.key()].satellitesInView; - } - } else { - // if we come here from requestUpdate(), we need to emit, even if the data - // didn't really change - inUseUpdated = true; - inViewUpdated = true; - } - - m_lastUpdate = update; - if (update.m_validInUse && inUseUpdated) { - emit m_source->satellitesInUseUpdated(update.allSatellitesInUse()); - emitted = true; - } - if (update.m_validInView && inViewUpdated) { - emit m_source->satellitesInViewUpdated(update.allSatellitesInView()); - emitted = true; - } - return emitted; -} - -void QNmeaSatelliteInfoSourcePrivate::timerEvent(QTimerEvent * /*event*/) -{ - emitPendingUpdate(); -} - -/*! - \class QNmeaSatelliteInfoSource - \inmodule QtPositioning - \ingroup QtPositioning-positioning - \since 6.2 - - \brief The \l QNmeaSatelliteInfoSource class provides satellite information - using an NMEA data source. - - NMEA is a commonly used protocol for the specification of one's global - position at a certain point in time. The \l QNmeaSatelliteInfoSource class - reads NMEA data and uses it to provide information about satellites in view - and satellites in use in form of lists of \l QGeoSatelliteInfo objects. - - A \l QNmeaSatelliteInfoSource instance operates in either \l {RealTimeMode} - or \l {SimulationMode}. These modes allow NMEA data to be read from either a - live source of data, or replayed for simulation purposes from previously - recorded NMEA data. - - The source of NMEA data is set via \l setDevice(). - - Use \l startUpdates() to start receiving regular satellite information - updates and \l stopUpdates() to stop these updates. If you only require - updates occasionally, you can call \l requestUpdate() to request a single - update of both satellites in view and satellites in use. - - The information about satellites in view is received via the - \l satellitesInViewUpdated() signal. - - The information about satellites in use is received via the - \l satellitesInUseUpdated() signal. -*/ - -/*! - \enum QNmeaSatelliteInfoSource::UpdateMode - Defines the available update modes. - - \value RealTimeMode Satellite information is read and distributed from the - data source as it becomes available. Use this mode if you are using - a live source of NMEA data (for example a GPS hardware device). - \value SimulationMode Satellite information is read and distributed from the - data source at the given rate. The rate is determined by the - \l {QNmeaSatelliteInfoSource::}{SimulationUpdateInterval} parameter. - Use this mode if the data source contains previously recorded NMEA - data and you want to replay the data for simulation purposes. -*/ - -/*! - \variable QNmeaSatelliteInfoSource::SimulationUpdateInterval - \brief The backend property name for data read rate in the - \l SimulationMode. The value for this property is the integer number - representing the amount of milliseconds between the subsequent reads. - Use this parameter in the \l {QNmeaSatelliteInfoSource::} - {setBackendProperty()} and \l {QNmeaSatelliteInfoSource::}{backendProperty()} - methods. - - \note This property is different from the interval that can be set via - \l {setUpdateInterval()}. The value set via \l {setUpdateInterval()} - denotes an interval for the user notification, while this parameter - specifies the internal frequency of reading the data from source file. It - means that one can have multiple (or none) reads during the - \l {updateInterval()} period. -*/ -QString QNmeaSatelliteInfoSource::SimulationUpdateInterval = - QStringLiteral("nmea.satellite_info_simulation_interval"); - -/*! - Constructs a \l QNmeaSatelliteInfoSource instance with the given \a parent - and \a mode. -*/ -QNmeaSatelliteInfoSource::QNmeaSatelliteInfoSource(UpdateMode mode, QObject *parent) - : QGeoSatelliteInfoSource(parent), - d(new QNmeaSatelliteInfoSourcePrivate(this, mode)) -{ -} - -/*! - Destroys the satellite information source. -*/ -QNmeaSatelliteInfoSource::~QNmeaSatelliteInfoSource() -{ - delete d; -} - -/*! - Returns the update mode. -*/ -QNmeaSatelliteInfoSource::UpdateMode QNmeaSatelliteInfoSource::updateMode() const -{ - return d->m_updateMode; -} - -/*! - Sets the NMEA data source to \a device. If the device is not open, it - will be opened in QIODevice::ReadOnly mode. - - The source device can only be set once and must be set before calling - \l startUpdates() or \l requestUpdate(). - - \note The \a device must emit \l {QIODevice::readyRead()} for the - source to be notified when data is available for reading. - \l QNmeaSatelliteInfoSource does not assume the ownership of the device, - and hence does not deallocate it upon destruction. -*/ -void QNmeaSatelliteInfoSource::setDevice(QIODevice *device) -{ - if (device != d->m_device) { - if (!d->m_device) - d->m_device = device; - else - qWarning("QNmeaSatelliteInfoSource: source device has already been set"); - } -} - -/*! - Returns the NMEA data source. -*/ -QIODevice *QNmeaSatelliteInfoSource::device() const -{ - return d->m_device; -} - -/*! - \reimp -*/ -void QNmeaSatelliteInfoSource::setUpdateInterval(int msec) -{ - int interval = msec; - if (interval != 0) - interval = qMax(msec, minimumUpdateInterval()); - QGeoSatelliteInfoSource::setUpdateInterval(interval); - if (d->m_invokedStart) { - d->stopUpdates(); - d->startUpdates(); - } -} - -/*! - \reimp -*/ -int QNmeaSatelliteInfoSource::minimumUpdateInterval() const -{ - return 2; // Some chips are capable of over 100 updates per seconds. -} - -/*! - \reimp -*/ -QGeoSatelliteInfoSource::Error QNmeaSatelliteInfoSource::error() const -{ - return d->m_satelliteError; -} - -/*! - \reimp -*/ -bool QNmeaSatelliteInfoSource::setBackendProperty(const QString &name, const QVariant &value) -{ - if (name == SimulationUpdateInterval && d->m_updateMode == UpdateMode::SimulationMode) { - bool ok = false; - const int interval = value.toInt(&ok); - if (ok) { - auto *reader = dynamic_cast<QNmeaSatelliteSimulationReader *>(d->m_nmeaReader.get()); - if (reader) { - reader->setUpdateInterval(interval); - } else { - // d->m_nmeaReader will use it in constructor - d->m_simulationUpdateInterval = interval; - } - return true; - } - } - return false; -} - -/*! - \reimp -*/ -QVariant QNmeaSatelliteInfoSource::backendProperty(const QString &name) const -{ - if (name == SimulationUpdateInterval && d->m_updateMode == UpdateMode::SimulationMode) { - auto *reader = dynamic_cast<QNmeaSatelliteSimulationReader *>(d->m_nmeaReader.get()); - if (reader) - return reader->updateInterval(); - else - return d->m_simulationUpdateInterval; - } - return QVariant(); -} - -/*! - \reimp -*/ -void QNmeaSatelliteInfoSource::startUpdates() -{ - d->startUpdates(); -} - -/*! - \reimp -*/ -void QNmeaSatelliteInfoSource::stopUpdates() -{ - d->stopUpdates(); -} - -/*! - \reimp -*/ -void QNmeaSatelliteInfoSource::requestUpdate(int msec) -{ - d->requestUpdate(msec == 0 ? 60000 * 5 : msec); // 5min default timeout -} - -/*! - Parses an NMEA sentence string to extract the IDs of satelites in use. - - The default implementation will parse standard NMEA $GPGSA sentences. - This method should be reimplemented in a subclass whenever the need to deal - with non-standard NMEA sentences arises. - - The parser reads \a size bytes from \a data and uses that information to - fill \a pnrsInUse list. - - Returns system type if the sentence was successfully parsed, otherwise - returns \l QGeoSatelliteInfo::Undefined and should not modifiy \a pnrsInUse. -*/ -QGeoSatelliteInfo::SatelliteSystem -QNmeaSatelliteInfoSource::parseSatellitesInUseFromNmea(const char *data, int size, - QList<int> &pnrsInUse) -{ - return QLocationUtils::getSatInUseFromNmea(data, size, pnrsInUse); -} - -/*! - \enum QNmeaSatelliteInfoSource::SatelliteInfoParseStatus - Defines the parse status of satellite information. The satellite information - can be split into multiple sentences, and we need to parse all of them. - \value NotParsed The data does not contain information about satellites. - \value PartiallyParsed A valid satellite information is received and parsed, - but it's not complete, so we need to wait for another NMEA sentence. - \value FullyParsed Satellite information was fully collected and parsed. -*/ - -/*! - Parses an NMEA sentence string to extract the information about satellites - in view. - - The default implementation will parse standard NMEA $GPGSV sentences. - This method should be reimplemented in a subclass whenever the need to deal - with non-standard NMEA sentences arises. - - The parser reads \a size bytes from \a data and uses that information to - fill \a infos list. - - Returns \l SatelliteInfoParseStatus with parse result. - Modifies \a infos list in case \l {QNmeaSatelliteInfoSource::} - {PartiallyParsed} or \l {QNmeaSatelliteInfoSource::}{FullyParsed} is - returned. - Also sets the \a system to correct satellite system type. This is required - to determine the system type in case there are no satellites in view. -*/ -QNmeaSatelliteInfoSource::SatelliteInfoParseStatus -QNmeaSatelliteInfoSource::parseSatelliteInfoFromNmea(const char *data, int size, - QList<QGeoSatelliteInfo> &infos, - QGeoSatelliteInfo::SatelliteSystem &system) -{ - return static_cast<SatelliteInfoParseStatus>( - QLocationUtils::getSatInfoFromNmea(data, size, infos, system)); -} - -void QNmeaSatelliteInfoSource::setError(QGeoSatelliteInfoSource::Error satelliteError) -{ - d->m_satelliteError = satelliteError; - if (d->m_satelliteError != QGeoSatelliteInfoSource::NoError) - emit QGeoSatelliteInfoSource::errorOccurred(satelliteError); -} - -QList<QGeoSatelliteInfo> QNmeaSatelliteInfoUpdate::allSatellitesInUse() const -{ - QList<QGeoSatelliteInfo> result; - for (const auto &s : m_satellites) - result.append(s.satellitesInUse); - return result; -} - -QList<QGeoSatelliteInfo> QNmeaSatelliteInfoUpdate::allSatellitesInView() const -{ - QList<QGeoSatelliteInfo> result; - for (const auto &s : m_satellites) - result.append(s.satellitesInView); - return result; -} - -void QNmeaSatelliteInfoUpdate::setSatellitesInView(QGeoSatelliteInfo::SatelliteSystem system, - const QList<QGeoSatelliteInfo> &inView) -{ - auto &info = m_satellites[system]; - info.updatingGSV = false; - - info.satellitesInView = inView; - info.validInView = true; - - if (!info.satellitesInUseReceived) { - // Normally a GSA message should come after a GSV message. If this flag - // is not set, we have received 2 consecutive GSV messages for this - // system without a GSA in between. - // This means that we could actually receive a $GNGSA empty message for - // this specific type. As it had no ids and GN talker id, we could not - // determine system type. This most probably means that we have no - // satellites in use for this system type. - // Clear satellites in use, if any. - info.satellitesInUse.clear(); - info.inUseIds.clear(); - info.validInUse = true; - } - info.satellitesInUseReceived = false; - - if (info.satellitesInView.isEmpty()) { - // If we received an empty list of satellites in view, then the list of - // satellites in use will also be empty, so we would not be able to - // match it with correct system type in case of $GNGSA message. Clear - // the list in advance. - info.satellitesInUse.clear(); - info.inUseIds.clear(); - info.validInUse = true; - } else if (!info.inUseIds.isEmpty()) { - // We have some satellites in use cached. Check if we have received the - // proper GSV for them. - info.satellitesInUse.clear(); - info.validInUse = false; - bool corrupt = false; - for (const auto id : info.inUseIds) { - bool found = false; - for (const auto &s : info.satellitesInView) { - if (s.satelliteIdentifier() == id) { - info.satellitesInUse.append(s); - found = true; - break; - } - } - if (!found) { - // The previoulsy received GSA is incorrect or not related to - // this GSV - info.satellitesInUse.clear(); - corrupt = true; - break; - } - } - info.validInUse = !corrupt; - info.inUseIds.clear(); - } - - m_validInUse = calculateValidInUse(); - m_validInView = calculateValidInView(); - m_fresh = true; -} - -bool QNmeaSatelliteInfoUpdate::setSatellitesInUse(QGeoSatelliteInfo::SatelliteSystem system, - const QList<int> &inUse) -{ - if (system == QGeoSatelliteInfo::Undefined || system == QGeoSatelliteInfo::Multiple) - return false; // No way to determine satellite system - - SatelliteInfo &info = m_satellites[system]; - info.satellitesInUse.clear(); - - info.satellitesInUseReceived = true; - info.inUseIds = inUse; - - if (info.updatingGSV) { - info.validInView = false; - m_validInView = false; - return false; - } - - for (const auto id : inUse) { - bool found = false; - for (const auto &s : info.satellitesInView) { - if (s.satelliteIdentifier() == id) { - info.satellitesInUse.append(s); - found = true; - break; - } - } - if (!found) { - // satellites in use are not in view -> related GSV is not yet received - info.satellitesInView.clear(); - info.validInView = false; - m_validInView = false; - return false; - } - } - - info.inUseIds.clear(); // make sure we remove all obsolete cache - - info.validInUse = true; - m_fresh = true; - m_validInUse = calculateValidInUse(); - - return true; -} - -void QNmeaSatelliteInfoUpdate::consume() -{ - m_fresh = false; -} - -bool QNmeaSatelliteInfoUpdate::isFresh() const -{ - return m_fresh; -} - -void QNmeaSatelliteInfoUpdate::clear() -{ - m_satellites.clear(); - m_satellitesInViewParsed.clear(); - m_validInView = false; - m_validInUse = false; - m_fresh = false; -#if USE_NMEA_PIMPL - gsa.clear(); - gsv.clear(); -#endif -} - -bool QNmeaSatelliteInfoUpdate::isValid() const -{ - // GSV without GSA is valid. GSA with outdated but still matching GSV also valid. - return m_validInView || m_validInUse; -} - -bool QNmeaSatelliteInfoUpdate::calculateValidInUse() const -{ - for (const auto &s : m_satellites) { - if (!s.validInUse) - return false; - } - return true; -} - -bool QNmeaSatelliteInfoUpdate::calculateValidInView() const -{ - for (const auto &s : m_satellites) { - if (!s.validInView) - return false; - } - return true; -} - -QNmeaSatelliteReader::QNmeaSatelliteReader(QNmeaSatelliteInfoSourcePrivate *sourcePrivate) - : m_proxy(sourcePrivate) -{ -} - -QNmeaSatelliteReader::~QNmeaSatelliteReader() -{ -} - -QNmeaSatelliteRealTimeReader::QNmeaSatelliteRealTimeReader(QNmeaSatelliteInfoSourcePrivate *sourcePrivate) - : QNmeaSatelliteReader(sourcePrivate) -{ -} - -void QNmeaSatelliteRealTimeReader::readAvailableData() -{ - while (m_proxy->m_device->canReadLine()) - m_proxy->processNmeaData(m_proxy->m_pendingUpdate); - m_proxy->notifyNewUpdate(); -} - -QNmeaSatelliteSimulationReader::QNmeaSatelliteSimulationReader(QNmeaSatelliteInfoSourcePrivate *sourcePrivate) - : QNmeaSatelliteReader(sourcePrivate) -{ - m_timer.reset(new QTimer); - QObject::connect(m_timer.get(), &QTimer::timeout, [this]() { - readAvailableData(); - }); - m_updateInterval = - qMax(m_proxy->m_simulationUpdateInterval, m_proxy->m_source->minimumUpdateInterval()); -} - -void QNmeaSatelliteSimulationReader::readAvailableData() -{ - if (!m_timer->isActive()) { - // At the very first start we just start a timer to simulate a short - // delay for overlapping requestUpdate() calls. - // See TestQGeoSatelliteInfoSource::requestUpdate_overlappingCalls and - // TestQGeoSatelliteInfoSource::requestUpdate_overlappingCallsWithTimeout - m_timer->start(m_updateInterval); - } else { - // Here we try to get both satellites in view and satellites in use. - // We behave like that because according to the QGeoSatelliteInfoSource - // tests each call to requestUpdate() should return both satellites in - // view and satellites in use. Same is expected on each interval for - // startUpdates(). - // However user-provided NMEA logs might not contain some of the - // messages, so we will try not to get stuck here infinitely. - int numSatInUseMsgs = 0; - int numSatInViewMsgs = 0; - while (!numSatInUseMsgs || !numSatInViewMsgs) { - m_proxy->processNmeaData(m_proxy->m_pendingUpdate); - if (m_proxy->m_pendingUpdate.m_validInUse) - numSatInUseMsgs++; - if (m_proxy->m_pendingUpdate.m_validInView) - numSatInViewMsgs++; - // if we got the second message for one of them, but still didn't - // receive any for the other - break. - // We use 2 in the comparison, because, as soon as the m_validIn* - // flag is set, it will stay true until we receive invalid message. - if (numSatInUseMsgs > 2 || numSatInViewMsgs > 2) { - const QString msgType = (numSatInUseMsgs > numSatInViewMsgs) - ? QStringLiteral("GSA") - : QStringLiteral("GSV"); - qWarning() << "nmea simulation reader: possibly incorrect message order. Got too " - "many consecutive" - << msgType << "messages"; - break; - } - } - m_proxy->notifyNewUpdate(); - } -} - -void QNmeaSatelliteSimulationReader::setUpdateInterval(int msec) -{ - // restart the timer with new interval - m_updateInterval = qMax(msec, m_proxy->m_source->minimumUpdateInterval()); - if (m_timer->isActive()) - m_timer->start(m_updateInterval); -} - -int QNmeaSatelliteSimulationReader::updateInterval() const -{ - return m_updateInterval; -} - -QT_END_NAMESPACE |