Skip to content

Commit

Permalink
Fix typo in class name.
Browse files Browse the repository at this point in the history
  • Loading branch information
jimwebber committed Feb 17, 2016
1 parent 2fd1130 commit 668956d
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 9 deletions.
Expand Up @@ -21,11 +21,11 @@


import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;


public class ExpontentialBackoffStrategy implements RetryStrategy public class ExponentialBackoffStrategy implements RetryStrategy
{ {
private final long initialBackoffTimeMillis; private final long initialBackoffTimeMillis;


public ExpontentialBackoffStrategy( long initialBackoffTime, TimeUnit timeUnit ) public ExponentialBackoffStrategy( long initialBackoffTime, TimeUnit timeUnit )
{ {
initialBackoffTimeMillis = timeUnit.toMillis( initialBackoffTime ); initialBackoffTimeMillis = timeUnit.toMillis( initialBackoffTime );
} }
Expand Down
Expand Up @@ -64,7 +64,7 @@
import org.neo4j.coreedge.raft.replication.token.ReplicatedRelationshipTypeTokenHolder; import org.neo4j.coreedge.raft.replication.token.ReplicatedRelationshipTypeTokenHolder;
import org.neo4j.coreedge.raft.replication.tx.CommittingTransactions; import org.neo4j.coreedge.raft.replication.tx.CommittingTransactions;
import org.neo4j.coreedge.raft.replication.tx.CommittingTransactionsRegistry; import org.neo4j.coreedge.raft.replication.tx.CommittingTransactionsRegistry;
import org.neo4j.coreedge.raft.replication.tx.ExpontentialBackoffStrategy; import org.neo4j.coreedge.raft.replication.tx.ExponentialBackoffStrategy;
import org.neo4j.coreedge.raft.replication.tx.ReplicatedTransactionCommitProcess; import org.neo4j.coreedge.raft.replication.tx.ReplicatedTransactionCommitProcess;
import org.neo4j.coreedge.raft.replication.tx.ReplicatedTransactionStateMachine; import org.neo4j.coreedge.raft.replication.tx.ReplicatedTransactionStateMachine;
import org.neo4j.coreedge.raft.roles.Role; import org.neo4j.coreedge.raft.roles.Role;
Expand Down Expand Up @@ -386,7 +386,7 @@ public static CommitProcessFactory createCommitProcessFactory(
stateMachines.add( replicatedTxStateMachine ); stateMachines.add( replicatedTxStateMachine );


return new ReplicatedTransactionCommitProcess( replicator, localSessionPool, return new ReplicatedTransactionCommitProcess( replicator, localSessionPool,
new ExpontentialBackoffStrategy( 10, TimeUnit.SECONDS ), logging, committingTransactions, monitors new ExponentialBackoffStrategy( 10, TimeUnit.SECONDS ), logging, committingTransactions, monitors
); );
}; };
} }
Expand Down
Expand Up @@ -82,7 +82,7 @@ public void shouldAlwaysCompleteFutureEvenIfReplicationHappensAtUnfortunateMomen
stateMachines.add( stateMachine ); stateMachines.add( stateMachine );


ReplicatedTransactionCommitProcess commitProcess = new ReplicatedTransactionCommitProcess( ReplicatedTransactionCommitProcess commitProcess = new ReplicatedTransactionCommitProcess(
replicator, sessionPool, new ExpontentialBackoffStrategy( 10, SECONDS ), replicator, sessionPool, new ExponentialBackoffStrategy( 10, SECONDS ),
NullLogService.getInstance(), txFutures, new Monitors() ); NullLogService.getInstance(), txFutures, new Monitors() );


// when // when
Expand Down Expand Up @@ -114,7 +114,7 @@ public void shouldFailTransactionIfLockSessionChanges() throws Exception
stateMachines.add( stateMachine ); stateMachines.add( stateMachine );


ReplicatedTransactionCommitProcess commitProcess = new ReplicatedTransactionCommitProcess( ReplicatedTransactionCommitProcess commitProcess = new ReplicatedTransactionCommitProcess(
replicator, sessionPool, new ExpontentialBackoffStrategy( 10, SECONDS ), replicator, sessionPool, new ExponentialBackoffStrategy( 10, SECONDS ),
NullLogService.getInstance(), txFutures, new Monitors() ); NullLogService.getInstance(), txFutures, new Monitors() );


// when // when
Expand Down
Expand Up @@ -25,15 +25,15 @@


import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;


public class ExpontentialBackoffStrategyTest public class ExponentialBackoffStrategyTest
{ {
private static final int NUMBER_OF_ACCESSES = 5; private static final int NUMBER_OF_ACCESSES = 5;


@Test @Test
public void shouldDoubleEachTime() throws Exception public void shouldDoubleEachTime() throws Exception
{ {
// given // given
ExpontentialBackoffStrategy strategy = new ExpontentialBackoffStrategy( 1, MILLISECONDS ); ExponentialBackoffStrategy strategy = new ExponentialBackoffStrategy( 1, MILLISECONDS );
RetryStrategy.Timeout timeout = strategy.newTimeout(); RetryStrategy.Timeout timeout = strategy.newTimeout();


// when // when
Expand All @@ -50,7 +50,7 @@ public void shouldDoubleEachTime() throws Exception
public void shouldProvidePreviousTimeout() throws Exception public void shouldProvidePreviousTimeout() throws Exception
{ {
// given // given
ExpontentialBackoffStrategy strategy = new ExpontentialBackoffStrategy( 1, MILLISECONDS ); ExponentialBackoffStrategy strategy = new ExponentialBackoffStrategy( 1, MILLISECONDS );
RetryStrategy.Timeout timeout = strategy.newTimeout(); RetryStrategy.Timeout timeout = strategy.newTimeout();


// when // when
Expand Down

0 comments on commit 668956d

Please sign in to comment.