Merge pull request #403 from rhatdan/retry
Rename internal functions to make them easier to understand
This commit is contained in:
commit
e32d0ae37f
|
|
@ -69,7 +69,7 @@ func isRetryable(err error) bool {
|
|||
}
|
||||
return isRetryable(e.Err)
|
||||
case syscall.Errno:
|
||||
return shouldRestart(e)
|
||||
return isErrnoRetryable(e)
|
||||
case errcode.Errors:
|
||||
// if this error is a group of errors, process them all in turn
|
||||
for i := range e {
|
||||
|
|
@ -94,10 +94,10 @@ func isRetryable(err error) bool {
|
|||
return false
|
||||
}
|
||||
|
||||
func shouldRestart(e error) bool {
|
||||
func isErrnoRetryable(e error) bool {
|
||||
switch e {
|
||||
case syscall.ECONNREFUSED, syscall.EINTR, syscall.EAGAIN, syscall.EBUSY, syscall.ENETDOWN, syscall.ENETUNREACH, syscall.ENETRESET, syscall.ECONNABORTED, syscall.ECONNRESET, syscall.ETIMEDOUT, syscall.EHOSTDOWN, syscall.EHOSTUNREACH:
|
||||
return true
|
||||
}
|
||||
return shouldRestartPlatform(e)
|
||||
return isErrnoERESTART(e)
|
||||
}
|
||||
|
|
|
|||
|
|
@ -4,6 +4,6 @@ import (
|
|||
"syscall"
|
||||
)
|
||||
|
||||
func shouldRestartPlatform(e error) bool {
|
||||
func isErrnoERESTART(e error) bool {
|
||||
return e == syscall.ERESTART
|
||||
}
|
||||
|
|
|
|||
|
|
@ -2,6 +2,6 @@
|
|||
|
||||
package retry
|
||||
|
||||
func shouldRestartPlatform(e error) bool {
|
||||
func isErrnoERESTART(e error) bool {
|
||||
return false
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue