From c4dbc0d83d918f20590cb94c0d1dd38e955a3f51 Mon Sep 17 00:00:00 2001 From: zhouken Date: Wed, 11 Jan 2023 11:18:39 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dxa=20grpc=20=E4=BA=8B?= =?UTF-8?q?=E5=8A=A1=E6=97=A0=E6=B3=95=E6=90=BA=E5=B8=A6header=20=E7=AD=89?= =?UTF-8?q?=E4=BF=A1=E6=81=AF=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- client/dtmgrpc/xa.go | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/client/dtmgrpc/xa.go b/client/dtmgrpc/xa.go index f23e3bf..2309d67 100644 --- a/client/dtmgrpc/xa.go +++ b/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,