From b98c1a7edc7270effd3040cafc7ac1b5069be813 Mon Sep 17 00:00:00 2001
From: Matt Joiner <anacrolix@gmail.com>
Date: Sat, 23 Jul 2016 22:39:06 +1000
Subject: [PATCH] dht: Add counters for writes and write errors

---
 dht/expvar.go | 2 ++
 dht/server.go | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/dht/expvar.go b/dht/expvar.go
index 4fdf69ce..11a0a987 100644
--- 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 56917292..bf269398 100644
--- 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
 	}
-- 
2.48.1