2 Commits

View File

@@ -509,7 +509,7 @@ class Machine {
this.logger.debug(`Flow update: ${value} at ${position} from ${context.childName || 'child'}`);
if (this.upstreamSource && this.downstreamSink) {
this._updateSourceSink();
this.updateSourceSink();
}
// Store in parent's measurement container
@@ -521,7 +521,7 @@ class Machine {
}
}
_updateSourceSink() {
updateSourceSink() {
// Handles flow according to the configured "flow number"
this.logger.debug(`Updating source-sink pair: ${this.upstreamSource.config.functionality.softwareType} - ${this.downstreamSink.config.functionality.softwareType}`);
this.downstreamSink.setInfluent = this.upstreamSource.getEffluent[this.config.flowNumber];