////  ReceivedPacketProcessor.cpp//  libraries/networking/src////  Created by Brad Hefta-Gaub on 8/12/13.//  Copyright 2013 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// #include "NodeList.h"#include "ReceivedPacketProcessor.h"#include "SharedUtil.h" void ReceivedPacketProcessor::terminating() {    _hasPackets.wakeAll();} void ReceivedPacketProcessor::queueReceivedPacket(const SharedNodePointer& sendingNode, const QByteArray& packet) {    // Make sure our Node and NodeList knows we've heard from this node.    sendingNode->setLastHeardMicrostamp(usecTimestampNow());     NetworkPacket networkPacket(sendingNode, packet);    lock();    _packets.push_back(networkPacket);    _nodePacketCounts[sendingNode->getUUID()]++;    unlock();        // Make sure to wake our actual processing thread because we now have packets for it to process.    _hasPackets.wakeAll();} bool ReceivedPacketProcessor::process() {     if (_packets.size() == 0) {        _waitingOnPacketsMutex.lock();        _hasPackets.wait(&_waitingOnPacketsMutex, getMaxWait());        _waitingOnPacketsMutex.unlock();    }    preProcess();    while (_packets.size() > 0) {        lock(); // lock to make sure nothing changes on us        NetworkPacket& packet = _packets.front(); // get the oldest packet        NetworkPacket temporary = packet; // make a copy of the packet in case the vector is resized on us        _packets.erase(_packets.begin()); // remove the oldest packet        if (!temporary.getNode().isNull()) {            _nodePacketCounts[temporary.getNode()->getUUID()]--;        }        unlock(); // let others add to the packets        processPacket(temporary.getNode(), temporary.getByteArray()); // process our temporary copy        midProcess();    }    postProcess();    return isStillRunning();  // keep running till they terminate us} void ReceivedPacketProcessor::nodeKilled(SharedNodePointer node) {    lock();    _nodePacketCounts.remove(node->getUUID());    unlock();}