Skip to content

Commit 6e348b3

Browse files
authored
Merge pull request #328 from acekingke/followerCloneFirst
sidecar: first choose follower to clone init #322
2 parents b8cb91a + 0323a5b commit 6e348b3

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

sidecar/init.go

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -78,15 +78,16 @@ func CheckServiceExist(cfg *Config, service string) bool {
7878

7979
// Clone from leader or follower.
8080
func runCloneAndInit(cfg *Config) error {
81-
//check leader is exist?
82-
serviceURL := ""
83-
if len(serviceURL) == 0 && CheckServiceExist(cfg, "leader") {
84-
serviceURL = fmt.Sprintf("http://%s-%s:%v", cfg.ClusterName, "leader", utils.XBackupPort)
85-
}
8681
//check follower is exists?
82+
serviceURL := ""
8783
if len(serviceURL) == 0 && CheckServiceExist(cfg, "follower") {
8884
serviceURL = fmt.Sprintf("http://%s-%s:%v", cfg.ClusterName, "follower", utils.XBackupPort)
8985
}
86+
//check leader is exist?
87+
if len(serviceURL) == 0 && CheckServiceExist(cfg, "leader") {
88+
serviceURL = fmt.Sprintf("http://%s-%s:%v", cfg.ClusterName, "leader", utils.XBackupPort)
89+
}
90+
9091
if len(serviceURL) != 0 {
9192
// backup at first
9293
Args := fmt.Sprintf("rm -rf /backup/initbackup;mkdir -p /backup/initbackup;curl --user $BACKUP_USER:$BACKUP_PASSWORD %s/download|xbstream -x -C /backup/initbackup; exit ${PIPESTATUS[0]}",

0 commit comments

Comments
 (0)