ZOOKEEPER-1293. Remove unused readyToStart from Leader.java (Alex Shraer via phunt)

git-svn-id: https://svn.apache.org/repos/asf/zookeeper/trunk@1227927 13f79535-47bb-0310-9956-ffa450edef68

CHANGES.txt

@@ -174,6 +174,8 @@ IMPROVEMENTS:
   ZOOKEEPER-1345. Add a .gitignore file with general exclusions and
   Eclipse project files excluded (Harsh J via phunt)
 
+  ZOOKEEPER-1293. Remove unused readyToStart from Leader.java
+  (Alex Shraer via phunt)
 
 Release 3.4.0 - 
 

src/java/main/org/apache/zookeeper/server/quorum/Leader.java

@@ -75,7 +75,7 @@ public class Leader {
     final QuorumPeer self;
 
     // the follower acceptor thread
-    LearnerCnxAcceptor cnxAcceptor;
+    volatile LearnerCnxAcceptor cnxAcceptor = null;
 
     // list of all the followers
     public final HashSet<LearnerHandler> learners =
@@ -280,7 +280,6 @@ public class Leader {
 
     long epoch = -1;
     boolean waitingForNewEpoch = true;
-    volatile boolean readyToStart = false;
 
     /**
      * This method is main function that is called to lead
@@ -309,7 +308,6 @@ public class Leader {
             cnxAcceptor.setName("LearnerCnxAcceptor-" + ss.getLocalSocketAddress());
             cnxAcceptor.start();
 
-            readyToStart = true;
             long epoch = getEpochToPropose(self.getId(), self.getAcceptedEpoch());            
 
             zk.setZxid(ZxidUtils.makeZxid(epoch, 0));

src/java/test/org/apache/zookeeper/server/quorum/Zab1_0Test.java

@@ -229,7 +229,6 @@ public class Zab1_0Test {
             FollowerMockThread f2 = new FollowerMockThread(2, leader, false);
 
             // things needed for waitForEpochAck to run (usually in leader.lead(), but we're not running leader here)
-            leader.readyToStart = true;
             leader.leaderStateSummary = new StateSummary(leader.self.getCurrentEpoch(), leader.zk.getLastProcessedZxid());
             
             f1.start();
@@ -323,7 +322,7 @@ public class Zab1_0Test {
             leadThread = new LeadThread(leader);
             leadThread.start();
 
-            while(!leader.readyToStart) {
+            while(leader.cnxAcceptor == null || !leader.cnxAcceptor.isAlive()) {
                 Thread.sleep(20);
             }