Skip to content

Commit

Permalink
branch type & default port
Browse files Browse the repository at this point in the history
  • Loading branch information
Bughue committed Feb 6, 2024
1 parent c0de496 commit c5e4a8d
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ private static String doTestCommit(int times) throws TransactionException {

String xid = tm.begin(ProtocolTestConstants.APPLICATION_ID, ProtocolTestConstants.SERVICE_GROUP, "test", 60000);
MockCoordinator.getInstance().setExpectedRetry(xid, times);
Long branchId = rm.branchRegister(BranchType.AT, RESOURCE_ID, "1", xid, "1", "1");
Long branchId = rm.branchRegister(BranchType.TCC, RESOURCE_ID, "1", xid, "1", "1");
GlobalStatus commit = tm.commit(xid);
Assertions.assertEquals(GlobalStatus.Committed, commit);
return xid;
Expand All @@ -96,7 +96,7 @@ private static String doTestRollback(int times) throws TransactionException {

String xid = tm.begin(ProtocolTestConstants.APPLICATION_ID, ProtocolTestConstants.SERVICE_GROUP, "test", 60000);
MockCoordinator.getInstance().setExpectedRetry(xid, times);
Long branchId = rm.branchRegister(BranchType.AT, RESOURCE_ID, "1", xid, "1", "1");
Long branchId = rm.branchRegister(BranchType.TCC, RESOURCE_ID, "1", xid, "1", "1");
GlobalStatus rollback = tm.rollback(xid);
Assertions.assertEquals(GlobalStatus.Rollbacked, rollback);
return xid;
Expand Down

0 comments on commit c5e4a8d

Please sign in to comment.