Skip to content

Commit

Permalink
Rename field forgotten in refactoring
Browse files Browse the repository at this point in the history
  • Loading branch information
chrisvest committed Mar 8, 2016
1 parent ca69953 commit 9448042
Showing 1 changed file with 4 additions and 4 deletions.
Expand Up @@ -32,7 +32,7 @@


public class ConfigurableIOLimiter implements IOLimiter public class ConfigurableIOLimiter implements IOLimiter
{ {
private static final AtomicIntegerFieldUpdater<ConfigurableIOLimiter> rushUpdater = private static final AtomicIntegerFieldUpdater<ConfigurableIOLimiter> disableCountUpdater =
AtomicIntegerFieldUpdater.newUpdater( ConfigurableIOLimiter.class, "disabledCount" ); AtomicIntegerFieldUpdater.newUpdater( ConfigurableIOLimiter.class, "disabledCount" );


private static final int NO_LIMIT = 0; private static final int NO_LIMIT = 0;
Expand All @@ -43,7 +43,7 @@ public class ConfigurableIOLimiter implements IOLimiter
private final int iopq; // IOs per quantum private final int iopq; // IOs per quantum
private final ObjLongConsumer<Object> pauseNanos; private final ObjLongConsumer<Object> pauseNanos;


@SuppressWarnings( "unused" ) // Updated via rushUpdater @SuppressWarnings( "unused" ) // Updated via disableCountUpdater
private volatile int disabledCount; private volatile int disabledCount;


public ConfigurableIOLimiter( Config config ) public ConfigurableIOLimiter( Config config )
Expand Down Expand Up @@ -116,13 +116,13 @@ public long maybeLimitIO( long previousStamp, int recentlyCompletedIOs, Flushabl
@Override @Override
public void disableLimit() public void disableLimit()
{ {
rushUpdater.getAndIncrement( this ); disableCountUpdater.getAndIncrement( this );
} }


@Override @Override
public void enableLimit() public void enableLimit()
{ {
rushUpdater.getAndDecrement( this ); disableCountUpdater.getAndDecrement( this );
} }


private long currentTimeMillis() private long currentTimeMillis()
Expand Down

0 comments on commit 9448042

Please sign in to comment.