diff options
Diffstat (limited to 'transport/failover.go')
| -rw-r--r-- | transport/failover.go | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/transport/failover.go b/transport/failover.go index 77129a3..c2981f0 100644 --- a/transport/failover.go +++ b/transport/failover.go @@ -53,10 +53,6 @@ func NewFailoverTransport(transports []Transport, config *FailoverConfig) *Failo // Connect attempts to connect using transports in priority order func (ft *FailoverTransport) Connect(address string) (net.Conn, error) { - ft.mu.Lock() - startIndex := ft.currentIndex - ft.mu.Unlock() - // Try each transport in order for attempt := 0; attempt < len(ft.transports)*ft.maxRetries; attempt++ { ft.mu.Lock() |