From 25fea2fd9f78434299036fe3a23c65dc9613f0bb Mon Sep 17 00:00:00 2001 From: Ben Johnson Date: Fri, 2 May 2014 13:59:23 -0600 Subject: Refactor split/spill. --- tx.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) (limited to 'tx.go') diff --git a/tx.go b/tx.go index 612f493..7cdadae 100644 --- a/tx.go +++ b/tx.go @@ -363,8 +363,9 @@ type TxStats struct { Rebalance int // number of node rebalances RebalanceTime time.Duration // total time spent rebalancing - // Spill statistics. - Spill int // number of node spilled + // Split/Spill statistics. + Split int // number of nodes split + Spill int // number of nodes spilled SpillTime time.Duration // total time spent spilling // Write statistics. @@ -380,6 +381,7 @@ func (s *TxStats) add(other *TxStats) { s.NodeDeref += other.NodeDeref s.Rebalance += other.Rebalance s.RebalanceTime += other.RebalanceTime + s.Split += other.Split s.Spill += other.Spill s.SpillTime += other.SpillTime s.Write += other.Write @@ -398,6 +400,7 @@ func (s *TxStats) Sub(other *TxStats) TxStats { diff.NodeDeref = s.NodeDeref - other.NodeDeref diff.Rebalance = s.Rebalance - other.Rebalance diff.RebalanceTime = s.RebalanceTime - other.RebalanceTime + diff.Split = s.Split - other.Split diff.Spill = s.Spill - other.Spill diff.SpillTime = s.SpillTime - other.SpillTime diff.Write = s.Write - other.Write -- cgit v1.2.3