scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-08-28 10:54:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #6 from linhvo/entropy

Browse source 
add entropy statsD
This commit is contained in:
Michael Baird 2017-04-25 10:43:49 -05:00 • committed by GitHub
commit 6cacf5d0dc
2 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
fragment.go
View file

@ -1376,11 +1376,11 @@ func (s *FragmentSyncer) SyncFragment() error {
if byteSlicesEqual(checksums) {
continue
}
// Synchronize block.
if err := s.syncBlock(blockID); err != nil {
return fmt.Errorf("sync block: id=%d, err=%s", blockID, err)
}
s.Fragment.stats.Count("BlockRepair", 1)
}
return nil

5
server.go
View file

@ -171,6 +171,7 @@ func (s *Server) Addr() net.Addr {
func (s *Server) logger() *log.Logger { return log.New(s.LogOutput, "", log.LstdFlags) }
func (s *Server) monitorAntiEntropy() {
t := time.Now()
ticker := time.NewTicker(s.AntiEntropyInterval)
defer ticker.Stop()
@ -182,6 +183,7 @@ func (s *Server) monitorAntiEntropy() {
case <-s.closing:
return
case <-ticker.C:
s.Holder.Stats.Count("AntiEntropy", 1)
}
s.logger().Printf("holder sync beginning")
@ -199,9 +201,12 @@ func (s *Server) monitorAntiEntropy() {
continue
}
// Record successful sync in log.
s.logger().Printf("holder sync complete")
}
dif := time.Since(t)
s.Holder.Stats.Histogram("AntiEntropyDuration", float64(dif))
}
// monitorMaxSlices periodically pulls the highest slice from each node in the cluster.