From 1ae2d3371498ba28c83267a9e6071da11fd5a40b Mon Sep 17 00:00:00 2001 From: Bryan Boreham Date: Wed, 12 Oct 2016 17:02:48 +0100 Subject: [PATCH] Remove old-style 'expvar' metrics --- ipam/ring/expvar.go | 31 ------------------------------- ipam/ring/ring.go | 6 ------ 2 files changed, 37 deletions(-) delete mode 100644 ipam/ring/expvar.go diff --git a/ipam/ring/expvar.go b/ipam/ring/expvar.go deleted file mode 100644 index 9ba8c8ea..00000000 --- a/ipam/ring/expvar.go +++ /dev/null @@ -1,31 +0,0 @@ -package ring - -/* Exported variables for monitoring and management */ - -import ( - "expvar" - "strconv" -) - -var ( - expRingSize = expvar.NewMap("ipam.ringSize") - expRingEntries = expvar.NewMap("ipam.ringEntries") -) - -type _int int - -func (i _int) String() string { - return strconv.Itoa(int(i)) -} - -type _uint32 uint32 - -func (i _uint32) String() string { - return strconv.FormatUint(uint64(i), 10) -} - -func (r *Ring) updateExportedVariables() { - ringName := r.Start.String() - expRingSize.Set(ringName, _uint32(r.End-r.Start)) - expRingEntries.Set(ringName, _int(len(r.Entries))) -} diff --git a/ipam/ring/ring.go b/ipam/ring/ring.go index 1d3c10b2..65882af3 100644 --- a/ipam/ring/ring.go +++ b/ipam/ring/ring.go @@ -114,7 +114,6 @@ func New(start, end address.Address, peer mesh.PeerName, f OnUpdate) *Ring { common.Assert(start < end) ring := &Ring{Start: start, End: end, Peer: peer, Entries: make([]*entry, 0), onUpdate: f} - ring.updateExportedVariables() return ring } @@ -151,7 +150,6 @@ func (r *Ring) GrantRangeToHost(start, end address.Address, peer mesh.PeerName) r.assertInvariants() defer r.trackUpdates()() defer r.assertInvariants() - defer r.updateExportedVariables() // ----------------- Start of Checks ----------------- @@ -218,7 +216,6 @@ func (r *Ring) GrantRangeToHost(start, end address.Address, peer mesh.PeerName) func (r *Ring) Merge(gossip Ring) (bool, error) { r.assertInvariants() defer r.trackUpdates()() - defer r.updateExportedVariables() // Don't panic when checking the gossiped in ring. // In this case just return any error found. @@ -404,7 +401,6 @@ func (r *Ring) ClaimForPeers(peers []mesh.PeerName) { defer r.trackUpdates()() defer r.assertInvariants() - defer r.updateExportedVariables() defer func() { e := r.Entries[len(r.Entries)-1] common.Assert(address.Add(e.Token, address.Offset(e.Free)) == r.End) @@ -455,7 +451,6 @@ func (r *Ring) String() string { func (r *Ring) ReportFree(freespace map[address.Address]address.Count) (updated bool) { r.assertInvariants() defer r.assertInvariants() - defer r.updateExportedVariables() common.Assert(!r.Empty()) entries := r.Entries @@ -564,7 +559,6 @@ func (r *Ring) Transfer(from, to mesh.PeerName) []address.Range { defer r.trackUpdates()() defer r.trackUpdatesOfPeer(from)() defer r.assertInvariants() - defer r.updateExportedVariables() var newRanges []address.Range