Skip to content

Commit

Permalink
Address the comment
Browse files Browse the repository at this point in the history
Signed-off-by: JmPotato <[email protected]>
  • Loading branch information
JmPotato committed Dec 25, 2024
1 parent e7bc6d8 commit 192f36e
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions client/clients/tso/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -456,11 +456,11 @@ func (c *Cli) tryConnectToTSOWithProxy(ctx context.Context) error {
return errors.Errorf("cannot find the tso leader")
}
// GC the stale one.
c.conCtxMgr.GC(func(url string) bool {
_, ok := tsoStreamBuilders[url]
c.conCtxMgr.GC(func(addr string) bool {
_, ok := tsoStreamBuilders[addr]
if !ok {
log.Info("[tso] remove the stale tso stream",
zap.String("addr", url))
zap.String("addr", addr))

Check warning on line 463 in client/clients/tso/client.go

View check run for this annotation

Codecov / codecov/patch

client/clients/tso/client.go#L463

Added line #L463 was not covered by tests
}
return !ok
})
Expand Down

0 comments on commit 192f36e

Please sign in to comment.