Skip to content

Commit

Permalink
fix unit tests
Browse files Browse the repository at this point in the history
  • Loading branch information
marcosgopen committed Apr 22, 2024
1 parent d802d57 commit 2bc0624
Showing 1 changed file with 19 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -400,16 +400,24 @@ public void start(Xid xid, int i) throws XAException {
}
});

int oldCount = recoverCalled;
callFirstPass(xarm, oldCount);
callSecondPass(xarm, oldCount);
callFirstPass(xarm, oldCount);
callFirstPass(xarm, oldCount);
callSecondPass(xarm, oldCount);
}

public void callFirstPass(XARecoveryModule xarm, int oldCount) {
xarm.periodicWorkFirstPass();
assertEquals(recoverCalled, 1);
xarm.periodicWorkSecondPass();
assertEquals(recoverCalled, 2);
xarm.periodicWorkFirstPass();
assertEquals(recoverCalled, 3);
xarm.periodicWorkFirstPass();
assertEquals(recoverCalled, 5);
assertTrue(recoverCalled > oldCount);
oldCount = recoverCalled;
}

private void callSecondPass(XARecoveryModule xarm, int oldCount) {
xarm.periodicWorkSecondPass();
assertEquals(recoverCalled, 6);
assertTrue(recoverCalled > oldCount);
oldCount = recoverCalled;
}

@Test
Expand Down Expand Up @@ -525,20 +533,17 @@ public XAResource[] getXAResources() throws Exception {
// 1st pass: returns one xid (count is 1)
xarm.periodicWorkFirstPass();
// 2nd pass: throws an exception (count is 2)
xarm.periodicWorkSecondPass();
assertTrue(xarm.getContactedJndiNames().contains("test"));
xarm.periodicWorkFirstPass();
assertFalse(rolledback);
// 1st pass: throws an exception (count is 3)
xarm.periodicWorkFirstPass();
// 2nd pass: throws an exception (count is 4)
xarm.periodicWorkSecondPass();
assertFalse(xarm.getContactedJndiNames().contains("test"));
xarm.periodicWorkFirstPass();
assertFalse(rolledback);
// 1st pass: returns an empty list of xids (count is 5)
xarm.periodicWorkFirstPass();
// 2nd pass: returns an empty list of xids (count is 6)
xarm.periodicWorkSecondPass();
assertTrue(xarm.getContactedJndiNames().contains("test"));
xarm.periodicWorkFirstPass();
assertTrue(rolledback);

jtaPropertyManager.getJTAEnvironmentBean().setOrphanSafetyInterval(orphanSafetyInterval);
Expand Down

0 comments on commit 2bc0624

Please sign in to comment.