From d806d4fe543189a90dbfef0378f1821027a67b79 Mon Sep 17 00:00:00 2001 From: Simo Kinnunen Date: Tue, 2 Jun 2015 13:26:43 +0900 Subject: [PATCH] EventEmitter constructor was not being called in many places. It did work due to the EventEmitter3 constructor being empty, but we can't rely on that. --- lib/units/device/plugins/screen/stream.js | 1 + lib/util/failcounter.js | 1 + lib/util/riskystream.js | 2 ++ lib/util/ttlset.js | 1 + 4 files changed, 5 insertions(+) diff --git a/lib/units/device/plugins/screen/stream.js b/lib/units/device/plugins/screen/stream.js index 4c72d3b9..5b4eb26b 100644 --- a/lib/units/device/plugins/screen/stream.js +++ b/lib/units/device/plugins/screen/stream.js @@ -28,6 +28,7 @@ module.exports = syrup.serial() var plugin = Object.create(null) function FrameProducer(config) { + EventEmitter.call(this) this.actionQueue = [] this.runningState = FrameProducer.STATE_STOPPED this.desiredState = new StateQueue() diff --git a/lib/util/failcounter.js b/lib/util/failcounter.js index 4df55912..186abb1b 100644 --- a/lib/util/failcounter.js +++ b/lib/util/failcounter.js @@ -3,6 +3,7 @@ var util = require('util') var EventEmitter = require('eventemitter3').EventEmitter function FailCounter(threshold, time) { + EventEmitter.call(this) this.threshold = threshold this.time = time this.values = [] diff --git a/lib/util/riskystream.js b/lib/util/riskystream.js index b953e922..643fa172 100644 --- a/lib/util/riskystream.js +++ b/lib/util/riskystream.js @@ -3,6 +3,8 @@ var util = require('util') var EventEmitter = require('eventemitter3').EventEmitter function RiskyStream(stream) { + EventEmitter.call(this) + this.endListener = function() { this.ended = true this.stream.removeListener('end', this.endListener) diff --git a/lib/util/ttlset.js b/lib/util/ttlset.js index d6fd3917..0a34d3f5 100644 --- a/lib/util/ttlset.js +++ b/lib/util/ttlset.js @@ -10,6 +10,7 @@ function TtlItem(value) { } function TtlSet(ttl) { + EventEmitter.call(this) this.head = null this.tail = null this.mapping = Object.create(null)