|
|
@ -21,7 +21,6 @@ import ( |
|
|
func TestMsgJrpcNormal(t *testing.T) { |
|
|
func TestMsgJrpcNormal(t *testing.T) { |
|
|
msg := genJrpcMsg(dtmimp.GetFuncName()) |
|
|
msg := genJrpcMsg(dtmimp.GetFuncName()) |
|
|
msg.Submit() |
|
|
msg.Submit() |
|
|
assert.Equal(t, StatusSubmitted, getTransStatus(msg.Gid)) |
|
|
|
|
|
waitTransProcessed(msg.Gid) |
|
|
waitTransProcessed(msg.Gid) |
|
|
assert.Equal(t, []string{StatusSucceed, StatusSucceed}, getBranchesStatus(msg.Gid)) |
|
|
assert.Equal(t, []string{StatusSucceed, StatusSucceed}, getBranchesStatus(msg.Gid)) |
|
|
assert.Equal(t, StatusSucceed, getTransStatus(msg.Gid)) |
|
|
assert.Equal(t, StatusSucceed, getTransStatus(msg.Gid)) |
|
|
|