forked from signal18/replication-manager
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathtest_switchover_assync_slavesstop_norplcheck.go
41 lines (35 loc) · 1.22 KB
/
test_switchover_assync_slavesstop_norplcheck.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
// replication-manager - Replication Manager Monitoring and CLI for MariaDB and MySQL
// Copyright 2017 Signal 18 SARL
// Authors: Guillaume Lefranc <guillaume@signal18.io>
// Stephane Varoqui <svaroqui@gmail.com>
// This source code is licensed under the GNU General Public License, version 3.
package regtest
import (
"time"
"github.com/signal18/replication-manager/cluster"
)
func testSwitchoverAllSlavesStopNoSemiSyncNoRplCheck(cluster *cluster.Cluster, conf string, test *cluster.Test) bool {
cluster.SetRplMaxDelay(0)
cluster.SetRplChecks(false)
err := cluster.DisableSemisync()
if err != nil {
cluster.LogPrintf(LvlErr, "%s", err)
return false
}
err = cluster.StopSlaves()
if err != nil {
cluster.LogPrintf(LvlErr, "%s", err)
return false
}
time.Sleep(4 * time.Second)
SaveMasterURL := cluster.GetMaster().URL
cluster.LogPrintf("TEST", "Master is %s", cluster.GetMaster().URL)
cluster.SwitchoverWaitTest()
cluster.LogPrintf("TEST", "New Master %s ", cluster.GetMaster().URL)
time.Sleep(2 * time.Second)
if cluster.GetMaster().URL == SaveMasterURL {
cluster.LogPrintf(LvlErr, "Saved Prefered master %s <> from saved %s ", SaveMasterURL, cluster.GetMaster().URL)
return false
}
return true
}