github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-02-09 15:27:11 +00:00
Code Issues Projects Releases Packages Wiki Activity

lib/netutil: do not count timeouts as network errors

Browse source
This commit is contained in:
Aliaksandr Valialkin 2019-07-15 23:05:35 +03:00
parent 575d2f0a91
commit daba0cdb05
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
lib/netutil/conn.go
View file

@ -72,9 +72,10 @@ func (sc *statConn) Read(p []byte) (int, error) {
sc.cm.readCalls.Inc() sc.cm.readCalls.Inc()
sc.cm.readBytes.Add(n) sc.cm.readBytes.Add(n)
if err != nil && err != io.EOF { if err != nil && err != io.EOF {
sc.cm.readErrors.Inc()
if ne, ok := err.(net.Error); ok && ne.Timeout() { if ne, ok := err.(net.Error); ok && ne.Timeout() {
sc.cm.readTimeouts.Inc() sc.cm.readTimeouts.Inc()
} else {
sc.cm.readErrors.Inc()
} }
} }
return n, err return n, err
@ -96,9 +97,10 @@ func (sc *statConn) Write(p []byte) (int, error) {
sc.cm.writeCalls.Inc() sc.cm.writeCalls.Inc()
sc.cm.writtenBytes.Add(n) sc.cm.writtenBytes.Add(n)
if err != nil { if err != nil {
sc.cm.writeErrors.Inc()
if ne, ok := err.(net.Error); ok && ne.Timeout() { if ne, ok := err.(net.Error); ok && ne.Timeout() {
sc.cm.writeTimeouts.Inc() sc.cm.writeTimeouts.Inc()
} else {
sc.cm.writeErrors.Inc()
} }
} }
return n, err return n, err