Browse Source

registerBranch dock updated

pull/52/head
yedf2 4 years ago
parent
commit
8c0b66f344
  1. 3
      dtmgrpc/dtmgimp/dtmgimp.proto
  2. 15
      test/tcc_test.go

3
dtmgrpc/dtmgimp/dtmgimp.proto

@ -35,9 +35,6 @@ message DtmGidReply {
string Gid = 1;
}
message DtmBranchInfo {
}
message DtmBranchRequest {
string Gid = 1;
string TransType = 2;

15
test/tcc_test.go

@ -62,3 +62,18 @@ func TestTccTimeout(t *testing.T) {
assert.Equal(t, StatusFailed, getTransStatus(gid))
assert.Equal(t, []string{StatusSucceed, StatusPrepared}, getBranchesStatus(gid))
}
func TestTccCompatible(t *testing.T) {
req := examples.GenTransReq(30, false, false)
gid := dtmimp.GetFuncName()
err := dtmcli.TccGlobalTransaction(examples.DtmServer, gid, func(tcc *dtmcli.Tcc) (*resty.Response, error) {
_, err := tcc.CallBranch(req, Busi+"/TransOut", Busi+"/TransOutConfirm", Busi+"/TransOutRevert")
assert.Nil(t, err)
return tcc.CallBranch(req, Busi+"/TransIn", Busi+"/TransInConfirm", Busi+"/TransInRevert")
})
assert.Nil(t, err)
waitTransProcessed(gid)
assert.Equal(t, StatusSucceed, getTransStatus(gid))
assert.Equal(t, []string{StatusPrepared, StatusSucceed, StatusPrepared, StatusSucceed}, getBranchesStatus(gid))
}

Loading…
Cancel
Save