Skip to content

Commit cbadf7d

Browse files
committed
Fixing variable diff
1 parent 62b203f commit cbadf7d

File tree

2 files changed

+13
-8
lines changed

2 files changed

+13
-8
lines changed

cluster/cluster.go

+12-7
Original file line numberDiff line numberDiff line change
@@ -789,20 +789,25 @@ func (cluster *Cluster) MonitorVariablesDiff() {
789789
var slavevalue Diff
790790
slavevalue.Server = s.URL
791791
slavevalue.VariableValue = slaveVariables[k]
792-
myvalues = append(myvalues, mastervalue)
792+
myvalues = append(myvalues, slavevalue)
793793
variablesdiff += "+ Master Variable: " + k + " -> " + v + "\n"
794794
variablesdiff += "- Slave: " + s.URL + " -> " + slaveVariables[k] + "\n"
795795
}
796-
if len(myvalues) > 1 {
797-
myvardiff.VariableName = k
798-
myvardiff.DiffValues = myvalues
799-
alldiff = append(alldiff, myvardiff)
800-
}
796+
}
797+
if len(myvalues) > 1 {
798+
myvardiff.VariableName = k
799+
myvardiff.DiffValues = myvalues
800+
alldiff = append(alldiff, myvardiff)
801801
}
802802
}
803803
if variablesdiff != "" {
804804
cluster.DiffVariables = alldiff
805-
cluster.SetState("WARN0084", state.State{ErrType: "WARNING", ErrDesc: fmt.Sprintf(clusterError["WARN0084"], variablesdiff), ErrFrom: "MON", ServerUrl: cluster.GetMaster().URL})
805+
jtext, err := json.MarshalIndent(alldiff, " ", "\t")
806+
if err != nil {
807+
cluster.LogPrintf(LvlErr, "Encoding variables diff %s", err)
808+
return
809+
}
810+
cluster.SetState("WARN0084", state.State{ErrType: "WARNING", ErrDesc: fmt.Sprintf(clusterError["WARN0084"], string(jtext)), ErrFrom: "MON", ServerUrl: cluster.GetMaster().URL})
806811
}
807812
}
808813

etc/local/config.toml.osx

+1-1
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ backup-mysqldump-path = "/usr/local/bin/mysqldump"
3434
include="etc/local/features/prefered"
3535
#include="etc/local/masterslave"
3636
#include="etc/local/masterslave/consul"
37-
include="etc/local/masterslave/haproxy"
37+
#include="etc/local/masterslave/haproxy"
3838
#include="etc/local/masterslave/maxscale"
3939
#include="etc/local/masterslave/myproxy"
4040
#include="etc/local/masterslave/shardproxy"

0 commit comments

Comments
 (0)