mirror of
https://github.com/HifiExperiments/overte.git
synced 2025-07-07 17:20:00 +02:00
430 lines
19 KiB
C++
430 lines
19 KiB
C++
//
|
|
// OctreeStatsDialog.cpp
|
|
// interface/src/ui
|
|
//
|
|
// Created by Brad Hefta-Gaub on 7/19/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 <sstream>
|
|
|
|
#include <QFormLayout>
|
|
#include <QDialogButtonBox>
|
|
|
|
#include <QPalette>
|
|
#include <QColor>
|
|
|
|
#include <OctreeSceneStats.h>
|
|
|
|
#include "Application.h"
|
|
|
|
#include "ui/OctreeStatsDialog.h"
|
|
|
|
OctreeStatsDialog::OctreeStatsDialog(QWidget* parent, NodeToOctreeSceneStats* model) :
|
|
QDialog(parent, Qt::Window | Qt::WindowCloseButtonHint | Qt::WindowStaysOnTopHint),
|
|
_model(model) {
|
|
|
|
_statCount = 0;
|
|
_octreeServerLabelsCount = 0;
|
|
|
|
for (int i = 0; i < MAX_VOXEL_SERVERS; i++) {
|
|
_octreeServerLables[i] = 0;
|
|
_extraServerDetails[i] = LESS;
|
|
}
|
|
|
|
for (int i = 0; i < MAX_STATS; i++) {
|
|
_labels[i] = NULL;
|
|
}
|
|
|
|
this->setWindowTitle("Octree Server Statistics");
|
|
|
|
// Create layouter
|
|
_form = new QFormLayout();
|
|
this->QDialog::setLayout(_form);
|
|
|
|
// Setup stat items
|
|
_serverElements = AddStatItem("Elements on Servers");
|
|
_localElements = AddStatItem("Local Elements");
|
|
_localElementsMemory = AddStatItem("Elements Memory");
|
|
_sendingMode = AddStatItem("Sending Mode");
|
|
_entityUpdateTime = AddStatItem("Entity Update Time");
|
|
|
|
layout()->setSizeConstraint(QLayout::SetFixedSize);
|
|
}
|
|
|
|
void OctreeStatsDialog::RemoveStatItem(int item) {
|
|
QLabel* myLabel = _labels[item];
|
|
QWidget* automaticLabel = _form->labelForField(myLabel);
|
|
_form->removeWidget(myLabel);
|
|
_form->removeWidget(automaticLabel);
|
|
automaticLabel->deleteLater();
|
|
myLabel->deleteLater();
|
|
_labels[item] = NULL;
|
|
}
|
|
|
|
void OctreeStatsDialog::moreless(const QString& link) {
|
|
QStringList linkDetails = link.split("-");
|
|
const int COMMAND_ITEM = 0;
|
|
const int SERVER_NUMBER_ITEM = 1;
|
|
QString serverNumberString = linkDetails[SERVER_NUMBER_ITEM];
|
|
QString command = linkDetails[COMMAND_ITEM];
|
|
int serverNumber = serverNumberString.toInt();
|
|
|
|
if (command == "more") {
|
|
_extraServerDetails[serverNumber-1] = MORE;
|
|
} else if (command == "most") {
|
|
_extraServerDetails[serverNumber-1] = MOST;
|
|
} else {
|
|
_extraServerDetails[serverNumber-1] = LESS;
|
|
}
|
|
}
|
|
|
|
|
|
int OctreeStatsDialog::AddStatItem(const char* caption, unsigned colorRGBA) {
|
|
char strBuf[64];
|
|
const int STATS_LABEL_WIDTH = 600;
|
|
|
|
_statCount++; // increment our current stat count
|
|
|
|
if (colorRGBA == 0) {
|
|
static unsigned rotatingColors[] = { GREENISH, YELLOWISH, GREYISH };
|
|
colorRGBA = rotatingColors[_statCount % (sizeof(rotatingColors)/sizeof(rotatingColors[0]))];
|
|
}
|
|
QLabel* label = _labels[_statCount] = new QLabel();
|
|
|
|
// Set foreground color to 62.5% brightness of the meter (otherwise will be hard to read on the bright background)
|
|
QPalette palette = label->palette();
|
|
|
|
// This goofiness came from the bandwidth meter code, it basically stores a color in an unsigned and extracts it
|
|
unsigned rgb = colorRGBA >> 8;
|
|
const unsigned colorpart1 = 0xfefefeu;
|
|
const unsigned colorpart2 = 0xf8f8f8;
|
|
rgb = ((rgb & colorpart1) >> 1) + ((rgb & colorpart2) >> 3);
|
|
palette.setColor(QPalette::WindowText, QColor::fromRgb(rgb));
|
|
label->setPalette(palette);
|
|
snprintf(strBuf, sizeof(strBuf), " %s:", caption);
|
|
_form->addRow(strBuf, label);
|
|
label->setFixedWidth(STATS_LABEL_WIDTH);
|
|
|
|
return _statCount;
|
|
}
|
|
|
|
OctreeStatsDialog::~OctreeStatsDialog() {
|
|
for (int i = 0; i < _statCount; i++) {
|
|
delete _labels[i];
|
|
}
|
|
}
|
|
|
|
void OctreeStatsDialog::paintEvent(QPaintEvent* event) {
|
|
|
|
// Update labels
|
|
|
|
QLabel* label;
|
|
QLocale locale(QLocale::English);
|
|
std::stringstream statsValue;
|
|
statsValue.precision(4);
|
|
|
|
// Octree Elements Memory Usage
|
|
label = _labels[_localElementsMemory];
|
|
statsValue.str("");
|
|
statsValue << "Elements RAM: " << OctreeElement::getTotalMemoryUsage() / 1000000.0f << "MB ";
|
|
label->setText(statsValue.str().c_str());
|
|
|
|
// Local Elements
|
|
label = _labels[_localElements];
|
|
unsigned long localTotal = OctreeElement::getNodeCount();
|
|
unsigned long localInternal = OctreeElement::getInternalNodeCount();
|
|
unsigned long localLeaves = OctreeElement::getLeafNodeCount();
|
|
QString localTotalString = locale.toString((uint)localTotal); // consider adding: .rightJustified(10, ' ');
|
|
QString localInternalString = locale.toString((uint)localInternal);
|
|
QString localLeavesString = locale.toString((uint)localLeaves);
|
|
|
|
statsValue.str("");
|
|
statsValue <<
|
|
"Total: " << qPrintable(localTotalString) << " / " <<
|
|
"Internal: " << qPrintable(localInternalString) << " / " <<
|
|
"Leaves: " << qPrintable(localLeavesString) << "";
|
|
label->setText(statsValue.str().c_str());
|
|
|
|
// iterate all the current octree stats, and list their sending modes, total their octree elements, etc...
|
|
std::stringstream sendingMode("");
|
|
|
|
int serverCount = 0;
|
|
int movingServerCount = 0;
|
|
unsigned long totalNodes = 0;
|
|
unsigned long totalInternal = 0;
|
|
unsigned long totalLeaves = 0;
|
|
|
|
Application::getInstance()->lockOctreeSceneStats();
|
|
NodeToOctreeSceneStats* sceneStats = Application::getInstance()->getOcteeSceneStats();
|
|
for(NodeToOctreeSceneStatsIterator i = sceneStats->begin(); i != sceneStats->end(); i++) {
|
|
//const QUuid& uuid = i->first;
|
|
OctreeSceneStats& stats = i->second;
|
|
serverCount++;
|
|
|
|
// calculate server node totals
|
|
totalNodes += stats.getTotalElements();
|
|
totalInternal += stats.getTotalInternal();
|
|
totalLeaves += stats.getTotalLeaves();
|
|
|
|
// Sending mode
|
|
if (serverCount > 1) {
|
|
sendingMode << ",";
|
|
}
|
|
if (stats.isMoving()) {
|
|
sendingMode << "M";
|
|
movingServerCount++;
|
|
} else {
|
|
sendingMode << "S";
|
|
}
|
|
}
|
|
Application::getInstance()->unlockOctreeSceneStats();
|
|
sendingMode << " - " << serverCount << " servers";
|
|
if (movingServerCount > 0) {
|
|
sendingMode << " <SCENE NOT STABLE>";
|
|
} else {
|
|
sendingMode << " <SCENE STABLE>";
|
|
}
|
|
|
|
label = _labels[_sendingMode];
|
|
label->setText(sendingMode.str().c_str());
|
|
|
|
// Server Elements
|
|
QString serversTotalString = locale.toString((uint)totalNodes); // consider adding: .rightJustified(10, ' ');
|
|
QString serversInternalString = locale.toString((uint)totalInternal);
|
|
QString serversLeavesString = locale.toString((uint)totalLeaves);
|
|
label = _labels[_serverElements];
|
|
statsValue.str("");
|
|
statsValue <<
|
|
"Total: " << qPrintable(serversTotalString) << " / " <<
|
|
"Internal: " << qPrintable(serversInternalString) << " / " <<
|
|
"Leaves: " << qPrintable(serversLeavesString) << "";
|
|
label->setText(statsValue.str().c_str());
|
|
|
|
label = _labels[_entityUpdateTime];
|
|
auto entites = Application::getInstance()->getEntities()->getTree();
|
|
quint64 averageEditDelta = entites->getAverageEditDeltas();
|
|
QString averageEditDeltaString = locale.toString((uint)averageEditDelta);
|
|
quint64 maxEditDelta = entites->getMaxEditDelta();
|
|
QString maxEditDeltaString = locale.toString((uint)maxEditDelta);
|
|
|
|
statsValue.str("");
|
|
statsValue <<
|
|
"Average: " << qPrintable(averageEditDeltaString) << " (usecs) / " <<
|
|
"Max: " << qPrintable(maxEditDeltaString) << " (usecs)";
|
|
label->setText(statsValue.str().c_str());
|
|
|
|
|
|
showAllOctreeServers();
|
|
|
|
this->QDialog::paintEvent(event);
|
|
}
|
|
void OctreeStatsDialog::showAllOctreeServers() {
|
|
int serverCount = 0;
|
|
|
|
showOctreeServersOfType(serverCount, NodeType::EntityServer, "Entity",
|
|
Application::getInstance()->getEntityServerJurisdictions());
|
|
|
|
if (_octreeServerLabelsCount > serverCount) {
|
|
for (int i = serverCount; i < _octreeServerLabelsCount; i++) {
|
|
int serverLabel = _octreeServerLables[i];
|
|
RemoveStatItem(serverLabel);
|
|
_octreeServerLables[i] = 0;
|
|
}
|
|
_octreeServerLabelsCount = serverCount;
|
|
}
|
|
}
|
|
|
|
void OctreeStatsDialog::showOctreeServersOfType(int& serverCount, NodeType_t serverType, const char* serverTypeName,
|
|
NodeToJurisdictionMap& serverJurisdictions) {
|
|
|
|
QLocale locale(QLocale::English);
|
|
|
|
auto nodeList = DependencyManager::get<NodeList>();
|
|
nodeList->eachNode([&](const SharedNodePointer& node){
|
|
|
|
// only send to the NodeTypes that are NodeType_t_VOXEL_SERVER
|
|
if (node->getType() == serverType) {
|
|
serverCount++;
|
|
|
|
if (serverCount > _octreeServerLabelsCount) {
|
|
QString label = QString("%1 Server %2").arg(serverTypeName).arg(serverCount);
|
|
int thisServerRow = _octreeServerLables[serverCount-1] = AddStatItem(label.toUtf8().constData());
|
|
_labels[thisServerRow]->setTextFormat(Qt::RichText);
|
|
_labels[thisServerRow]->setTextInteractionFlags(Qt::TextBrowserInteraction);
|
|
connect(_labels[thisServerRow], SIGNAL(linkActivated(const QString&)), this, SLOT(moreless(const QString&)));
|
|
_octreeServerLabelsCount++;
|
|
}
|
|
|
|
std::stringstream serverDetails("");
|
|
std::stringstream extraDetails("");
|
|
std::stringstream linkDetails("");
|
|
|
|
if (node->getActiveSocket()) {
|
|
serverDetails << "active ";
|
|
} else {
|
|
serverDetails << "inactive ";
|
|
}
|
|
|
|
QUuid nodeUUID = node->getUUID();
|
|
|
|
// lookup our nodeUUID in the jurisdiction map, if it's missing then we're
|
|
// missing at least one jurisdiction
|
|
serverJurisdictions.lockForRead();
|
|
if (serverJurisdictions.find(nodeUUID) == serverJurisdictions.end()) {
|
|
serverDetails << " unknown jurisdiction ";
|
|
serverJurisdictions.unlock();
|
|
} else {
|
|
const JurisdictionMap& map = serverJurisdictions[nodeUUID];
|
|
|
|
unsigned char* rootCode = map.getRootOctalCode();
|
|
|
|
if (rootCode) {
|
|
QString rootCodeHex = octalCodeToHexString(rootCode);
|
|
|
|
VoxelPositionSize rootDetails;
|
|
voxelDetailsForCode(rootCode, rootDetails);
|
|
AACube serverBounds(glm::vec3(rootDetails.x, rootDetails.y, rootDetails.z), rootDetails.s);
|
|
serverDetails << " jurisdiction: "
|
|
<< qPrintable(rootCodeHex)
|
|
<< " ["
|
|
<< rootDetails.x << ", "
|
|
<< rootDetails.y << ", "
|
|
<< rootDetails.z << ": "
|
|
<< rootDetails.s << "] ";
|
|
} else {
|
|
serverDetails << " jurisdiction has no rootCode";
|
|
} // root code
|
|
serverJurisdictions.unlock();
|
|
} // jurisdiction
|
|
|
|
// now lookup stats details for this server...
|
|
if (_extraServerDetails[serverCount-1] != LESS) {
|
|
Application::getInstance()->lockOctreeSceneStats();
|
|
NodeToOctreeSceneStats* sceneStats = Application::getInstance()->getOcteeSceneStats();
|
|
if (sceneStats->find(nodeUUID) != sceneStats->end()) {
|
|
OctreeSceneStats& stats = sceneStats->at(nodeUUID);
|
|
|
|
switch (_extraServerDetails[serverCount-1]) {
|
|
case MOST: {
|
|
extraDetails << "<br/>" ;
|
|
|
|
const unsigned long USECS_PER_MSEC = 1000;
|
|
float lastFullEncode = stats.getLastFullTotalEncodeTime() / USECS_PER_MSEC;
|
|
float lastFullSend = stats.getLastFullElapsedTime() / USECS_PER_MSEC;
|
|
float lastFullSendInSeconds = stats.getLastFullElapsedTime() / USECS_PER_SECOND;
|
|
float lastFullPackets = stats.getLastFullTotalPackets();
|
|
float lastFullPPS = lastFullPackets;
|
|
if (lastFullSendInSeconds > 0) {
|
|
lastFullPPS = lastFullPackets / lastFullSendInSeconds;
|
|
}
|
|
|
|
QString lastFullEncodeString = locale.toString(lastFullEncode);
|
|
QString lastFullSendString = locale.toString(lastFullSend);
|
|
QString lastFullPacketsString = locale.toString(lastFullPackets);
|
|
QString lastFullBytesString = locale.toString((uint)stats.getLastFullTotalBytes());
|
|
QString lastFullPPSString = locale.toString(lastFullPPS);
|
|
|
|
extraDetails << "<br/>" << "Last Full Scene... " <<
|
|
"Encode: " << qPrintable(lastFullEncodeString) << " ms " <<
|
|
"Send: " << qPrintable(lastFullSendString) << " ms " <<
|
|
"Packets: " << qPrintable(lastFullPacketsString) << " " <<
|
|
"Bytes: " << qPrintable(lastFullBytesString) << " " <<
|
|
"Rate: " << qPrintable(lastFullPPSString) << " PPS";
|
|
|
|
for (int i = 0; i < OctreeSceneStats::ITEM_COUNT; i++) {
|
|
OctreeSceneStats::Item item = (OctreeSceneStats::Item)(i);
|
|
OctreeSceneStats::ItemInfo& itemInfo = stats.getItemInfo(item);
|
|
extraDetails << "<br/>" << itemInfo.caption << " " << stats.getItemValue(item);
|
|
}
|
|
} // fall through... since MOST has all of MORE
|
|
case MORE: {
|
|
QString totalString = locale.toString((uint)stats.getTotalElements());
|
|
QString internalString = locale.toString((uint)stats.getTotalInternal());
|
|
QString leavesString = locale.toString((uint)stats.getTotalLeaves());
|
|
|
|
serverDetails << "<br/>" << "Node UUID: " << qPrintable(nodeUUID.toString()) << " ";
|
|
|
|
serverDetails << "<br/>" << "Elements: " <<
|
|
qPrintable(totalString) << " total " <<
|
|
qPrintable(internalString) << " internal " <<
|
|
qPrintable(leavesString) << " leaves ";
|
|
|
|
QString incomingPacketsString = locale.toString((uint)stats.getIncomingPackets());
|
|
QString incomingBytesString = locale.toString((uint)stats.getIncomingBytes());
|
|
QString incomingWastedBytesString = locale.toString((uint)stats.getIncomingWastedBytes());
|
|
const SequenceNumberStats& seqStats = stats.getIncomingOctreeSequenceNumberStats();
|
|
QString incomingOutOfOrderString = locale.toString((uint)seqStats.getOutOfOrder());
|
|
QString incomingLateString = locale.toString((uint)seqStats.getLate());
|
|
QString incomingUnreasonableString = locale.toString((uint)seqStats.getUnreasonable());
|
|
QString incomingEarlyString = locale.toString((uint)seqStats.getEarly());
|
|
QString incomingLikelyLostString = locale.toString((uint)seqStats.getLost());
|
|
QString incomingRecovered = locale.toString((uint)seqStats.getRecovered());
|
|
|
|
int clockSkewInMS = node->getClockSkewUsec() / (int)USECS_PER_MSEC;
|
|
QString incomingFlightTimeString = locale.toString((int)stats.getIncomingFlightTimeAverage());
|
|
QString incomingPingTimeString = locale.toString(node->getPingMs());
|
|
QString incomingClockSkewString = locale.toString(clockSkewInMS);
|
|
|
|
serverDetails << "<br/>" << "Incoming Packets: " << qPrintable(incomingPacketsString) <<
|
|
"/ Lost: " << qPrintable(incomingLikelyLostString) <<
|
|
"/ Recovered: " << qPrintable(incomingRecovered);
|
|
|
|
serverDetails << "<br/>" << " Out of Order: " << qPrintable(incomingOutOfOrderString) <<
|
|
"/ Early: " << qPrintable(incomingEarlyString) <<
|
|
"/ Late: " << qPrintable(incomingLateString) <<
|
|
"/ Unreasonable: " << qPrintable(incomingUnreasonableString);
|
|
|
|
serverDetails << "<br/>" <<
|
|
" Average Flight Time: " << qPrintable(incomingFlightTimeString) << " msecs";
|
|
|
|
serverDetails << "<br/>" <<
|
|
" Average Ping Time: " << qPrintable(incomingPingTimeString) << " msecs";
|
|
|
|
serverDetails << "<br/>" <<
|
|
" Average Clock Skew: " << qPrintable(incomingClockSkewString) << " msecs";
|
|
|
|
serverDetails << "<br/>" << "Incoming" <<
|
|
" Bytes: " << qPrintable(incomingBytesString) <<
|
|
" Wasted Bytes: " << qPrintable(incomingWastedBytesString);
|
|
|
|
serverDetails << extraDetails.str();
|
|
if (_extraServerDetails[serverCount-1] == MORE) {
|
|
linkDetails << " " << " [<a href='most-" << serverCount << "'>most...</a>]";
|
|
linkDetails << " " << " [<a href='less-" << serverCount << "'>less...</a>]";
|
|
} else {
|
|
linkDetails << " " << " [<a href='more-" << serverCount << "'>less...</a>]";
|
|
linkDetails << " " << " [<a href='less-" << serverCount << "'>least...</a>]";
|
|
}
|
|
|
|
} break;
|
|
case LESS: {
|
|
// nothing
|
|
} break;
|
|
}
|
|
}
|
|
Application::getInstance()->unlockOctreeSceneStats();
|
|
} else {
|
|
linkDetails << " " << " [<a href='more-" << serverCount << "'>more...</a>]";
|
|
linkDetails << " " << " [<a href='most-" << serverCount << "'>most...</a>]";
|
|
}
|
|
serverDetails << linkDetails.str();
|
|
_labels[_octreeServerLables[serverCount - 1]]->setText(serverDetails.str().c_str());
|
|
} // is VOXEL_SERVER
|
|
});
|
|
}
|
|
|
|
void OctreeStatsDialog::reject() {
|
|
// Just regularly close upon ESC
|
|
this->QDialog::close();
|
|
}
|
|
|
|
void OctreeStatsDialog::closeEvent(QCloseEvent* event) {
|
|
this->QDialog::closeEvent(event);
|
|
emit closed();
|
|
}
|
|
|
|
|