}
		}
	}
}

// time a scanner action.
// Use for s < scannerMetricLastRealtime
func (p *scannerMetrics) time(s scannerMetric) func() {
	startTime := time.Now()
	return func() {
		duration := time.Since(startTime)

		atomic.AddUint64(&p.operations[s], 1)
		if s < scannerMetricLastRealtime {
			p.latency[s].add(duration)
		}
	}
}

// timeSize add time and size of a scanner action.

    @RetainedLocalRef Future<?> localTimer = timer;
    // Try to cancel the timer as an optimization.
    // timer may be null if this call to run was by the timer task since there is no happens-before
    // edge between the assignment to timer and an execution of the timer task.
    if (localTimer != null) {
      localTimer.cancel(false);
    }

    delegateRef = null;
    timer = null;
  }

Russ Cox <******@****.***> 1511973652 -0500

Joe Tsai <******@****.***> 1503947278 -0700

Joe Tsai <******@****.***> 1503947278 -0700

Joe Tsai <******@****.***> 1503947278 -0700

Joe Tsai <******@****.***> 1503947278 -0700

Joe Tsai <******@****.***> 1503947278 -0700

Joe Tsai <******@****.***> 1503947278 -0700

Joe Tsai <******@****.***> 1503947278 -0700