Ref T632, mix fixes

* avoid empty callsign CClient object (harmless, but stupid)
* better validations in client provider
* check aircraft config packets (really broadcasts)
This commit is contained in:
Klaus Basan
2019-04-24 13:38:00 +02:00
parent eb89273104
commit a1490fd4e0
3 changed files with 29 additions and 5 deletions

View File

@@ -1070,9 +1070,12 @@ namespace BlackCore
{ {
Q_ASSERT(CThreadUtils::isCurrentThreadObjectThread(this)); Q_ASSERT(CThreadUtils::isCurrentThreadObjectThread(this));
this->storeAircraftParts(callsign, jsonObject, currentOffsetMs); this->storeAircraftParts(callsign, jsonObject, currentOffsetMs);
BLACK_AUDIT_X(!callsign.isEmpty(), Q_FUNC_INFO, "Need callsign");
if (callsign.isEmpty()) { return; }
// update client capability // update client capability
CClient client = this->getClientOrDefaultForCallsign(callsign); CClient client = this->getClientOrDefaultForCallsign(callsign);
client.setUserCallsign(callsign); // make valid by setting a callsign
if (client.hasCapability(CClient::FsdWithAircraftConfig)) { return; } if (client.hasCapability(CClient::FsdWithAircraftConfig)) { return; }
client.addCapability(CClient::FsdWithAircraftConfig); client.addCapability(CClient::FsdWithAircraftConfig);
this->setOtherClient(client); this->setOtherClient(client);

View File

@@ -8,6 +8,7 @@
#include "clientprovider.h" #include "clientprovider.h"
#include "blackmisc/aviation/aircraftsituation.h" #include "blackmisc/aviation/aircraftsituation.h"
#include "blackmisc/verify.h"
using namespace BlackMisc::Aviation; using namespace BlackMisc::Aviation;
@@ -40,17 +41,25 @@ namespace BlackMisc
CClientList CClientProvider::getClientsForCallsigns(const CCallsignSet &callsigns) const CClientList CClientProvider::getClientsForCallsigns(const CCallsignSet &callsigns) const
{ {
if (callsigns.isEmpty()) { return {}; }
return this->getClients().findByCallsigns(callsigns); return this->getClients().findByCallsigns(callsigns);
} }
CClient CClientProvider::getClientOrDefaultForCallsign(const CCallsign &callsign) const CClient CClientProvider::getClientOrDefaultForCallsign(const CCallsign &callsign) const
{ {
QReadLocker l(&m_lockClient); if (callsign.isEmpty()) { return {}; }
return m_clients.value(callsign); {
QReadLocker l(&m_lockClient);
if (m_clients.contains(callsign)) { return m_clients.value(callsign); }
}
return CClient();
} }
bool CClientProvider::setOtherClient(const CClient &client) bool CClientProvider::setOtherClient(const CClient &client)
{ {
const bool hasCallsign = !client.getCallsign().isEmpty();
BLACK_VERIFY_X(hasCallsign, Q_FUNC_INFO, "Need callsign in client");
if (!hasCallsign) { return false; }
QWriteLocker l(&m_lockClient); QWriteLocker l(&m_lockClient);
m_clients[client.getCallsign()] = client; m_clients[client.getCallsign()] = client;
return true; return true;
@@ -58,6 +67,7 @@ namespace BlackMisc
bool CClientProvider::hasClientInfo(const CCallsign &callsign) const bool CClientProvider::hasClientInfo(const CCallsign &callsign) const
{ {
if (callsign.isEmpty()) { return false; }
QReadLocker l(&m_lockClient); QReadLocker l(&m_lockClient);
return m_clients.contains(callsign); return m_clients.contains(callsign);
} }
@@ -65,7 +75,8 @@ namespace BlackMisc
bool CClientProvider::addNewClient(const CClient &client) bool CClientProvider::addNewClient(const CClient &client)
{ {
const CCallsign callsign = client.getCallsign(); const CCallsign callsign = client.getCallsign();
Q_ASSERT_X(!callsign.isEmpty(), Q_FUNC_INFO, "invalid callsign"); BLACK_VERIFY_X(!callsign.isEmpty(), Q_FUNC_INFO, "Missing client callsign");
if (callsign.isEmpty()) { return false; }
if (this->hasClientInfo(callsign)) { return false; } if (this->hasClientInfo(callsign)) { return false; }
QWriteLocker l(&m_lockClient); QWriteLocker l(&m_lockClient);
m_clients[callsign] = client; m_clients[callsign] = client;
@@ -74,7 +85,8 @@ namespace BlackMisc
int CClientProvider::updateOrAddClient(const CCallsign &callsign, const CPropertyIndexVariantMap &vm, bool skipEqualValues) int CClientProvider::updateOrAddClient(const CCallsign &callsign, const CPropertyIndexVariantMap &vm, bool skipEqualValues)
{ {
Q_ASSERT_X(!callsign.isEmpty(), Q_FUNC_INFO, "Missing callsign"); BLACK_VERIFY_X(!callsign.isEmpty(), Q_FUNC_INFO, "Missing client callsign");
if (callsign.isEmpty()) { return 0; }
int c = 0; int c = 0;
if (this->hasClientInfo(callsign)) if (this->hasClientInfo(callsign))
{ {
@@ -113,6 +125,9 @@ namespace BlackMisc
bool CClientProvider::setClientGndCapability(const CCallsign &callsign, bool supportGndFlag) bool CClientProvider::setClientGndCapability(const CCallsign &callsign, bool supportGndFlag)
{ {
BLACK_VERIFY_X(!callsign.isEmpty(), Q_FUNC_INFO, "Missing client callsign");
if (callsign.isEmpty()) { return 0; }
CClient client = this->getClientOrDefaultForCallsign(callsign); CClient client = this->getClientOrDefaultForCallsign(callsign);
// need to change? // need to change?
@@ -133,6 +148,7 @@ namespace BlackMisc
void CClientProvider::markAsSwiftClient(const CCallsign &callsign) void CClientProvider::markAsSwiftClient(const CCallsign &callsign)
{ {
if (callsign.isEmpty()) { return; }
QWriteLocker l(&m_lockClient); QWriteLocker l(&m_lockClient);
if (!m_clients.contains(callsign)) { return; } if (!m_clients.contains(callsign)) { return; }
m_clients[callsign].setSwiftClient(true); m_clients[callsign].setSwiftClient(true);

View File

@@ -402,9 +402,14 @@ namespace BlackMisc
{ {
const CSimulatedAircraft remoteAircraft(this->getAircraftInRangeForCallsign(callsign)); const CSimulatedAircraft remoteAircraft(this->getAircraftInRangeForCallsign(callsign));
const bool isFull = jsonObject.value(CAircraftParts::attributeNameIsFullJson()).toBool(); const bool isFull = jsonObject.value(CAircraftParts::attributeNameIsFullJson()).toBool();
const bool validCs = remoteAircraft.hasValidCallsign();
if (!validCs)
{
if (!isFull) { return; } // incremental parts broadcasting
return; // suspicious
}
// If we are not yet synchronized, we throw away any incremental packet // If we are not yet synchronized, we throw away any incremental packet
if (!remoteAircraft.hasValidCallsign()) { return; }
if (!remoteAircraft.isPartsSynchronized() && !isFull) { return; } if (!remoteAircraft.isPartsSynchronized() && !isFull) { return; }
CAircraftParts parts; CAircraftParts parts;