Skip to content

Commit e783c4f

Browse files
authored
REP-5337 Don’t mongos-refresh on pre-v5 clusters. (#73)
PR #64 introduced a bug where it would try to refresh mongoses regardless of server version. This fixes that by only refreshing mongoses for pre-v5 server versions.
1 parent 545a21e commit e783c4f

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

internal/verifier/uri.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ func (verifier *Verifier) SetSrcURI(ctx context.Context, uri string) error {
2424

2525
verifier.srcClusterInfo = &clusterInfo
2626

27-
if clusterInfo.Topology == util.TopologySharded {
27+
if clusterInfo.VersionArray[0] < 5 && clusterInfo.Topology == util.TopologySharded {
2828
err := RefreshAllMongosInstances(
2929
ctx,
3030
verifier.logger,
@@ -57,7 +57,7 @@ func (verifier *Verifier) SetDstURI(ctx context.Context, uri string) error {
5757

5858
verifier.dstClusterInfo = &clusterInfo
5959

60-
if clusterInfo.Topology == util.TopologySharded {
60+
if clusterInfo.VersionArray[0] < 5 && clusterInfo.Topology == util.TopologySharded {
6161
err := RefreshAllMongosInstances(
6262
ctx,
6363
verifier.logger,
@@ -67,7 +67,7 @@ func (verifier *Verifier) SetDstURI(ctx context.Context, uri string) error {
6767
if err != nil {
6868
return errors.Wrap(
6969
err,
70-
"failed to refresh source mongos instances",
70+
"failed to refresh destination mongos instances",
7171
)
7272
}
7373
}

0 commit comments

Comments
 (0)