mirror of
https://github.com/HifiExperiments/overte.git
synced 2025-07-06 08:38:48 +02:00
2be85d439b
Conflicts: interface/src/Application.cpp interface/src/VoxelPacketProcessor.cpp libraries/voxels/src/VoxelEditPacketSender.cpp
62 lines
2.5 KiB
C++
62 lines
2.5 KiB
C++
//
|
|
// VoxelPacketProcessor.cpp
|
|
// interface
|
|
//
|
|
// Created by Brad Hefta-Gaub on 8/12/13.
|
|
// Copyright (c) 2013 High Fidelity, Inc. All rights reserved.
|
|
//
|
|
// Threaded or non-threaded voxel packet receiver for the Application
|
|
//
|
|
|
|
#include <PerfStat.h>
|
|
|
|
#include "Application.h"
|
|
#include "Menu.h"
|
|
#include "VoxelPacketProcessor.h"
|
|
|
|
void VoxelPacketProcessor::processPacket(sockaddr& senderAddress, unsigned char* packetData, ssize_t packetLength) {
|
|
PerformanceWarning warn(Menu::getInstance()->isOptionChecked(MenuOption::PipelineWarnings),
|
|
"VoxelPacketProcessor::processPacket()");
|
|
ssize_t messageLength = packetLength;
|
|
|
|
Application* app = Application::getInstance();
|
|
|
|
// check to see if the UI thread asked us to kill the voxel tree. since we're the only thread allowed to do that
|
|
if (app->_wantToKillLocalVoxels) {
|
|
app->_voxels.killLocalVoxels();
|
|
app->_wantToKillLocalVoxels = false;
|
|
}
|
|
|
|
// note: PACKET_TYPE_VOXEL_STATS can have PACKET_TYPE_VOXEL_DATA or PACKET_TYPE_VOXEL_DATA_MONOCHROME
|
|
// immediately following them inside the same packet. So, we process the PACKET_TYPE_VOXEL_STATS first
|
|
// then process any remaining bytes as if it was another packet
|
|
if (packetData[0] == PACKET_TYPE_VOXEL_STATS) {
|
|
|
|
int statsMessageLength = app->parseVoxelStats(packetData, messageLength, senderAddress);
|
|
if (messageLength > statsMessageLength) {
|
|
packetData += statsMessageLength;
|
|
messageLength -= statsMessageLength;
|
|
if (!packetVersionMatch(packetData)) {
|
|
return; // bail since piggyback data doesn't match our versioning
|
|
}
|
|
} else {
|
|
return; // bail since no piggyback data
|
|
}
|
|
} // fall through to piggyback message
|
|
|
|
if (Menu::getInstance()->isOptionChecked(MenuOption::Voxels)) {
|
|
Node* voxelServer = NodeList::getInstance()->nodeWithAddress(&senderAddress);
|
|
if (voxelServer && socketMatch(voxelServer->getActiveSocket(), &senderAddress)) {
|
|
voxelServer->lock();
|
|
if (packetData[0] == PACKET_TYPE_ENVIRONMENT_DATA) {
|
|
app->_environment.parseData(&senderAddress, packetData, messageLength);
|
|
} else {
|
|
app->_voxels.setDataSourceID(voxelServer->getNodeID());
|
|
app->_voxels.parseData(packetData, messageLength);
|
|
app->_voxels.setDataSourceID(UNKNOWN_NODE_ID);
|
|
}
|
|
voxelServer->unlock();
|
|
}
|
|
}
|
|
}
|
|
|