@@ -45,7 +45,7 @@ Add separated code to enforce continuous proposals
45
45
create mode 100644 zookeeper-server/src/test/java/org/apache/zookeeper/server/quorum/QuorumSyncTest.java
46
46
47
47
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/Request.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/Request.java
48
- index c174fdd1e..ad5071375 100644
48
+ index c174fdd1..ad507137 100644
49
49
--- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/Request.java
50
50
+++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/Request.java
51
51
@@ -78,6 +78,19 @@ public class Request {
@@ -69,7 +69,7 @@ index c174fdd1e..ad5071375 100644
69
69
70
70
public final int cxid;
71
71
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/TxnLogEntry.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/TxnLogEntry.java
72
- index 352eb81da..409fd21fa 100644
72
+ index 352eb81d..409fd21f 100644
73
73
--- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/TxnLogEntry.java
74
74
+++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/TxnLogEntry.java
75
75
@@ -47,4 +47,8 @@ public final class TxnLogEntry {
@@ -82,7 +82,7 @@ index 352eb81da..409fd21fa 100644
82
82
+ }
83
83
}
84
84
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/ZKDatabase.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/ZKDatabase.java
85
- index 7258daa7c..7a26d8362 100644
85
+ index 7258daa7..7a26d836 100644
86
86
--- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/ZKDatabase.java
87
87
+++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/ZKDatabase.java
88
88
@@ -58,6 +58,7 @@ import org.apache.zookeeper.server.quorum.Leader.Proposal;
@@ -156,7 +156,7 @@ index 7258daa7c..7a26d8362 100644
156
156
wl.unlock();
157
157
}
158
158
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/ZooKeeperServer.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/ZooKeeperServer.java
159
- index 6740f6d52..14dd59b8c 100644
159
+ index 6740f6d5..14dd59b8 100644
160
160
--- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/ZooKeeperServer.java
161
161
+++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/ZooKeeperServer.java
162
162
@@ -1846,13 +1846,6 @@ public class ZooKeeperServer implements SessionExpirer, ServerStats.Provider {
@@ -205,7 +205,7 @@ index 6740f6d52..14dd59b8c 100644
205
205
206
206
private void processTxnForSessionEvents(Request request, TxnHeader hdr, Record txn) {
207
207
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Follower.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Follower.java
208
- index 0eff9d248..ca99974cb 100644
208
+ index 0eff9d24..ca99974c 100644
209
209
--- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Follower.java
210
210
+++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Follower.java
211
211
@@ -35,7 +35,6 @@ import org.apache.zookeeper.server.quorum.flexible.QuorumVerifier;
@@ -234,7 +234,7 @@ index 0eff9d248..ca99974cb 100644
234
234
/*
235
235
* Request header is created only by the leader, so this is only set
236
236
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/FollowerZooKeeperServer.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/FollowerZooKeeperServer.java
237
- index b67661999..1b0b5cd92 100644
237
+ index b6766199..1b0b5cd9 100644
238
238
--- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/FollowerZooKeeperServer.java
239
239
+++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/FollowerZooKeeperServer.java
240
240
@@ -22,7 +22,6 @@ import java.io.IOException;
@@ -303,7 +303,7 @@ index b67661999..1b0b5cd92 100644
303
303
- }
304
304
}
305
305
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Learner.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Learner.java
306
- index 1ef99e50a..adf0ef6e5 100644
306
+ index 1ef99e50..adf0ef6e 100644
307
307
--- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Learner.java
308
308
+++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Learner.java
309
309
@@ -82,6 +82,10 @@ public class Learner {
@@ -431,7 +431,7 @@ index 1ef99e50a..adf0ef6e5 100644
431
431
}
432
432
} else {
433
433
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Observer.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Observer.java
434
- index d3aa41b5f..334fa54c1 100644
434
+ index d3aa41b5..334fa54c 100644
435
435
--- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Observer.java
436
436
+++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/Observer.java
437
437
@@ -202,12 +202,8 @@ public class Observer extends Learner {
@@ -464,7 +464,7 @@ index d3aa41b5f..334fa54c1 100644
464
464
465
465
boolean majorChange = self.processReconfig(qv, suggestedLeaderId, qp.getZxid(), true);
466
466
diff --git a/zookeeper-server/src/test/java/org/apache/zookeeper/server/TxnLogDigestTest.java b/zookeeper-server/src/test/java/org/apache/zookeeper/server/TxnLogDigestTest.java
467
- index 75d6fe680..b52ea3418 100644
467
+ index 75d6fe68..b52ea341 100644
468
468
--- a/zookeeper-server/src/test/java/org/apache/zookeeper/server/TxnLogDigestTest.java
469
469
+++ b/zookeeper-server/src/test/java/org/apache/zookeeper/server/TxnLogDigestTest.java
470
470
@@ -60,6 +60,7 @@ public class TxnLogDigestTest extends ClientBase {
@@ -484,7 +484,7 @@ index 75d6fe680..b52ea3418 100644
484
484
super.tearDown();
485
485
486
486
diff --git a/zookeeper-server/src/test/java/org/apache/zookeeper/server/ZxidRolloverTest.java b/zookeeper-server/src/test/java/org/apache/zookeeper/server/ZxidRolloverTest.java
487
- index 031ccc2f7..b23fd80a3 100644
487
+ index 031ccc2f..b23fd80a 100644
488
488
--- a/zookeeper-server/src/test/java/org/apache/zookeeper/server/ZxidRolloverTest.java
489
489
+++ b/zookeeper-server/src/test/java/org/apache/zookeeper/server/ZxidRolloverTest.java
490
490
@@ -60,6 +60,7 @@ public class ZxidRolloverTest extends ZKTestCase {
@@ -505,7 +505,7 @@ index 031ccc2f7..b23fd80a3 100644
505
505
zkClients[i].close();
506
506
diff --git a/zookeeper-server/src/test/java/org/apache/zookeeper/server/quorum/QuorumSyncTest.java b/zookeeper-server/src/test/java/org/apache/zookeeper/server/quorum/QuorumSyncTest.java
507
507
new file mode 100644
508
- index 000000000..c4b7720cf
508
+ index 00000000..c4b7720c
509
509
--- /dev/null
510
510
+++ b/zookeeper-server/src/test/java/org/apache/zookeeper/server/quorum/QuorumSyncTest.java
511
511
@@ -0,0 +1,100 @@
0 commit comments