From a257d501df3d0624f9cc52efb602e7d9d2a4dc07 Mon Sep 17 00:00:00 2001 From: George Goldberg Date: Thu, 27 Sep 2018 20:17:55 +0100 Subject: MM-12080: Added some extra logging to cluster leader changed. (#9475) Purpose of this is to make in-field debugging of cluster leader issues (particularly around duplicate job scheduling) easier to debug from production server logs. --- app/cluster.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'app/cluster.go') diff --git a/app/cluster.go b/app/cluster.go index 020e57c61..22b9843b8 100644 --- a/app/cluster.go +++ b/app/cluster.go @@ -3,7 +3,10 @@ package app -import "github.com/mattermost/mattermost-server/model" +import ( + "github.com/mattermost/mattermost-server/mlog" + "github.com/mattermost/mattermost-server/model" +) // Registers a given function to be called when the cluster leader may have changed. Returns a unique ID for the // listener which can later be used to remove it. If clustering is not enabled in this build, the callback will never @@ -20,6 +23,7 @@ func (a *App) RemoveClusterLeaderChangedListener(id string) { } func (a *App) InvokeClusterLeaderChangedListeners() { + mlog.Info("Cluster leader changed. Invoking ClusterLeaderChanged listeners.") a.Go(func() { a.clusterLeaderListeners.Range(func(_, listener interface{}) bool { listener.(func())() -- cgit v1.2.3-1-g7c22