renaming

vladimir-bukhtoyarov · Apr 29, 2016 · f1708d6 · f1708d6
1 parent 00e0aaa
commit f1708d6
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/main/java/com/github/metricscore/hdrhistogram/accumulator/ResetByChunksAccumulator.java b/src/main/java/com/github/metricscore/hdrhistogram/accumulator/ResetByChunksAccumulator.java
@@ -72,7 +72,7 @@ public ResetByChunksAccumulator(Supplier<Recorder> recorderSupplier, int numberC
     @Override
     public void recordSingleValueWithExpectedInterval(long value, long expectedIntervalBetweenValueSamples) {
         long currentTimeMillis = clock.getTime();
-        recordValue(value, expectedIntervalBetweenValueSamples, currentTimeMillis, true);
+        recordOrTouch(value, expectedIntervalBetweenValueSamples, currentTimeMillis, true);
     }
 
     @Override
@@ -92,7 +92,7 @@ public final synchronized Snapshot getSnapshot(Function<Histogram, Snapshot> sna
                 if (phase.proposedInvalidationTimestamp <= currentTimeMillis) {
                     // detected that reservoir was unused by writer for a long time
                     // lets record fake value in order to trigger the rotation process
-                    recordValue(FAKE_VALUE, 0, currentTimeMillis, false);
+                    recordOrTouch(FAKE_VALUE, 0, currentTimeMillis, false);
                 }
                 if (reportUncompletedChunkToSnapshot) {
                     phase.intervalHistogram = phase.recorder.getIntervalHistogram(phase.intervalHistogram);
@@ -117,17 +117,17 @@ public final synchronized Snapshot getSnapshot(Function<Histogram, Snapshot> sna
         return snapshotTaker.apply(temporarySnapshotHistogram);
     }
 
-    private void recordValue(long value, long expectedIntervalBetweenValueSamples, long currentTimeMillis, boolean currentThreadIsWriter) {
+    private void recordOrTouch(long value, long expectedIntervalBetweenValueSamples, long currentTimeMillis, boolean currentThreadIsWriter) {
         Phase currentPhase = currentPhaseRef.get();
         if (currentTimeMillis < currentPhase.proposedInvalidationTimestamp) {
-            if (value != FAKE_VALUE) {
+            if (currentThreadIsWriter) {
                 currentPhase.recorder.recordValueWithExpectedInterval(value, expectedIntervalBetweenValueSamples);
             }
             return;
         }
 
         Phase nextPhase = currentPhase == left ? right : left;
-        if (value != FAKE_VALUE) {
+        if (currentThreadIsWriter) {
             nextPhase.recorder.recordValueWithExpectedInterval(value, expectedIntervalBetweenValueSamples);
         }
         if (!currentPhaseRef.compareAndSet(currentPhase, nextPhase)) {