Skip to content

Commit

Permalink
feat: check if failovertimer already initialized
Browse files Browse the repository at this point in the history
  • Loading branch information
Abdulsametileri committed Nov 2, 2023
1 parent 320f2c9 commit a46a3f4
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions couchbase/rollback_mitigation.go
Original file line number Diff line number Diff line change
Expand Up @@ -220,6 +220,10 @@ func (r *rollbackMitigation) startObserve(groupID int) {
}

func (r *rollbackMitigation) observeVbUUIDMap() {
if r.failOverUUIDTimer != nil {
return
}

r.failOverUUIDTimer = time.NewTicker(time.Minute)
for range r.failOverUUIDTimer.C {
r.LoadVbUUIDMap()
Expand Down

0 comments on commit a46a3f4

Please sign in to comment.