SagerNet/sing
1
0
Fork 0
mirror of https://github.com/SagerNet/sing.git synced 2025-04-06 21:37:38 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Define TimeoutError interface

Browse source
This commit is contained in:
世界 2022-05-08 19:41:45 +08:00
parent 81484131e3
commit 3acb9463b4
No known key found for this signature in database
GPG key ID: CD109927C34A63C4
1 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

8
common/exceptions/error.go
View file

@ -50,6 +50,10 @@ func IsClosed(err error) bool {
return IsTimeout(err) || errors.Is(err, io.EOF) || errors.Is(err, net.ErrClosed) || errors.Is(err, syscall.EPIPE) return IsTimeout(err) || errors.Is(err, io.EOF) || errors.Is(err, net.ErrClosed) || errors.Is(err, syscall.EPIPE)
} }
type TimeoutError interface {
Timeout() bool
}
func IsTimeout(err error) bool { func IsTimeout(err error) bool {
if unwrapErr := errors.Unwrap(err); unwrapErr != nil { if unwrapErr := errors.Unwrap(err); unwrapErr != nil {
err = unwrapErr err = unwrapErr
@ -57,9 +61,7 @@ func IsTimeout(err error) bool {
if ne, ok := err.(*os.SyscallError); ok { if ne, ok := err.(*os.SyscallError); ok {
err = ne.Err err = ne.Err
} }
if timeoutErr, isTimeoutErr := err.(interface { if timeoutErr, isTimeoutErr := err.(TimeoutError); isTimeoutErr {
Timeout() bool
}); isTimeoutErr {
return timeoutErr.Timeout() return timeoutErr.Timeout()
} }
return false return false