From d7b1852164cf1db401393524e9c956da2818e4a0 Mon Sep 17 00:00:00 2001 From: Brad Davis Date: Mon, 16 Mar 2015 15:25:44 -0700 Subject: [PATCH 1/7] Creating eachMatchingNode and using it in avatar mixer --- assignment-client/src/avatars/AvatarMixer.cpp | 44 ++++++++++++++----- libraries/networking/src/LimitedNodeList.h | 13 +++++- 2 files changed, 45 insertions(+), 12 deletions(-) diff --git a/assignment-client/src/avatars/AvatarMixer.cpp b/assignment-client/src/avatars/AvatarMixer.cpp index 9616c8cb21..a6420c357a 100644 --- a/assignment-client/src/avatars/AvatarMixer.cpp +++ b/assignment-client/src/avatars/AvatarMixer.cpp @@ -119,12 +119,24 @@ void AvatarMixer::broadcastAvatarData() { auto nodeList = DependencyManager::get(); - AvatarMixerClientData* nodeData = NULL; - AvatarMixerClientData* otherNodeData = NULL; - - nodeList->eachNode([&](const SharedNodePointer& node) { - if (node->getLinkedData() && node->getType() == NodeType::Agent && node->getActiveSocket() - && (nodeData = reinterpret_cast(node->getLinkedData()))->getMutex().tryLock()) { + nodeList->eachMatchingNode( + [&](const SharedNodePointer& node)->bool { + if (!node->getLinkedData()) { + return false; + } + if (node->getType() != NodeType::Agent) { + return false; + } + if (!node->getActiveSocket()) { + return false; + } + return true; + }, + [&](const SharedNodePointer& node) { + AvatarMixerClientData* nodeData = reinterpret_cast(node->getLinkedData()); + if (!nodeData->getMutex().tryLock()) { + return; + } ++_sumListeners; // reset packet pointers for this node @@ -135,9 +147,21 @@ void AvatarMixer::broadcastAvatarData() { // this is an AGENT we have received head data from // send back a packet with other active node data to this node - nodeList->eachNode([&](const SharedNodePointer& otherNode) { - if (otherNode->getLinkedData() && otherNode->getUUID() != node->getUUID() - && (otherNodeData = reinterpret_cast(otherNode->getLinkedData()))->getMutex().tryLock()) { + nodeList->eachMatchingNode( + [&](const SharedNodePointer& otherNode)->bool { + if (!otherNode->getLinkedData()) { + return false; + } + if (otherNode->getUUID() == node->getUUID()) { + return false; + } + return true; + }, + [&](const SharedNodePointer& otherNode) { + AvatarMixerClientData* otherNodeData = otherNodeData = reinterpret_cast(otherNode->getLinkedData()); + if (!otherNodeData->getMutex().tryLock()) { + return; + } AvatarMixerClientData* otherNodeData = reinterpret_cast(otherNode->getLinkedData()); AvatarData& otherAvatar = otherNodeData->getAvatar(); @@ -202,13 +226,11 @@ void AvatarMixer::broadcastAvatarData() { } otherNodeData->getMutex().unlock(); - } }); nodeList->writeDatagram(mixedAvatarByteArray, node); nodeData->getMutex().unlock(); - } }); _lastFrameTimestamp = QDateTime::currentMSecsSinceEpoch(); diff --git a/libraries/networking/src/LimitedNodeList.h b/libraries/networking/src/LimitedNodeList.h index a071eced31..532e8ffcf4 100644 --- a/libraries/networking/src/LimitedNodeList.h +++ b/libraries/networking/src/LimitedNodeList.h @@ -151,7 +151,18 @@ public: functor(it->second); } } - + + template + void eachMatchingNode(PredLambda predicate, NodeLambda functor) { + QReadLocker readLock(&_nodeMutex); + + for (NodeHash::const_iterator it = _nodeHash.cbegin(); it != _nodeHash.cend(); ++it) { + if (predicate(it->second)) { + functor(it->second); + } + } + } + template void eachNodeBreakable(BreakableNodeLambda functor) { QReadLocker readLock(&_nodeMutex); From 80b5a44cc45b19614348496146f334d87bcf1d55 Mon Sep 17 00:00:00 2001 From: Brad Davis Date: Tue, 17 Mar 2015 11:49:17 -0700 Subject: [PATCH 2/7] Adding a RAII version of the mutex locker that uses tryLock instead of lock --- libraries/shared/src/TryLocker.h | 31 +++++++++++++++++++++++++++++++ 1 file changed, 31 insertions(+) create mode 100644 libraries/shared/src/TryLocker.h diff --git a/libraries/shared/src/TryLocker.h b/libraries/shared/src/TryLocker.h new file mode 100644 index 0000000000..e434ae4372 --- /dev/null +++ b/libraries/shared/src/TryLocker.h @@ -0,0 +1,31 @@ +// +// TryLocker.h +// libraries/shared/src +// +// Created by Brad Davis on 2015/03/16. +// Copyright 2015 High Fidelity, Inc. +// +// Distributed under the Apache License, Version 2.0. +// See the accompanying file LICENSE or http://www.apache.org/licenses/LICENSE-2.0.html +// + +#ifndef hifi_TryLocker_h +#define hifi_TryLocker_h + +#include + +class MutexTryLocker { + QMutex & _mutex; + bool _locked{false}; +public: + MutexTryLocker(QMutex &m) : _mutex(m) {} + ~MutexTryLocker() { if (_locked) _mutex.unlock(); } + bool tryLock() { + if (_locked) { + return true; + } + return (_locked = _mutex.tryLock()); + } +} + +#endif // hifi_UUID_h From 6415ff99f61d9004e85632631bf7f7a4d2841284 Mon Sep 17 00:00:00 2001 From: Brad Davis Date: Tue, 17 Mar 2015 12:04:04 -0700 Subject: [PATCH 3/7] Work in progress --- assignment-client/src/avatars/AvatarMixer.cpp | 131 +++++++++--------- libraries/networking/src/BandwidthRecorder.h | 1 - libraries/networking/src/LimitedNodeList.cpp | 6 +- libraries/networking/src/NetworkPeer.cpp | 37 ++++- libraries/networking/src/NetworkPeer.h | 6 + libraries/shared/src/TryLocker.h | 9 +- 6 files changed, 115 insertions(+), 75 deletions(-) diff --git a/assignment-client/src/avatars/AvatarMixer.cpp b/assignment-client/src/avatars/AvatarMixer.cpp index a6420c357a..bd0239cdc8 100644 --- a/assignment-client/src/avatars/AvatarMixer.cpp +++ b/assignment-client/src/avatars/AvatarMixer.cpp @@ -20,9 +20,9 @@ #include #include #include +#include #include "AvatarMixerClientData.h" - #include "AvatarMixer.h" const QString AVATAR_MIXER_LOGGING_NAME = "avatar-mixer"; @@ -134,7 +134,8 @@ void AvatarMixer::broadcastAvatarData() { }, [&](const SharedNodePointer& node) { AvatarMixerClientData* nodeData = reinterpret_cast(node->getLinkedData()); - if (!nodeData->getMutex().tryLock()) { + MutexTryLocker lock(nodeData->getMutex()); + if (!lock.tryLock()) { return; } ++_sumListeners; @@ -144,6 +145,7 @@ void AvatarMixer::broadcastAvatarData() { AvatarData& avatar = nodeData->getAvatar(); glm::vec3 myPosition = avatar.getPosition(); + float outputBandwidth = node->getBandwidthRecorder().getTotalAverageOutputKilobitsPerSecond(); // this is an AGENT we have received head data from // send back a packet with other active node data to this node @@ -155,82 +157,81 @@ void AvatarMixer::broadcastAvatarData() { if (otherNode->getUUID() == node->getUUID()) { return false; } + + // Check throttling value + if (!(_performanceThrottlingRatio == 0 || randFloat() < (1.0f - _performanceThrottlingRatio))) { + return; + } return true; }, [&](const SharedNodePointer& otherNode) { AvatarMixerClientData* otherNodeData = otherNodeData = reinterpret_cast(otherNode->getLinkedData()); - if (!otherNodeData->getMutex().tryLock()) { + MutexTryLocker lock(otherNodeData->getMutex()); + if (!lock.tryLock()) { return; } - - AvatarMixerClientData* otherNodeData = reinterpret_cast(otherNode->getLinkedData()); AvatarData& otherAvatar = otherNodeData->getAvatar(); - glm::vec3 otherPosition = otherAvatar.getPosition(); - - float distanceToAvatar = glm::length(myPosition - otherPosition); + // Decide whether to send this avatar's data based on it's distance from us // The full rate distance is the distance at which EVERY update will be sent for this avatar // at a distance of twice the full rate distance, there will be a 50% chance of sending this avatar's update const float FULL_RATE_DISTANCE = 2.0f; - - // Decide whether to send this avatar's data based on it's distance from us - if ((_performanceThrottlingRatio == 0 || randFloat() < (1.0f - _performanceThrottlingRatio)) - && (distanceToAvatar == 0.0f || randFloat() < FULL_RATE_DISTANCE / distanceToAvatar)) { - QByteArray avatarByteArray; - avatarByteArray.append(otherNode->getUUID().toRfc4122()); - avatarByteArray.append(otherAvatar.toByteArray()); - - if (avatarByteArray.size() + mixedAvatarByteArray.size() > MAX_PACKET_SIZE) { - nodeList->writeDatagram(mixedAvatarByteArray, node); - - // reset the packet - mixedAvatarByteArray.resize(numPacketHeaderBytes); - } - - // copy the avatar into the mixedAvatarByteArray packet - mixedAvatarByteArray.append(avatarByteArray); - - // if the receiving avatar has just connected make sure we send out the mesh and billboard - // for this avatar (assuming they exist) - bool forceSend = !nodeData->checkAndSetHasReceivedFirstPackets(); - - // we will also force a send of billboard or identity packet - // if either has changed in the last frame - - if (otherNodeData->getBillboardChangeTimestamp() > 0 - && (forceSend - || otherNodeData->getBillboardChangeTimestamp() > _lastFrameTimestamp - || randFloat() < BILLBOARD_AND_IDENTITY_SEND_PROBABILITY)) { - QByteArray billboardPacket = byteArrayWithPopulatedHeader(PacketTypeAvatarBillboard); - billboardPacket.append(otherNode->getUUID().toRfc4122()); - billboardPacket.append(otherNodeData->getAvatar().getBillboard()); - nodeList->writeDatagram(billboardPacket, node); - - ++_sumBillboardPackets; - } - - if (otherNodeData->getIdentityChangeTimestamp() > 0 - && (forceSend - || otherNodeData->getIdentityChangeTimestamp() > _lastFrameTimestamp - || randFloat() < BILLBOARD_AND_IDENTITY_SEND_PROBABILITY)) { - - QByteArray identityPacket = byteArrayWithPopulatedHeader(PacketTypeAvatarIdentity); - - QByteArray individualData = otherNodeData->getAvatar().identityByteArray(); - individualData.replace(0, NUM_BYTES_RFC4122_UUID, otherNode->getUUID().toRfc4122()); - identityPacket.append(individualData); - - nodeList->writeDatagram(identityPacket, node); - - ++_sumIdentityPackets; - } + glm::vec3 otherPosition = otherAvatar.getPosition(); + float distanceToAvatar = glm::length(myPosition - otherPosition); + + if (!(distanceToAvatar == 0.0f || randFloat() < FULL_RATE_DISTANCE / distanceToAvatar)) { + return; + } + + QByteArray avatarByteArray; + avatarByteArray.append(otherNode->getUUID().toRfc4122()); + avatarByteArray.append(otherAvatar.toByteArray()); + + if (avatarByteArray.size() + mixedAvatarByteArray.size() > MAX_PACKET_SIZE) { + nodeList->writeDatagram(mixedAvatarByteArray, node); + + // reset the packet + mixedAvatarByteArray.resize(numPacketHeaderBytes); + } + + // copy the avatar into the mixedAvatarByteArray packet + mixedAvatarByteArray.append(avatarByteArray); + + // if the receiving avatar has just connected make sure we send out the mesh and billboard + // for this avatar (assuming they exist) + bool forceSend = !nodeData->checkAndSetHasReceivedFirstPackets(); + + // we will also force a send of billboard or identity packet + // if either has changed in the last frame + + if (otherNodeData->getBillboardChangeTimestamp() > 0 + && (forceSend + || otherNodeData->getBillboardChangeTimestamp() > _lastFrameTimestamp + || randFloat() < BILLBOARD_AND_IDENTITY_SEND_PROBABILITY)) { + QByteArray billboardPacket = byteArrayWithPopulatedHeader(PacketTypeAvatarBillboard); + billboardPacket.append(otherNode->getUUID().toRfc4122()); + billboardPacket.append(otherNodeData->getAvatar().getBillboard()); + nodeList->writeDatagram(billboardPacket, node); + + ++_sumBillboardPackets; + } + + if (otherNodeData->getIdentityChangeTimestamp() > 0 + && (forceSend + || otherNodeData->getIdentityChangeTimestamp() > _lastFrameTimestamp + || randFloat() < BILLBOARD_AND_IDENTITY_SEND_PROBABILITY)) { + + QByteArray identityPacket = byteArrayWithPopulatedHeader(PacketTypeAvatarIdentity); + + QByteArray individualData = otherNodeData->getAvatar().identityByteArray(); + individualData.replace(0, NUM_BYTES_RFC4122_UUID, otherNode->getUUID().toRfc4122()); + identityPacket.append(individualData); + + nodeList->writeDatagram(identityPacket, node); + + ++_sumIdentityPackets; } - - otherNodeData->getMutex().unlock(); }); - nodeList->writeDatagram(mixedAvatarByteArray, node); - - nodeData->getMutex().unlock(); }); _lastFrameTimestamp = QDateTime::currentMSecsSinceEpoch(); diff --git a/libraries/networking/src/BandwidthRecorder.h b/libraries/networking/src/BandwidthRecorder.h index c22665d2cc..f87d9d4d06 100644 --- a/libraries/networking/src/BandwidthRecorder.h +++ b/libraries/networking/src/BandwidthRecorder.h @@ -17,7 +17,6 @@ #include #include #include "DependencyManager.h" -#include "Node.h" #include "SimpleMovingAverage.h" diff --git a/libraries/networking/src/LimitedNodeList.cpp b/libraries/networking/src/LimitedNodeList.cpp index 520dc650ed..98e1ed0572 100644 --- a/libraries/networking/src/LimitedNodeList.cpp +++ b/libraries/networking/src/LimitedNodeList.cpp @@ -263,8 +263,10 @@ qint64 LimitedNodeList::writeDatagram(const QByteArray& datagram, } emit dataSent(destinationNode->getType(), datagram.size()); - - return writeDatagram(datagram, *destinationSockAddr, destinationNode->getConnectionSecret()); + auto bytesWritten = writeDatagram(datagram, *destinationSockAddr, destinationNode->getConnectionSecret()); + // Keep track of per-destination-node bandwidth + destinationNode->recordBytesSent(bytesWritten); + return bytesWritten; } // didn't have a destinationNode to send to, return 0 diff --git a/libraries/networking/src/NetworkPeer.cpp b/libraries/networking/src/NetworkPeer.cpp index eaaf57471c..eb072a91f0 100644 --- a/libraries/networking/src/NetworkPeer.cpp +++ b/libraries/networking/src/NetworkPeer.cpp @@ -15,6 +15,7 @@ #include #include "NetworkPeer.h" +#include "BandwidthRecorder.h" NetworkPeer::NetworkPeer() : _uuid(), @@ -96,4 +97,38 @@ QDebug operator<<(QDebug debug, const NetworkPeer &peer) { << "- public:" << peer.getPublicSocket() << "- local:" << peer.getLocalSocket(); return debug; -} \ No newline at end of file +} + + +// FIXME this is a temporary implementation to determine if this is the right approach. +// If so, migrate the BandwidthRecorder into the NetworkPeer class +using BandwidthRecorderPtr = QSharedPointer < BandwidthRecorder > ; +static QHash PEER_BANDWIDTH; + +BandwidthRecorder & getBandwidthRecorder(const QUuid & uuid) { + if (!PEER_BANDWIDTH.count(uuid)) { + PEER_BANDWIDTH.insert(uuid, BandwidthRecorderPtr(new BandwidthRecorder())); + } + return *PEER_BANDWIDTH[uuid].data(); +} + + +void NetworkPeer::recordBytesSent(int count) { + auto & bw = getBandwidthRecorder(_uuid); + bw.updateOutboundData(0, count); +} + +void NetworkPeer::recordBytesReceived(int count) { + auto & bw = getBandwidthRecorder(_uuid); + bw.updateInboundData(0, count); +} + +float NetworkPeer::getOutboundBandwidth() { + auto & bw = getBandwidthRecorder(_uuid); + return bw.getAverageOutputKilobitsPerSecond(0); +} + +float NetworkPeer::getInboundBandwidth() { + auto & bw = getBandwidthRecorder(_uuid); + return bw.getAverageInputKilobitsPerSecond(0); +} diff --git a/libraries/networking/src/NetworkPeer.h b/libraries/networking/src/NetworkPeer.h index bb92c54eb8..5bf798d2c5 100644 --- a/libraries/networking/src/NetworkPeer.h +++ b/libraries/networking/src/NetworkPeer.h @@ -54,6 +54,12 @@ public: int getConnectionAttempts() const { return _connectionAttempts; } void incrementConnectionAttempts() { ++_connectionAttempts; } void resetConnectionAttemps() { _connectionAttempts = 0; } + + void recordBytesSent(int count); + void recordBytesReceived(int count); + + float getOutboundBandwidth(); + float getInboundBandwidth(); friend QDataStream& operator<<(QDataStream& out, const NetworkPeer& peer); friend QDataStream& operator>>(QDataStream& in, NetworkPeer& peer); diff --git a/libraries/shared/src/TryLocker.h b/libraries/shared/src/TryLocker.h index e434ae4372..c5328b3b3a 100644 --- a/libraries/shared/src/TryLocker.h +++ b/libraries/shared/src/TryLocker.h @@ -18,13 +18,10 @@ class MutexTryLocker { QMutex & _mutex; bool _locked{false}; public: - MutexTryLocker(QMutex &m) : _mutex(m) {} + MutexTryLocker(QMutex &m) : _mutex(m), _locked(m.tryLock()) {} ~MutexTryLocker() { if (_locked) _mutex.unlock(); } - bool tryLock() { - if (_locked) { - return true; - } - return (_locked = _mutex.tryLock()); + bool isLocked() { + return _locked; } } From 72957670ba14c9130e0a3e42378bbfca18857ecb Mon Sep 17 00:00:00 2001 From: Brad Davis Date: Thu, 19 Mar 2015 09:55:03 -0700 Subject: [PATCH 4/7] Some commentary --- assignment-client/src/avatars/AvatarMixer.cpp | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/assignment-client/src/avatars/AvatarMixer.cpp b/assignment-client/src/avatars/AvatarMixer.cpp index bd0239cdc8..151a9f8861 100644 --- a/assignment-client/src/avatars/AvatarMixer.cpp +++ b/assignment-client/src/avatars/AvatarMixer.cpp @@ -145,6 +145,10 @@ void AvatarMixer::broadcastAvatarData() { AvatarData& avatar = nodeData->getAvatar(); glm::vec3 myPosition = avatar.getPosition(); + // TODO use this along with the distance in the calculation of whether to send an update + // about a given otherNode to this node + // FIXME does this mean we should sort the othernodes by distance before iterating + // over them? float outputBandwidth = node->getBandwidthRecorder().getTotalAverageOutputKilobitsPerSecond(); // this is an AGENT we have received head data from From bf607e4c9cc634f6c383913c7be8ae2a1d340114 Mon Sep 17 00:00:00 2001 From: Brad Davis Date: Thu, 19 Mar 2015 15:53:16 -0700 Subject: [PATCH 5/7] Fixing indentation and usage --- assignment-client/src/avatars/AvatarMixer.cpp | 8 ++++---- libraries/shared/src/TryLocker.h | 18 +++++++++--------- 2 files changed, 13 insertions(+), 13 deletions(-) diff --git a/assignment-client/src/avatars/AvatarMixer.cpp b/assignment-client/src/avatars/AvatarMixer.cpp index 151a9f8861..176fd51eea 100644 --- a/assignment-client/src/avatars/AvatarMixer.cpp +++ b/assignment-client/src/avatars/AvatarMixer.cpp @@ -135,7 +135,7 @@ void AvatarMixer::broadcastAvatarData() { [&](const SharedNodePointer& node) { AvatarMixerClientData* nodeData = reinterpret_cast(node->getLinkedData()); MutexTryLocker lock(nodeData->getMutex()); - if (!lock.tryLock()) { + if (!lock.isLocked()) { return; } ++_sumListeners; @@ -149,7 +149,7 @@ void AvatarMixer::broadcastAvatarData() { // about a given otherNode to this node // FIXME does this mean we should sort the othernodes by distance before iterating // over them? - float outputBandwidth = node->getBandwidthRecorder().getTotalAverageOutputKilobitsPerSecond(); + float outputBandwidth = node->getOutboundBandwidth(); // this is an AGENT we have received head data from // send back a packet with other active node data to this node @@ -164,14 +164,14 @@ void AvatarMixer::broadcastAvatarData() { // Check throttling value if (!(_performanceThrottlingRatio == 0 || randFloat() < (1.0f - _performanceThrottlingRatio))) { - return; + return false; } return true; }, [&](const SharedNodePointer& otherNode) { AvatarMixerClientData* otherNodeData = otherNodeData = reinterpret_cast(otherNode->getLinkedData()); MutexTryLocker lock(otherNodeData->getMutex()); - if (!lock.tryLock()) { + if (!lock.isLocked()) { return; } AvatarData& otherAvatar = otherNodeData->getAvatar(); diff --git a/libraries/shared/src/TryLocker.h b/libraries/shared/src/TryLocker.h index c5328b3b3a..f4b90575f1 100644 --- a/libraries/shared/src/TryLocker.h +++ b/libraries/shared/src/TryLocker.h @@ -15,14 +15,14 @@ #include class MutexTryLocker { - QMutex & _mutex; - bool _locked{false}; + QMutex & _mutex; + bool _locked{ false }; public: - MutexTryLocker(QMutex &m) : _mutex(m), _locked(m.tryLock()) {} - ~MutexTryLocker() { if (_locked) _mutex.unlock(); } - bool isLocked() { - return _locked; - } -} + MutexTryLocker(QMutex &m) : _mutex(m), _locked(m.tryLock()) {} + ~MutexTryLocker() { if (_locked) _mutex.unlock(); } + bool isLocked() { + return _locked; + } +}; -#endif // hifi_UUID_h +#endif // hifi_TryLocker_h From 599fe09e75fe6b2148ef0a14b410be1aaa3b00c2 Mon Sep 17 00:00:00 2001 From: Brad Davis Date: Thu, 19 Mar 2015 17:24:58 -0700 Subject: [PATCH 6/7] type & squish --- libraries/networking/src/NetworkPeer.cpp | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/libraries/networking/src/NetworkPeer.cpp b/libraries/networking/src/NetworkPeer.cpp index eb072a91f0..c6026b3a23 100644 --- a/libraries/networking/src/NetworkPeer.cpp +++ b/libraries/networking/src/NetworkPeer.cpp @@ -102,33 +102,32 @@ QDebug operator<<(QDebug debug, const NetworkPeer &peer) { // FIXME this is a temporary implementation to determine if this is the right approach. // If so, migrate the BandwidthRecorder into the NetworkPeer class -using BandwidthRecorderPtr = QSharedPointer < BandwidthRecorder > ; +using BandwidthRecorderPtr = QSharedPointer; static QHash PEER_BANDWIDTH; -BandwidthRecorder & getBandwidthRecorder(const QUuid & uuid) { +BandwidthRecorder& getBandwidthRecorder(const QUuid & uuid) { if (!PEER_BANDWIDTH.count(uuid)) { PEER_BANDWIDTH.insert(uuid, BandwidthRecorderPtr(new BandwidthRecorder())); } return *PEER_BANDWIDTH[uuid].data(); } - void NetworkPeer::recordBytesSent(int count) { - auto & bw = getBandwidthRecorder(_uuid); + auto& bw = getBandwidthRecorder(_uuid); bw.updateOutboundData(0, count); } void NetworkPeer::recordBytesReceived(int count) { - auto & bw = getBandwidthRecorder(_uuid); + auto& bw = getBandwidthRecorder(_uuid); bw.updateInboundData(0, count); } float NetworkPeer::getOutboundBandwidth() { - auto & bw = getBandwidthRecorder(_uuid); + auto& bw = getBandwidthRecorder(_uuid); return bw.getAverageOutputKilobitsPerSecond(0); } float NetworkPeer::getInboundBandwidth() { - auto & bw = getBandwidthRecorder(_uuid); + auto& bw = getBandwidthRecorder(_uuid); return bw.getAverageInputKilobitsPerSecond(0); } From 7079b5f978514277f9eb65a939fb5d2f174f5206 Mon Sep 17 00:00:00 2001 From: Brad Davis Date: Thu, 19 Mar 2015 17:29:57 -0700 Subject: [PATCH 7/7] type & squish again --- libraries/shared/src/TryLocker.h | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libraries/shared/src/TryLocker.h b/libraries/shared/src/TryLocker.h index f4b90575f1..a5c8077484 100644 --- a/libraries/shared/src/TryLocker.h +++ b/libraries/shared/src/TryLocker.h @@ -15,7 +15,7 @@ #include class MutexTryLocker { - QMutex & _mutex; + QMutex& _mutex; bool _locked{ false }; public: MutexTryLocker(QMutex &m) : _mutex(m), _locked(m.tryLock()) {}