LBRYFoundation/reflector.go
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/reflector.go.git synced 2025-08-23 17:27:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

more specific errors

Browse source
This commit is contained in:
Alex Grintsvayg 2020-01-03 10:27:29 -05:00
parent 5c5643749e
commit 780e899e90
No known key found for this signature in database
GPG key ID: AEB3F089F86A22B5
1 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
internal/metrics/metrics.go
View file

@ -71,10 +71,13 @@ const (
errWriteConnReset = "write_conn_reset" errWriteConnReset = "write_conn_reset"
errReadConnTimedOut = "read_conn_timed_out" errReadConnTimedOut = "read_conn_timed_out"
errWriteBrokenPipe = "write_broken_pipe" errWriteBrokenPipe = "write_broken_pipe"
errEPipe = "e_pipe"
errIOTimeout = "io_timeout" errIOTimeout = "io_timeout"
errUnexpectedEOF = "unexpected_eof" errUnexpectedEOF = "unexpected_eof"
errUnexpectedEOFStr = "unexpected_eof_str"
errJSONSyntax = "json_syntax" errJSONSyntax = "json_syntax"
errBlobTooBig = "blob_too_big" errBlobTooBig = "blob_too_big"
errDeadlineExceeded = "deadline_exceeded"
errOther = "other" errOther = "other"
) )
@ -114,8 +117,9 @@ func TrackError(direction string, e error) (shouldLog bool) { // shouldLog is a
errType = errIOTimeout errType = errIOTimeout
} else if errors.Is(e, syscall.ECONNRESET) { } else if errors.Is(e, syscall.ECONNRESET) {
errType = errConnReset errType = errConnReset
} else if errors.Is(e, context.DeadlineExceeded) {
errType = errDeadlineExceeded
} else if strings.Contains(err.Error(), "read: connection reset by peer") { // the other side closed the connection using TCP reset } else if strings.Contains(err.Error(), "read: connection reset by peer") { // the other side closed the connection using TCP reset
log.Warnln("read conn reset by peer is not the same as ECONNRESET")
errType = errReadConnReset errType = errReadConnReset
} else if strings.Contains(err.Error(), "write: connection reset by peer") { // the other side closed the connection using TCP reset } else if strings.Contains(err.Error(), "write: connection reset by peer") { // the other side closed the connection using TCP reset
log.Warnln("write conn reset by peer is not the same as ECONNRESET") log.Warnln("write conn reset by peer is not the same as ECONNRESET")
@ -128,12 +132,10 @@ func TrackError(direction string, e error) (shouldLog bool) { // shouldLog is a
} else if errors.Is(e, io.ErrUnexpectedEOF) { } else if errors.Is(e, io.ErrUnexpectedEOF) {
errType = errUnexpectedEOF errType = errUnexpectedEOF
} else if strings.Contains(err.Error(), "unexpected EOF") { // tried to read from closed pipe or socket } else if strings.Contains(err.Error(), "unexpected EOF") { // tried to read from closed pipe or socket
log.Warnln("unexpected eof is not the same as io.ErrUnexpectedEOF") errType = errUnexpectedEOFStr
errType = errUnexpectedEOF
} else if errors.Is(e, syscall.EPIPE) { } else if errors.Is(e, syscall.EPIPE) {
errType = errWriteBrokenPipe errType = errEPipe
} else if strings.Contains(err.Error(), "write: broken pipe") { // tried to write to a pipe or socket that was closed by the peer } else if strings.Contains(err.Error(), "write: broken pipe") { // tried to write to a pipe or socket that was closed by the peer
log.Warnln("broken pipe is not the same as EPIPE")
errType = errWriteBrokenPipe errType = errWriteBrokenPipe
//} else if errors.Is(e, reflector.ErrBlobTooBig) { # this creates a circular import //} else if errors.Is(e, reflector.ErrBlobTooBig) { # this creates a circular import
// errType = errBlobTooBig // errType = errBlobTooBig