|
|
@ -209,7 +209,11 @@ bool UDPLink::connect() |
|
|
|
connectState = socket->bind(host, port); |
|
|
|
connectState = socket->bind(host, port); |
|
|
|
|
|
|
|
|
|
|
|
emit connected(connectState); |
|
|
|
emit connected(connectState); |
|
|
|
if (connectState) emit connected(); |
|
|
|
if (connectState) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
emit connected(); |
|
|
|
|
|
|
|
connectionStartTime = MG::TIME::getGroundTimeNow(); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
start(HighPriority); |
|
|
|
start(HighPriority); |
|
|
|
return connectState; |
|
|
|
return connectState; |
|
|
@ -247,8 +251,9 @@ qint64 UDPLink::getNominalDataRate() { |
|
|
|
|
|
|
|
|
|
|
|
qint64 UDPLink::getTotalUpstream() { |
|
|
|
qint64 UDPLink::getTotalUpstream() { |
|
|
|
statisticsMutex.lock(); |
|
|
|
statisticsMutex.lock(); |
|
|
|
return bitsSentTotal / ((MG::TIME::getGroundTimeNow() - connectionStartTime) / 1000); |
|
|
|
qint64 totalUpstream = bitsSentTotal / ((MG::TIME::getGroundTimeNow() - connectionStartTime) / 1000); |
|
|
|
statisticsMutex.unlock(); |
|
|
|
statisticsMutex.unlock(); |
|
|
|
|
|
|
|
return totalUpstream; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
qint64 UDPLink::getCurrentUpstream() { |
|
|
|
qint64 UDPLink::getCurrentUpstream() { |
|
|
@ -269,8 +274,9 @@ qint64 UDPLink::getBitsReceived() { |
|
|
|
|
|
|
|
|
|
|
|
qint64 UDPLink::getTotalDownstream() { |
|
|
|
qint64 UDPLink::getTotalDownstream() { |
|
|
|
statisticsMutex.lock(); |
|
|
|
statisticsMutex.lock(); |
|
|
|
return bitsReceivedTotal / ((MG::TIME::getGroundTimeNow() - connectionStartTime) / 1000); |
|
|
|
qint64 totalDownstream = bitsReceivedTotal / ((MG::TIME::getGroundTimeNow() - connectionStartTime) / 1000); |
|
|
|
statisticsMutex.unlock(); |
|
|
|
statisticsMutex.unlock(); |
|
|
|
|
|
|
|
return totalDownstream; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
qint64 UDPLink::getCurrentDownstream() { |
|
|
|
qint64 UDPLink::getCurrentDownstream() { |
|
|
|