mirror/OpenSpace
1
0
Fork 0
mirror of https://github.com/OpenSpace/OpenSpace.git synced 2026-02-21 20:39:08 -06:00
Code Issues Packages Projects Releases Wiki Activity

Enable real time monitoring of StatsCollector data

Browse Source
This commit is contained in:
Erik Broberg
2016-06-27 18:08:26 -04:00
parent 6522a0f64a
commit 21c67e3199
4 changed files with 51 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
modules/globebrowsing/chunk/chunkedlodglobe.cpp
View File

@@ -68,7 +68,7 @@ namespace openspace {
, maxSplitDepth(22)
, _savedCamera(nullptr)
, _tileProviderManager(tileProviderManager)
, stats(StatsCollector(absPath("test_stats")))
, stats(StatsCollector(absPath("test_stats"), 1))
{
auto geometry = std::make_shared<SkirtedGrid>(

37
modules/globebrowsing/other/statscollector.h
View File

@@ -89,8 +89,13 @@ namespace openspace {
}
void reset() {
// copy last, i.e. current record
StatsRecord<T> lastRecord = _data.back();
_data.clear();
// add it again after cleared the vector
_data.push_back(lastRecord);
_writePos = 0;
}
void writeHeader(std::ostream& os) {
@@ -137,11 +142,13 @@ namespace openspace {
StatsCollector() = delete;
StatsCollector(const std::string& filename, const std::string& delimiter = ",", bool enabled = true)
StatsCollector(const std::string& filename, int dumpEveryXRecord, const std::string& delimiter = ",", bool enabled = true)
: _filename(filename)
, _dumpEveryXRecord(dumpEveryXRecord)
, _recordsSinceLastDump(0)
, _enabled(enabled)
, _delimiter(delimiter)
, _hasWrittenHead(false)
, _hasWrittenHeader(false)
, i(TemplatedStatsCollector<int>(_enabled, delimiter))
, d(TemplatedStatsCollector<double>(_enabled, delimiter))
{
@@ -154,6 +161,11 @@ namespace openspace {
void startNewRecord() {
if (_enabled) {
if (_dumpEveryXRecord && ++_recordsSinceLastDump >= _dumpEveryXRecord) {
dumpToDisk();
_recordsSinceLastDump = 0;
}
i.startNewRecord();
d.startNewRecord();
}
@@ -167,18 +179,24 @@ namespace openspace {
_enabled = true;
}
int hasHeaders() {
return i.hasHeaders() || d.hasHeaders();
}
void dumpToDisk() {
if (!_hasWrittenHead) {
writeHead();
if (_enabled && hasHeaders()) {
if (!_hasWrittenHeader) {
writeHeader();
}
writeData();
}
writeData();
}
TemplatedStatsCollector<int> i;
TemplatedStatsCollector<double> d;
private:
void writeHead() {
void writeHeader() {
std::ofstream ofs(_filename);
if (i.hasHeaders()) {
i.writeHeader(ofs);
@@ -190,6 +208,7 @@ namespace openspace {
else {
d.writeHeader(ofs);
}
_hasWrittenHeader = true;
ofs << std::endl;
ofs.close();
}
@@ -211,8 +230,12 @@ namespace openspace {
std::string _filename;
std::string _delimiter;
int _dumpEveryXRecord;
int _recordsSinceLastDump;
bool _enabled;
bool _hasWrittenHead;
bool _hasWrittenHeader;
};

17
monitor/index.html
View File

@@ -6,11 +6,27 @@
<script src="http://d3js.org/d3.v3.min.js" charset="utf-8"></script>
</head>
<body>
<button id="start-stop" onclick="startStop()">Start / Stop</button>
<svg></svg>
</body>
<script type="text/javascript">
var updateInterval = undefined;
function startStop(){
if(updateInterval === undefined){
console.log("Start updating");
updateInterval = setInterval(doVis, 1000);
doVis(); // Do one immediately
}
else{
console.log("Stop updating");
clearInterval(updateInterval);
updateInterval = undefined;
}
}
function doVis(){
var filename = "../data/scene/debugglobe/test_stats";
@@ -107,7 +123,6 @@ function doVis(){
});
}
doVis();
//setInterval(doVis, 1000);
</script>

4
monitor/style.css
View File

@@ -2,6 +2,10 @@ body {
font: 10px sans-serif;
}
#start-stop{
display: block;
}
.axis path,
.axis line {
fill: none;