added warn log for restarting a plugin

intelsdi-x · Feb 18, 2016 · 364d41d · 364d41d
1 parent dc59424
commit 364d41d
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/control/control_test.go b/control/control_test.go
@@ -1150,8 +1150,8 @@ func TestFailedPlugin(t *testing.T) {
 				}
 				<-lpe.done
 				eventMap[lpe.plugin.EventNamespace]++
-				So(eventMap[control_event.AvailablePluginDead], ShouldEqual, 4)
-				So(eventMap[control_event.AvailablePluginRestarted], ShouldEqual, 3)
+				So(eventMap[control_event.AvailablePluginDead], ShouldEqual, MaxPluginRestartCount+1)
+				So(eventMap[control_event.AvailablePluginRestarted], ShouldEqual, MaxPluginRestartCount)
 				So(eventMap[control_event.PluginRestartsExceeded], ShouldEqual, 1)
 				So(len(pool.Plugins()), ShouldEqual, 0)
 				So(pool.RestartCount(), ShouldEqual, MaxPluginRestartCount)

diff --git a/control/runner.go b/control/runner.go
@@ -268,6 +268,14 @@ func (r *runner) HandleGomitEvent(e gomit.Event) {
 					return
 				}
 				pool.IncRestartCount()
+
+				runnerLog.WithFields(log.Fields{
+					"_block":        "handle-events",
+					"event":         v.Name,
+					"aplugin":       v.Version,
+					"restart_count": pool.RestartCount(),
+				}).Warning("plugin restarted")
+
 				r.emitter.Emit(&control_event.RestartedAvailablePluginEvent{
 					Id:      v.Id,
 					Name:    v.Name,