opensource/dtm
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

add saga rollback pending bug

Browse Source
This commit is contained in:
yedf2 2021-07-29 20:23:23 +08:00
parent f90f2cde36
commit e80f68c387
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dtmsvr/trans_saga_test.go
View File

@ -26,7 +26,7 @@ func sagaNormal(t *testing.T) {
func sagaCommittedPending(t *testing.T) { func sagaCommittedPending(t *testing.T) {
saga := genSaga("gid-committedPending", false, false) saga := genSaga("gid-committedPending", false, false)
examples.MainSwitch.TransInResult.SetOnce("PENDING") examples.MainSwitch.TransOutResult.SetOnce("PENDING")
saga.Submit() saga.Submit()
WaitTransProcessed(saga.Gid) WaitTransProcessed(saga.Gid)
assert.Equal(t, []string{"prepared", "prepared", "prepared", "prepared"}, getBranchesStatus(saga.Gid)) assert.Equal(t, []string{"prepared", "prepared", "prepared", "prepared"}, getBranchesStatus(saga.Gid))
@ -37,8 +37,11 @@ func sagaCommittedPending(t *testing.T) {
func sagaRollback(t *testing.T) { func sagaRollback(t *testing.T) {
saga := genSaga("gid-rollbackSaga2", false, true) saga := genSaga("gid-rollbackSaga2", false, true)
examples.MainSwitch.TransOutRevertResult.SetOnce("PENDING")
saga.Submit() saga.Submit()
WaitTransProcessed(saga.Gid) WaitTransProcessed(saga.Gid)
assert.Equal(t, "aborting", getTransStatus(saga.Gid))
CronTransOnce(60 * time.Second)
assert.Equal(t, "failed", getTransStatus(saga.Gid)) assert.Equal(t, "failed", getTransStatus(saga.Gid))
assert.Equal(t, []string{"succeed", "succeed", "succeed", "failed"}, getBranchesStatus(saga.Gid)) assert.Equal(t, []string{"succeed", "succeed", "succeed", "failed"}, getBranchesStatus(saga.Gid))
} }

2
examples/main_base.go
View File

@ -62,7 +62,7 @@ var MainSwitch mainSwitchType
func handleGeneralBusiness(c *gin.Context, result1 string, result2 string, busi string) (interface{}, error) { func handleGeneralBusiness(c *gin.Context, result1 string, result2 string, busi string) (interface{}, error) {
info := infoFromContext(c) info := infoFromContext(c)
res := common.OrString(MainSwitch.TransInResult.Fetch(), result2, "SUCCESS") res := common.OrString(result1, result2, "SUCCESS")
logrus.Printf("%s %s result: %s", busi, info.String(), res) logrus.Printf("%s %s result: %s", busi, info.String(), res)
return M{"dtm_result": res}, nil return M{"dtm_result": res}, nil