From a4638ad514b0ea8937b04adfac2f4c38493809df Mon Sep 17 00:00:00 2001 From: Philip O'Toole Date: Sat, 21 Aug 2021 23:35:56 -0400 Subject: [PATCH] Set Raft Adv once and for all --- cmd/rqlited/main.go | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/cmd/rqlited/main.go b/cmd/rqlited/main.go index dbb1eb04..ed4bd552 100644 --- a/cmd/rqlited/main.go +++ b/cmd/rqlited/main.go @@ -156,6 +156,11 @@ func main() { os.Exit(1) } + // Ensure Raft adv address is set as per policy. + if raftAdv == "" { + raftAdv = raftAddr + } + dataPath := flag.Arg(0) // Display logo. @@ -265,10 +270,6 @@ func main() { // Execute any requested join operation. if len(joins) > 0 { log.Println("join addresses are:", joins) - advAddr := raftAddr - if raftAdv != "" { - advAddr = raftAdv - } joinDur, err := time.ParseDuration(joinInterval) if err != nil { @@ -288,7 +289,7 @@ func main() { } } - if j, err := cluster.Join(joinSrcIP, joins, str.ID(), advAddr, !raftNonVoter, + if j, err := cluster.Join(joinSrcIP, joins, str.ID(), raftAdv, !raftNonVoter, joinAttempts, joinDur, &tlsConfig); err != nil { log.Fatalf("failed to join cluster at %s: %s", joins, err.Error()) } else { @@ -467,9 +468,6 @@ func idOrRaftAddr() string { if nodeID != "" { return nodeID } - if raftAdv == "" { - return raftAddr - } return raftAdv }