mirror of
https://github.com/overte-org/overte.git
synced 2025-04-30 13:22:34 +02:00
15879b2832
this abstracts a portion of OctreeSendThread::packetDistributor() which will make it easier to split apart the tree traversal from the sending of packets also cleaned up some of the packet stats tracking
76 lines
2.3 KiB
C++
76 lines
2.3 KiB
C++
//
|
|
// OctreeSendThread.h
|
|
// assignment-client/src/octree
|
|
//
|
|
// Created by Brad Hefta-Gaub on 8/21/13.
|
|
// Copyright 2013 High Fidelity, Inc.
|
|
//
|
|
// Threaded or non-threaded object for sending octree data packets to a client
|
|
//
|
|
// 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_OctreeSendThread_h
|
|
#define hifi_OctreeSendThread_h
|
|
|
|
#include <atomic>
|
|
|
|
#include <GenericThread.h>
|
|
#include <Node.h>
|
|
#include <OctreePacketData.h>
|
|
|
|
class OctreeQueryNode;
|
|
class OctreeServer;
|
|
|
|
using AtomicUIntStat = std::atomic<uintmax_t>;
|
|
|
|
/// Threaded processor for sending octree packets to a single client
|
|
class OctreeSendThread : public GenericThread {
|
|
Q_OBJECT
|
|
public:
|
|
OctreeSendThread(OctreeServer* myServer, const SharedNodePointer& node);
|
|
virtual ~OctreeSendThread();
|
|
|
|
void setIsShuttingDown();
|
|
bool isShuttingDown() { return _isShuttingDown; }
|
|
|
|
QUuid getNodeUuid() const { return _nodeUuid; }
|
|
|
|
static AtomicUIntStat _totalBytes;
|
|
static AtomicUIntStat _totalWastedBytes;
|
|
static AtomicUIntStat _totalPackets;
|
|
|
|
static AtomicUIntStat _totalSpecialBytes;
|
|
static AtomicUIntStat _totalSpecialPackets;
|
|
|
|
static AtomicUIntStat _usleepTime;
|
|
static AtomicUIntStat _usleepCalls;
|
|
|
|
protected:
|
|
/// Implements generic processing behavior for this thread.
|
|
virtual bool process() override;
|
|
|
|
/// Called before a packetDistributor pass to allow for pre-distribution processing
|
|
virtual void preDistributionProcessing() {};
|
|
virtual void traverseTreeAndSendContents(SharedNodePointer node, OctreeQueryNode* nodeData, bool viewFrustumChanged, bool isFullScene);
|
|
|
|
OctreeServer* _myServer { nullptr };
|
|
QWeakPointer<Node> _node;
|
|
|
|
private:
|
|
int handlePacketSend(SharedNodePointer node, OctreeQueryNode* nodeData, bool dontSuppressDuplicate = false);
|
|
int packetDistributor(SharedNodePointer node, OctreeQueryNode* nodeData, bool viewFrustumChanged);
|
|
|
|
|
|
QUuid _nodeUuid;
|
|
|
|
OctreePacketData _packetData;
|
|
|
|
int _truePacketsSent { 0 }; // available for debug stats
|
|
int _trueBytesSent { 0 }; // available for debug stats
|
|
int _packetsSentThisInterval { 0 }; // used for bandwidth throttle condition
|
|
bool _isShuttingDown { false };
|
|
};
|
|
|
|
#endif // hifi_OctreeSendThread_h
|