diff options
| author | George Goldberg <george@gberg.me> | 2018-09-27 20:17:55 +0100 |
|---|---|---|
| committer | Christopher Speller <crspeller@gmail.com> | 2018-09-27 12:17:55 -0700 |
| commit | a257d501df3d0624f9cc52efb602e7d9d2a4dc07 (patch) | |
| tree | 7ff3b4efb10effa618ee93e3666fe4ab3caf91dd | |
| parent | 760e2007958569442e1bdd0093f0b5cc77ffaa38 (diff) | |
| download | chat-a257d501df3d0624f9cc52efb602e7d9d2a4dc07.tar.gz chat-a257d501df3d0624f9cc52efb602e7d9d2a4dc07.tar.bz2 chat-a257d501df3d0624f9cc52efb602e7d9d2a4dc07.zip | |
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.
| -rw-r--r-- | app/app.go | 1 | ||||
| -rw-r--r-- | app/cluster.go | 6 |
2 files changed, 6 insertions, 1 deletions
diff --git a/app/app.go b/app/app.go index dabd00571..d8974a48c 100644 --- a/app/app.go +++ b/app/app.go @@ -244,6 +244,7 @@ func New(options ...Option) (outApp *App, outErr error) { }) app.clusterLeaderListenerId = app.AddClusterLeaderChangedListener(func() { + mlog.Info("Cluster leader changed. Determining if job schedulers should be running:", mlog.Bool("isLeader", app.IsLeader())) app.Jobs.Schedulers.HandleClusterLeaderChange(app.IsLeader()) }) 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())() |