Browse Source

修复xa grpc 事务无法携带header 等信息的问题

alpha
zhouken 4 years ago
parent
commit
c4dbc0d83d
  1. 5
      client/dtmgrpc/xa.go

5
client/dtmgrpc/xa.go

@ -79,10 +79,7 @@ func XaGlobalTransaction2(server string, gid string, custom func(*XaGrpc), xaFun
xa := &XaGrpc{TransBase: *dtmimp.NewTransBase(gid, "xa", server, "")}
custom(xa)
dc := dtmgimp.MustGetDtmClient(xa.Dtm)
req := &dtmgpb.DtmRequest{
Gid: gid,
TransType: xa.TransType,
}
req := dtmgimp.GetDtmRequest(&xa.TransBase)
return dtmimp.XaHandleGlobalTrans(&xa.TransBase, func(action string) error {
f := map[string]func(context.Context, *dtmgpb.DtmRequest, ...grpc.CallOption) (*emptypb.Empty, error){
"prepare": dc.Prepare,

Loading…
Cancel
Save