From 3b32db998dd857afed5d56d7523e5199d848ced9 Mon Sep 17 00:00:00 2001 From: Todd Gruben Date: Thu, 7 Jul 2016 11:22:15 -0500 Subject: [PATCH] ignore checksum on single node clusters --- fragment.go | 8 ++++++-- handler.go | 2 ++ 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/fragment.go b/fragment.go index 4c9be2782..db934841e 100644 --- a/fragment.go +++ b/fragment.go @@ -1189,13 +1189,17 @@ func (s *FragmentSyncer) isClosing() bool { func (s *FragmentSyncer) SyncFragment() error { // Determine replica set. nodes := s.Cluster.FragmentNodes(s.Fragment.DB(), s.Fragment.Slice()) - + if len(nodes) == 1 { + //fmt.Println("no place to replicate", s.Fragment.DB(), s.Fragment.Frame(), s.Fragment.Slice()) + return nil + } // Create a set of blocks. blockSets := make([][]FragmentBlock, 0, len(nodes)) for _, node := range nodes { // Read local blocks. if node.Host == s.Host { - blockSets = append(blockSets, s.Fragment.Blocks()) + b := s.Fragment.Blocks() + blockSets = append(blockSets, b) continue } diff --git a/handler.go b/handler.go index 2c1510d53..fe4cecd85 100644 --- a/handler.go +++ b/handler.go @@ -59,6 +59,8 @@ func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) { pprof.Profile(w, r) case "/debug/pprof/symbol": pprof.Symbol(w, r) + case "/debug/pprof/trace": + pprof.Trace(w, r) default: pprof.Index(w, r) }