Skip to content

Commit eee65f9

Browse files
authored
Backport of #16 for transport (#640)
1 parent 4dad22a commit eee65f9

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

estransport/connection.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -152,6 +152,10 @@ func (cp *statusConnectionPool) OnSuccess(c *Connection) error {
152152
c.Lock()
153153
defer c.Unlock()
154154

155+
if !c.IsDead {
156+
return nil
157+
}
158+
155159
c.markAsHealthy()
156160
return cp.resurrect(c, true)
157161
}

0 commit comments

Comments
 (0)