in at/rollback/client/update.go [32:53]
func updateData(ctx context.Context) (re error) {
request := gorequest.New()
log.Infof("branch transaction begin")
// global transaction will roll back,because updateDataFail
request.Post(serverIpPort+"/updateDataSuccess").
Set(constant.XidKey, tm.GetXID(ctx)).
End(func(response gorequest.Response, body string, errs []error) {
if response.StatusCode != http.StatusOK {
re = fmt.Errorf("update data fail")
}
})
request.Post(serverIpPort2+"/updateDataFail").
Set(constant.XidKey, tm.GetXID(ctx)).
End(func(response gorequest.Response, body string, errs1 []error) {
if response.StatusCode != http.StatusOK {
re = fmt.Errorf("update data fail")
}
})
return
}