dht: Add counters for writes and write errors

diff --git a/dht/expvar.go b/dht/expvar.go
index 4fdf69ce8b05fdec0d32b05e9182a1909b8f7b7c..11a0a98718ccdb528f4a913b99b1d8090c12d2f5 100644 (file)
--- a/dht/expvar.go
+++ b/dht/expvar.go
@@ -11,4 +11,6 @@ var (
        readUnmarshalError = expvar.NewInt("dhtReadUnmarshalError")
        readQuery          = expvar.NewInt("dhtReadQuery")
        announceErrors     = expvar.NewInt("dhtAnnounceErrors")
+       writeErrors        = expvar.NewInt("dhtWriteErrors")
+       writes             = expvar.NewInt("dhtWrites")
 )

diff --git a/dht/server.go b/dht/server.go
index 56917292563e7dde7ce0f72b2451d209b262cb2f..bf269398349ae0d2cd3f31f65827233d188c417c 100644 (file)
--- a/dht/server.go
+++ b/dht/server.go
@@ -382,7 +382,9 @@ func (s *Server) writeToNode(b []byte, node Addr) (err error) {
                }
        }
        n, err := s.socket.WriteTo(b, node.UDPAddr())
+       writes.Add(1)
        if err != nil {
+               writeErrors.Add(1)
                err = fmt.Errorf("error writing %d bytes to %s: %s", len(b), node, err)
                return
        }