diff --git a/enterprise/kernel/src/main/java/org/neo4j/kernel/impl/enterprise/transaction/log/checkpoint/ConfigurableIOLimiter.java b/enterprise/kernel/src/main/java/org/neo4j/kernel/impl/enterprise/transaction/log/checkpoint/ConfigurableIOLimiter.java index c3050075969c..3b7c9f770e89 100644 --- a/enterprise/kernel/src/main/java/org/neo4j/kernel/impl/enterprise/transaction/log/checkpoint/ConfigurableIOLimiter.java +++ b/enterprise/kernel/src/main/java/org/neo4j/kernel/impl/enterprise/transaction/log/checkpoint/ConfigurableIOLimiter.java @@ -32,7 +32,7 @@ public class ConfigurableIOLimiter implements IOLimiter { - private static final AtomicIntegerFieldUpdater rushUpdater = + private static final AtomicIntegerFieldUpdater disableCountUpdater = AtomicIntegerFieldUpdater.newUpdater( ConfigurableIOLimiter.class, "disabledCount" ); private static final int NO_LIMIT = 0; @@ -43,7 +43,7 @@ public class ConfigurableIOLimiter implements IOLimiter private final int iopq; // IOs per quantum private final ObjLongConsumer pauseNanos; - @SuppressWarnings( "unused" ) // Updated via rushUpdater + @SuppressWarnings( "unused" ) // Updated via disableCountUpdater private volatile int disabledCount; public ConfigurableIOLimiter( Config config ) @@ -116,13 +116,13 @@ public long maybeLimitIO( long previousStamp, int recentlyCompletedIOs, Flushabl @Override public void disableLimit() { - rushUpdater.getAndIncrement( this ); + disableCountUpdater.getAndIncrement( this ); } @Override public void enableLimit() { - rushUpdater.getAndDecrement( this ); + disableCountUpdater.getAndDecrement( this ); } private long currentTimeMillis()