Github user ohadshacham commented on a diff in the pull request:
https://github.com/apache/incubator-omid/pull/23#discussion_r167857492
--- Diff:
tso-server/src/test/java/org/apache/omid/tso/TestPersistenceProcessorHandler.java
---
@@ -126,6 +126,36 @@ void afterMethod() {
Mockito.reset(mockWriter);
}
+ @Test(timeOut = 1_000)
+ public void testPersistentProcessorHandlerIdsAreCreatedConsecutive()
throws Exception {
+
+ TSOServerConfig tsoConfig = new TSOServerConfig();
+ tsoConfig.setNumConcurrentCTWriters(32);
+
+ PersistenceProcessorHandler[] handlers = new
PersistenceProcessorHandler[tsoConfig.getNumConcurrentCTWriters()];
+ for (int i = 0; i < tsoConfig.getNumConcurrentCTWriters(); i++) {
+ handlers[i] = new PersistenceProcessorHandler(metrics,
+ "localhost:1234",
+
mock(LeaseManager.class),
+ commitTable,
+
mock(ReplyProcessor.class),
+ retryProcessor,
+ panicker);
+ }
+
+ for (int i = 0; i < tsoConfig.getNumConcurrentCTWriters(); i++) {
+ // Required to generalize the cases when other tests have
increased the static variable assigning the ids
+ if (i + 1 < tsoConfig.getNumConcurrentCTWriters()) {
+ int followingHandlerIdAsInt = Integer.valueOf(handlers[i +
1].getId());
+ assertEquals(handlers[i].getId(),
String.valueOf(followingHandlerIdAsInt - 1));
--- End diff --
We kind of testing the atomic integer :)
---
