Slight reordering of operations, simply for readability purposes

neo4j · Nov 30, 2015 · 453107f · 453107f
1 parent 8d372cf
commit 453107f
Showing 1 changed file with 13 additions and 13 deletions.
diff --git a/...e/core-edge/src/main/java/org/neo4j/coreedge/server/core/EnterpriseCoreEditionModule.java b/...e/core-edge/src/main/java/org/neo4j/coreedge/server/core/EnterpriseCoreEditionModule.java
@@ -27,6 +27,8 @@
 
 import org.neo4j.coreedge.catchup.StoreIdSupplier;
 import org.neo4j.coreedge.catchup.CatchupServer;
+import org.neo4j.coreedge.raft.state.TermStore;
+import org.neo4j.coreedge.raft.state.VoteStore;
 import org.neo4j.coreedge.server.CoreEdgeClusterSettings;
 import org.neo4j.coreedge.catchup.CheckpointerSupplier;
 import org.neo4j.coreedge.catchup.DataSourceSupplier;
@@ -162,20 +164,20 @@ public EnterpriseCoreEditionModule( final PlatformModule platformModule,
         LoggingOutbound<AdvertisedSocketAddress> loggingOutbound = new LoggingOutbound<>(
                 senderService, myself.getRaftAddress(), messageLogger );
 
-        File raftLogsDirectory = createRaftLogsDirectory( platformModule.storeDir, fileSystem );
-
-        RaftLog raftLog = new NaiveDurableRaftLog( fileSystem, raftLogsDirectory, new RaftContentSerializer(),
-                platformModule.monitors );
-        dependencies.satisfyDependencies( raftLog );
-
         ListenSocketAddress raftListenAddress = config.get( CoreEdgeClusterSettings.raft_listen_address );
         RaftServer<CoreMember> raftServer = new RaftServer<>( marshall, raftListenAddress, logProvider );
 
         final ScheduledTimeoutService raftTimeoutService = new ScheduledTimeoutService();
 
-        raft = createRaft( life, loggingOutbound, discoveryService, config,
+        File raftLogsDirectory = createRaftLogsDirectory( platformModule.storeDir, fileSystem );
-                messageLogger, raftLog, myself, raftLogsDirectory, fileSystem, logProvider, raftServer,
+        NaiveDurableRaftLog raftLog = new NaiveDurableRaftLog( fileSystem, raftLogsDirectory, new RaftContentSerializer(),
-                raftTimeoutService );
+                platformModule.monitors );
+
+        DurableTermStore termStore = new DurableTermStore( fileSystem, raftLogsDirectory );
+        DurableVoteStore voteStore = new DurableVoteStore( fileSystem, raftLogsDirectory );
+
+        raft = createRaft( life, loggingOutbound, discoveryService, config, messageLogger, raftLog,
+                termStore, voteStore, myself, logProvider, raftServer, raftTimeoutService );
 
         RaftReplicator<CoreMember> replicator = new RaftReplicator<>( raft, myself,
                 new RaftOutbound( loggingOutbound ) );
@@ -308,9 +310,9 @@ private static RaftInstance<CoreMember> createRaft( LifeSupport life,
                                                         Config config,
                                                         MessageLogger<AdvertisedSocketAddress> messageLogger,
                                                         RaftLog raftLog,
+                                                        TermStore termStore,
+                                                        VoteStore voteStore,
                                                         CoreMember myself,
-                                                        File raftLogsDirectory,
-                                                        FileSystemAbstraction fileSystem,
                                                         LogProvider logProvider,
                                                         RaftServer<CoreMember> raftServer,
                                                         ScheduledTimeoutService raftTimeoutService )
@@ -326,8 +328,6 @@ private static RaftInstance<CoreMember> createRaft( LifeSupport life,
 
         CoreMemberSetBuilder memberSetBuilder = new CoreMemberSetBuilder();
 
-        DurableTermStore termStore = new DurableTermStore( fileSystem, raftLogsDirectory );
-        DurableVoteStore voteStore = new DurableVoteStore( fileSystem, raftLogsDirectory );
 
         Replicator localReplicator = new LocalReplicator<>( myself, myself.getRaftAddress(), outbound );