Revert "added locking on _singleSenderStats; untested!"

This reverts commit c542da9707.

assignment-client/src/octree/OctreeInboundPacketProcessor.cpp

@@ -25,9 +25,7 @@ OctreeInboundPacketProcessor::OctreeInboundPacketProcessor(OctreeServer* myServe
     _totalProcessTime(0),
     _totalLockWaitTime(0),
     _totalElementsInPacket(0),
-    _totalPackets(0),
-    _singleSenderStats(),
-    _singleSenderStatsLock()
+    _totalPackets(0)
 {
 }
 
@@ -38,9 +36,7 @@ void OctreeInboundPacketProcessor::resetStats() {
     _totalElementsInPacket = 0;
     _totalPackets = 0;
 
-    _singleSenderStatsLock.lockForWrite();
     _singleSenderStats.clear();
-    _singleSenderStatsLock.unlock();
 }
 
 
@@ -147,9 +143,7 @@ void OctreeInboundPacketProcessor::trackInboundPacket(const QUuid& nodeUUID, uns
     if (_singleSenderStats.find(nodeUUID) == _singleSenderStats.end()) {
         SingleSenderStats stats;
         stats.trackInboundPacket(sequence, transitTime, editsInPacket, processTime, lockWaitTime);
-        _singleSenderStatsLock.lockForWrite();
         _singleSenderStats[nodeUUID] = stats;
-        _singleSenderStatsLock.unlock();
     } else {
         SingleSenderStats& stats = _singleSenderStats[nodeUUID];
         stats.trackInboundPacket(sequence, transitTime, editsInPacket, processTime, lockWaitTime);

assignment-client/src/octree/OctreeInboundPacketProcessor.h

@@ -71,8 +71,6 @@ public:
 
     void resetStats();
 
-    void lockSingleSenderStatsForRead() { _singleSenderStatsLock.lockForRead(); }
-    void unlockSingleSenderStats() { _singleSenderStatsLock.unlock(); }
     NodeToSenderStatsMap& getSingleSenderStats() { return _singleSenderStats; }
     const NodeToSenderStatsMap& getSingleSenderStats() const { return _singleSenderStats; }
 
@@ -93,6 +91,5 @@ private:
     quint64 _totalPackets;
     
     NodeToSenderStatsMap _singleSenderStats;
-    QReadWriteLock _singleSenderStatsLock;
 };
 #endif // hifi_OctreeInboundPacketProcessor_h

assignment-client/src/octree/OctreeSendThread.cpp

@@ -120,7 +120,7 @@ int OctreeSendThread::sendNack(OctreeQueryNode* nodeData) {
         return 0;
     }
     
-    OctreeInboundPacketProcessor* myServerPacketProcessor = _myServer->getInboundPacketProcessor();
+    const OctreeInboundPacketProcessor* myServerPacketProcessor = _myServer->getInboundPacketProcessor();
 
     // if there are packets from _node that are waiting to be processed,
     // don't send a NACK since the missing packets may be among those waiting packets.
@@ -128,15 +128,18 @@ int OctreeSendThread::sendNack(OctreeQueryNode* nodeData) {
         return 0;
     }
 
-    myServerPacketProcessor->lockSingleSenderStatsForRead();
+    // lock unlock required ????????? prolly: _singleSenderStats may have our node's entry deleted during this or something
+    // maybe just make a copy instead!!
 
-    const QSet<unsigned short int>& missingSequenceNumbersFromNode = myServerPacketProcessor
+    // lock
+
+    const QSet<unsigned short int> missingSequenceNumbersFromNode = myServerPacketProcessor
         ->getSingleSenderStats().at(_node->getUUID()).getMissingSequenceNumbers();
 
     // check if there are any sequence numbers that need to be nacked
     int numSequenceNumbersAvailable = missingSequenceNumbersFromNode.size();
     if (numSequenceNumbersAvailable == 0) {
-        myServerPacketProcessor->unlockSingleSenderStats();
+        //unlock
         return 0;
     }
 
@@ -167,8 +170,6 @@ int OctreeSendThread::sendNack(OctreeQueryNode* nodeData) {
         dataAt += sizeof(unsigned short int);
     }
 
-    myServerPacketProcessor->unlockSingleSenderStats();
-
     // send it
     OctreeServer::didCallWriteDatagram(this);
     NodeList::getInstance()->writeDatagram((char*)packet, dataAt - packet, _node);

assignment-client/src/octree/OctreeServer.h

@@ -52,7 +52,7 @@ public:
     int getPacketsTotalPerInterval() const { return _packetsTotalPerInterval; }
     int getPacketsTotalPerSecond() const { return getPacketsTotalPerInterval() * INTERVALS_PER_SECOND; }
 
-    OctreeInboundPacketProcessor* getInboundPacketProcessor() { return _octreeInboundPacketProcessor; }
+    const OctreeInboundPacketProcessor* getInboundPacketProcessor() const { return _octreeInboundPacketProcessor; }
     
     static int getCurrentClientCount() { return _clientCount; }
     static void clientConnected() { _clientCount++; }