gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-16 19:14:41 -07:00
Code Issues Packages Projects Releases Wiki Activity

Changed "return" to "continue"

Browse Source 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
This commit is contained in:
Ivan Kozlovic
2022-07-27 18:23:54 -06:00
parent 38727417df
commit 5786d2d9d6
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server/jetstream_cluster.go
View File

@@ -3737,7 +3737,7 @@ func (js *jetStream) monitorConsumer(o *consumer, ca *consumerAssignment) {
// We set the state on the stream assignment update below.
replicas, err := o.replica()
if err != nil {
return
continue
}
if isLeader && len(rg.Peers) != replicas {
startMigrationMonitoring()
@@ -3755,7 +3755,7 @@ func (js *jetStream) monitorConsumer(o *consumer, ca *consumerAssignment) {
// If we are migrating, monitor for the new peers to be caught up.
replicas, err := o.replica()
if err != nil {
return
continue
}
if isLeader && len(rg.Peers) != replicas {
startMigrationMonitoring()
@@ -3771,7 +3771,7 @@ func (js *jetStream) monitorConsumer(o *consumer, ca *consumerAssignment) {
rg := o.raftGroup()
replicas, err := o.replica()
if err != nil {
return
continue
}
if len(rg.Peers) <= replicas {
// Migration no longer happening, so not our job anymore