Ref T129, formatting VATSIM data reader and minor tweaks

This commit is contained in:
Klaus Basan
2017-10-01 03:38:34 +02:00
committed by Mathew Sutcliffe
parent 3b842679e7
commit 21f80ca2e3
2 changed files with 46 additions and 44 deletions

View File

@@ -12,9 +12,8 @@
#include "blackmisc/aviation/aircraftsituation.h" #include "blackmisc/aviation/aircraftsituation.h"
#include "blackmisc/aviation/altitude.h" #include "blackmisc/aviation/altitude.h"
#include "blackmisc/aviation/atcstation.h" #include "blackmisc/aviation/atcstation.h"
#include "blackmisc/compare.h" #include "blackmisc/aviation/flightplanutils.h"
#include "blackmisc/geo/coordinategeodetic.h" #include "blackmisc/geo/coordinategeodetic.h"
#include "blackmisc/logmessage.h"
#include "blackmisc/network/entityflags.h" #include "blackmisc/network/entityflags.h"
#include "blackmisc/network/server.h" #include "blackmisc/network/server.h"
#include "blackmisc/network/url.h" #include "blackmisc/network/url.h"
@@ -24,6 +23,8 @@
#include "blackmisc/pq/length.h" #include "blackmisc/pq/length.h"
#include "blackmisc/pq/speed.h" #include "blackmisc/pq/speed.h"
#include "blackmisc/pq/units.h" #include "blackmisc/pq/units.h"
#include "blackmisc/logmessage.h"
#include "blackmisc/compare.h"
#include "blackmisc/predicates.h" #include "blackmisc/predicates.h"
#include "blackmisc/range.h" #include "blackmisc/range.h"
#include "blackmisc/simulation/simulatedaircraft.h" #include "blackmisc/simulation/simulatedaircraft.h"
@@ -59,24 +60,24 @@ namespace BlackCore
CVatsimDataFileReader::CVatsimDataFileReader(QObject *owner) : CVatsimDataFileReader::CVatsimDataFileReader(QObject *owner) :
CThreadedReader(owner, "CVatsimDataFileReader") CThreadedReader(owner, "CVatsimDataFileReader")
{ {
reloadSettings(); this->reloadSettings();
} }
CSimulatedAircraftList CVatsimDataFileReader::getAircraft() const CSimulatedAircraftList CVatsimDataFileReader::getAircraft() const
{ {
QReadLocker rl(&this->m_lock); QReadLocker rl(&m_lock);
return this->m_aircraft; return m_aircraft;
} }
CAtcStationList CVatsimDataFileReader::getAtcStations() const CAtcStationList CVatsimDataFileReader::getAtcStations() const
{ {
QReadLocker rl(&this->m_lock); QReadLocker rl(&m_lock);
return this->m_atcStations; return m_atcStations;
} }
CAtcStationList CVatsimDataFileReader::getAtcStationsForCallsign(const CCallsign &callsign) const CAtcStationList CVatsimDataFileReader::getAtcStationsForCallsign(const CCallsign &callsign) const
{ {
CCallsignSet cs({callsign}); const CCallsignSet cs({callsign});
return this->getAtcStationsForCallsigns(cs); return this->getAtcStationsForCallsigns(cs);
} }
@@ -87,12 +88,12 @@ namespace BlackCore
CServerList CVatsimDataFileReader::getVoiceServers() const CServerList CVatsimDataFileReader::getVoiceServers() const
{ {
return this->m_lastGoodSetup.get().getVoiceServers(); return m_lastGoodSetup.get().getVoiceServers();
} }
CServerList CVatsimDataFileReader::getFsdServers() const CServerList CVatsimDataFileReader::getFsdServers() const
{ {
return this->m_lastGoodSetup.get().getFsdServers(); return m_lastGoodSetup.get().getFsdServers();
} }
CUserList CVatsimDataFileReader::getPilotsForCallsigns(const CCallsignSet &callsigns) CUserList CVatsimDataFileReader::getPilotsForCallsigns(const CCallsignSet &callsigns)
@@ -102,35 +103,36 @@ namespace BlackCore
CUserList CVatsimDataFileReader::getPilotsForCallsign(const CCallsign &callsign) CUserList CVatsimDataFileReader::getPilotsForCallsign(const CCallsign &callsign)
{ {
CCallsignSet callsigns({callsign}); const CCallsignSet callsigns({callsign});
return this->getPilotsForCallsigns(callsigns); return this->getPilotsForCallsigns(callsigns);
} }
CAirlineIcaoCode CVatsimDataFileReader::getAirlineIcaoCode(const CCallsign &callsign) CAirlineIcaoCode CVatsimDataFileReader::getAirlineIcaoCode(const CCallsign &callsign)
{ {
CSimulatedAircraft aircraft = this->getAircraft().findFirstByCallsign(callsign); const CSimulatedAircraft aircraft = this->getAircraft().findFirstByCallsign(callsign);
return aircraft.getAirlineIcaoCode(); return aircraft.getAirlineIcaoCode();
} }
CAircraftIcaoCode CVatsimDataFileReader::getAircraftIcaoCode(const CCallsign &callsign) CAircraftIcaoCode CVatsimDataFileReader::getAircraftIcaoCode(const CCallsign &callsign)
{ {
CSimulatedAircraft aircraft = this->getAircraft().findFirstByCallsign(callsign); const CSimulatedAircraft aircraft = this->getAircraft().findFirstByCallsign(callsign);
return aircraft.getAircraftIcaoCode(); return aircraft.getAircraftIcaoCode();
} }
CVoiceCapabilities CVatsimDataFileReader::getVoiceCapabilityForCallsign(const CCallsign &callsign) CVoiceCapabilities CVatsimDataFileReader::getVoiceCapabilityForCallsign(const CCallsign &callsign)
{ {
QReadLocker rl(&this->m_lock); if (callsign.isEmpty()) { return CVoiceCapabilities(); }
return (this->m_voiceCapabilities.contains(callsign)) ? QReadLocker rl(&m_lock);
return m_voiceCapabilities.contains(callsign) ?
m_voiceCapabilities[callsign] : m_voiceCapabilities[callsign] :
CVoiceCapabilities::fromVoiceCapabilities(CVoiceCapabilities::Unknown); CVoiceCapabilities::fromVoiceCapabilities(CVoiceCapabilities::Unknown);
} }
QString CVatsimDataFileReader::getFlightPlanRemarksForCallsign(const CCallsign &callsign) QString CVatsimDataFileReader::getFlightPlanRemarksForCallsign(const CCallsign &callsign)
{ {
QReadLocker rl(&this->m_lock); if (callsign.isEmpty()) { return QString(); }
return (this->m_flightPlanRemarks.contains(callsign)) ? QReadLocker rl(&m_lock);
m_flightPlanRemarks[callsign] : ""; return m_flightPlanRemarks.value(callsign);
} }
void CVatsimDataFileReader::updateWithVatsimDataFileData(CSimulatedAircraft &aircraftToBeUdpated) const void CVatsimDataFileReader::updateWithVatsimDataFileData(CSimulatedAircraft &aircraftToBeUdpated) const
@@ -140,7 +142,7 @@ namespace BlackCore
CUserList CVatsimDataFileReader::getControllersForCallsign(const CCallsign &callsign) CUserList CVatsimDataFileReader::getControllersForCallsign(const CCallsign &callsign)
{ {
CCallsignSet cs({callsign}); const CCallsignSet cs({callsign});
return this->getControllersForCallsigns(cs); return this->getControllersForCallsigns(cs);
} }
@@ -151,7 +153,7 @@ namespace BlackCore
CUserList CVatsimDataFileReader::getUsersForCallsign(const CCallsign &callsign) CUserList CVatsimDataFileReader::getUsersForCallsign(const CCallsign &callsign)
{ {
CCallsignSet callsigns({callsign}); const CCallsignSet callsigns({callsign});
return this->getUsersForCallsigns(callsigns); return this->getUsersForCallsigns(callsigns);
} }
@@ -169,14 +171,14 @@ namespace BlackCore
void CVatsimDataFileReader::readInBackgroundThread() void CVatsimDataFileReader::readInBackgroundThread()
{ {
bool s = QMetaObject::invokeMethod(this, "ps_read"); const bool s = QMetaObject::invokeMethod(this, "ps_read");
Q_ASSERT_X(s, Q_FUNC_INFO, "Invoke failed"); Q_ASSERT_X(s, Q_FUNC_INFO, "Invoke failed");
Q_UNUSED(s); Q_UNUSED(s);
} }
void CVatsimDataFileReader::doWorkImpl() void CVatsimDataFileReader::doWorkImpl()
{ {
ps_read(); this->ps_read();
} }
void CVatsimDataFileReader::ps_read() void CVatsimDataFileReader::ps_read()
@@ -393,21 +395,21 @@ namespace BlackCore
// this part needs to be synchronized // this part needs to be synchronized
{ {
QWriteLocker wl(&this->m_lock); QWriteLocker wl(&m_lock);
this->setUpdateTimestamp(updateTimestampFromFile); this->setUpdateTimestamp(updateTimestampFromFile);
this->m_aircraft = aircraft; m_aircraft = aircraft;
this->m_atcStations = atcStations; m_atcStations = atcStations;
this->m_voiceCapabilities = voiceCapabilitiesMap; m_voiceCapabilities = voiceCapabilitiesMap;
this->m_flightPlanRemarks = flightPlanRemarksMap; m_flightPlanRemarks = flightPlanRemarksMap;
} }
// update cache itself is thread safe // update cache itself is thread safe
CVatsimSetup vs(this->m_lastGoodSetup.get()); CVatsimSetup vs(m_lastGoodSetup.get());
const bool changedSetup = vs.setServers(fsdServers, voiceServers); const bool changedSetup = vs.setServers(fsdServers, voiceServers);
if (changedSetup) if (changedSetup)
{ {
vs.setUtcTimestamp(updateTimestampFromFile); vs.setUtcTimestamp(updateTimestampFromFile);
this->m_lastGoodSetup.set(vs); m_lastGoodSetup.set(vs);
} }
// warnings, if required // warnings, if required

