ExternalVendorCode/openmct
1
0
Fork 0
mirror of https://github.com/nasa/openmct.git synced 2025-05-08 03:28:33 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

[Plot] Begin updating plot

Browse Source 
Begin updating plot to merge realtime and historical
telemetry, WTD-806.
This commit is contained in:
Victor Woeltjen 2015-04-16 16:48:03 -07:00
parent 03e1633a22
commit 9215eb1427
1 changed files with 40 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
platform/features/plot/src/elements/PlotUpdater.js
View File

@ -61,21 +61,7 @@ define(
return buffer; return buffer;
} }
// Add data to the plot. function setData(buffer, id, index, domainValue, rangeValue) {
function addData(obj) {
var id = obj.getId(),
index = lengths[id] || 0,
buffer = buffers[id],
domainValue = subscription.getDomainValue(obj, domain),
rangeValue = subscription.getRangeValue(obj, range);
// If we don't already have a data buffer for that ID,
// make one.
if (!buffer) {
buffer = new Float32Array(INITIAL_SIZE);
buffers[id] = buffer;
}
// Make sure there's data to add, and then add it // Make sure there's data to add, and then add it
if (domainValue !== undefined && rangeValue !== undefined && if (domainValue !== undefined && rangeValue !== undefined &&
(index < 1 || domainValue !== buffer[index * 2 - 2])) { (index < 1 || domainValue !== buffer[index * 2 - 2])) {
@ -94,14 +80,39 @@ define(
// Observe max/min range values // Observe max/min range values
max[1] = Math.max(max[1], rangeValue); max[1] = Math.max(max[1], rangeValue);
min[1] = Math.min(min[1], rangeValue); min[1] = Math.min(min[1], rangeValue);
}
return buffer;
}
// Add data to the plot.
function addData(obj) {
var id = obj.getId(),
index = lengths[id] || 0,
buffer = buffers[id],
domainValue = subscription.getDomainValue(obj, domain),
rangeValue = subscription.getRangeValue(obj, range);
// If we don't already have a data buffer for that ID,
// make one.
if (!buffer) {
buffer = new Float32Array(INITIAL_SIZE);
buffers[id] = buffer;
}
// Update the cutoff point for when we started receiving // Update the cutoff point for when we started receiving
// realtime data, to aid in clearing historical data later // realtime data, to aid in clearing historical data later
if (realtimeIndex[id] === undefined) { if (realtimeIndex[id] === undefined) {
realtimeIndex[id] = index; realtimeIndex[id] = index;
} }
}
return buffer; // Put the data in the buffer
return setData(
buffer,
id,
index,
domainValue,
rangeValue
);
} }
// Update min/max domain values for these objects // Update min/max domain values for these objects
@ -121,7 +132,15 @@ define(
// Update historical data for this domain object // Update historical data for this domain object
function setHistorical(domainObject) { function setHistorical(domainObject) {
var id = domainObject.getId(),
buffer = buffers[id],
endIndex = realtimeIndex[id] || 0;
// Make sure the buffer is big enough
// Move the realtime data into the correct position
// Insert the historical data before it
} }
// Handle new telemetry data // Handle new telemetry data