From 3436076052dd165ecb1f904e628ef6e1904181be Mon Sep 17 00:00:00 2001 From: Jeffrey Morgan Date: Thu, 30 Apr 2015 13:27:55 -0400 Subject: [PATCH 1/2] Fixing live logs Signed-off-by: Jeffrey Morgan --- src/stores/ContainerStore.js | 7 ++----- src/stores/LogStore.js | 4 ++++ 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/src/stores/ContainerStore.js b/src/stores/ContainerStore.js index 9cdd9e1abf..552858aa9b 100644 --- a/src/stores/ContainerStore.js +++ b/src/stores/ContainerStore.js @@ -5,7 +5,7 @@ var assign = require('object-assign'); var docker = require('../utils/DockerUtil'); var metrics = require('../utils/MetricsUtil'); var registry = require('../utils/RegistryUtil'); -var logstore = require('../stores/LogStore'); +var logStore = require('../stores/LogStore'); var bugsnag = require('bugsnag-js'); var _placeholders = {}; @@ -118,6 +118,7 @@ var ContainerStore = assign(Object.create(EventEmitter.prototype), { return; } self.fetchContainer(name, callback); + logStore.fetch(name); }); }, _createContainer: function (name, containerData, callback) { @@ -363,9 +364,6 @@ var ContainerStore = assign(Object.create(EventEmitter.prototype), { if (!data.name) { data.name = data.Name; } - if (name !== data.name) { - logstore.rename(name, data.name); - } var fullData = assign(_containers[name], data); this._createContainer(name, fullData, function () { _muted[name] = false; @@ -374,7 +372,6 @@ var ContainerStore = assign(Object.create(EventEmitter.prototype), { }.bind(this)); }, rename: function (name, newName, callback) { - logstore.rename(name, newName); docker.client().getContainer(name).rename({name: newName}, err => { if (err && err.statusCode !== 204) { callback(err); diff --git a/src/stores/LogStore.js b/src/stores/LogStore.js index a3ba515f80..464f512c01 100644 --- a/src/stores/LogStore.js +++ b/src/stores/LogStore.js @@ -68,11 +68,15 @@ module.exports = assign(Object.create(EventEmitter.prototype), { } this.emit(this.SERVER_LOGS_EVENT); }); + logStream.on('end', () => { + this.detach(name); + }); }); }, detach: function (name) { if (_streams[name]) { _streams[name].destroy(); + delete _streams[name]; } }, logs: function (name) { From 0b2c26fb1dc917767f390560f589ccb6de24b6e6 Mon Sep 17 00:00:00 2001 From: Jeffrey Morgan Date: Thu, 30 Apr 2015 13:28:32 -0400 Subject: [PATCH 2/2] Removing unused function Signed-off-by: Jeffrey Morgan --- src/stores/LogStore.js | 5 ----- 1 file changed, 5 deletions(-) diff --git a/src/stores/LogStore.js b/src/stores/LogStore.js index 464f512c01..7a886ee497 100644 --- a/src/stores/LogStore.js +++ b/src/stores/LogStore.js @@ -81,10 +81,5 @@ module.exports = assign(Object.create(EventEmitter.prototype), { }, logs: function (name) { return _logs[name] || []; - }, - rename: function (name, newName) { - if (_logs[name]) { - _logs[newName] = _logs[name]; - } } });