View File

@@ -17,14 +17,13 @@
#include "blackmisc/aviation/aircrafticaocode.h" #include "blackmisc/aviation/aircrafticaocode.h"
#include "blackmisc/aviation/airlineicaocode.h" #include "blackmisc/aviation/airlineicaocode.h"
#include "blackmisc/aviation/atcstationlist.h" #include "blackmisc/aviation/atcstationlist.h"
#include "blackmisc/aviation/callsign.h"
#include "blackmisc/aviation/callsignset.h" #include "blackmisc/aviation/callsignset.h"
#include "blackmisc/datacache.h"
#include "blackmisc/network/entityflags.h" #include "blackmisc/network/entityflags.h"
#include "blackmisc/network/serverlist.h" #include "blackmisc/network/serverlist.h"
#include "blackmisc/network/userlist.h" #include "blackmisc/network/userlist.h"
#include "blackmisc/network/voicecapabilities.h" #include "blackmisc/network/voicecapabilities.h"
#include "blackmisc/simulation/simulatedaircraftlist.h" #include "blackmisc/simulation/simulatedaircraftlist.h"
#include "blackmisc/datacache.h"
#include "blackcore/threadedreader.h" #include "blackcore/threadedreader.h"
#include <QMap> #include <QMap>
@@ -141,19 +140,6 @@ namespace BlackCore
void ps_read(); void ps_read();
private: private:
void reloadSettings();
BlackMisc::Aviation::CAtcStationList m_atcStations;
BlackMisc::Simulation::CSimulatedAircraftList m_aircraft;
BlackMisc::CData<BlackCore::Data::TVatsimSetup> m_lastGoodSetup { this };
BlackMisc::CSettingReadOnly<BlackCore::Vatsim::TVatsimDataFile> m_settings { this, &CVatsimDataFileReader::reloadSettings };
QMap<BlackMisc::Aviation::CCallsign, BlackMisc::Network::CVoiceCapabilities> m_voiceCapabilities; //!< voice capabilities
QMap<BlackMisc::Aviation::CCallsign, QString> m_flightPlanRemarks; //!< cache for flight plan remarks
//! Split line and assign values to their corresponding attribute names
//! \remark attributes expected as lower case
static const QMap<QString, QString> clientPartsToMap(const QString &currentLine, const QStringList &clientSectionAttributes);
//! Section in file //! Section in file
enum Section enum Section
{ {
@@ -164,6 +150,20 @@ namespace BlackCore
SectionGeneral SectionGeneral
}; };
BlackMisc::Aviation::CAtcStationList m_atcStations;
BlackMisc::Simulation::CSimulatedAircraftList m_aircraft;
BlackMisc::CData<BlackCore::Data::TVatsimSetup> m_lastGoodSetup { this };
BlackMisc::CSettingReadOnly<BlackCore::Vatsim::TVatsimDataFile> m_settings { this, &CVatsimDataFileReader::reloadSettings };
QMap<BlackMisc::Aviation::CCallsign, BlackMisc::Network::CVoiceCapabilities> m_voiceCapabilities; //!< voice capabilities
QMap<BlackMisc::Aviation::CCallsign, QString> m_flightPlanRemarks; //!< cache for flight plan remarks
//! Reload the reader settings
void reloadSettings();
//! Split line and assign values to their corresponding attribute names
//! \remark attributes expected as lower case
static const QMap<QString, QString> clientPartsToMap(const QString &currentLine, const QStringList &clientSectionAttributes);
//! Get current section //! Get current section
static Section currentLineToSection(const QString &currentLine); static Section currentLineToSection(const QString &currentLine);
}; };