Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Prevent over zealous peer recovery scuppering test #30433

Open
wants to merge 1 commit into
base: integration
Choose a base branch
from
Open

Prevent over zealous peer recovery scuppering test #30433

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 8 additions & 3 deletions dev/com.ibm.ws.transaction.cloud_fat.base/fat/src/tests/CloudFATServletClient.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -182,16 +182,21 @@ public void testAggressiveTakeover1() throws Exception {
// Now start server1
FATUtils.startServers(_runner, longLeaseCompeteServer1);

// Check it recovered successfully
longLeaseCompeteServer1.resetLogMarks();
assertNotNull(longLeaseCompeteServer1.getServerName() + " did not recover its own logs",
longLeaseCompeteServer1.waitForStringInLog("WTRN0133I: Transaction recovery processing for this server is complete"));

// Wake up server2 which will be sleeping in recover
Log.info(getClass(), "testAggressiveTakeover1", "Wake up " + server2fastcheck.getServerName());
XAResourceImpl.wakeUp();

assertNotNull("Peer recovery was not interrupted",
assertNotNull(server2fastcheck.getServerName() + " did not fail to recover for " + longLeaseCompeteServer1.getServerName(),
server2fastcheck.waitForStringInTrace("WTRN0107W: Server with identity cloud0021 attempted but failed to recover the logs of peer server cloud0011",
FATUtils.LOG_SEARCH_TIMEOUT));

// Server appears to have started ok. Check for key string to see whether recovery has succeeded, irrespective of what server2fastcheck has done
assertNotNull("Local recovery failed", longLeaseCompeteServer1.waitForStringInLog("CWRLS0012I:", FATUtils.LOG_SEARCH_TIMEOUT));
// Prevent server2 from trying again during server1 shutdown
FATUtils.stopServers(server2fastcheck);

FATUtils.runWithRetries(() -> runTestWithResponse(longLeaseCompeteServer1, SERVLET_NAME, "checkRecAggressiveTakeover").toString());
}
Expand Down