change file names
This commit is contained in:
parent
66d03f5ccb
commit
c19e446455
@ -105,9 +105,6 @@ func MustRemarshal(from interface{}, to interface{}) {
|
|||||||
E2P(err)
|
E2P(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// LogFunc log function type
|
|
||||||
type LogFunc func(format string, args ...interface{})
|
|
||||||
|
|
||||||
// Logf 输出日志
|
// Logf 输出日志
|
||||||
func Logf(format string, args ...interface{}) {
|
func Logf(format string, args ...interface{}) {
|
||||||
msg := fmt.Sprintf(format, args...)
|
msg := fmt.Sprintf(format, args...)
|
||||||
|
|||||||
@ -2,6 +2,7 @@ package dtmpb
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
context "context"
|
context "context"
|
||||||
|
"fmt"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
"github.com/yedf/dtm/dtmcli"
|
"github.com/yedf/dtm/dtmcli"
|
||||||
@ -47,8 +48,12 @@ func GetServerAndMethod(grpcURL string) (string, string) {
|
|||||||
func GrpcServerLog(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
|
func GrpcServerLog(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
|
||||||
dtmcli.Logf("grpc server handling: %s %v", info.FullMethod, req)
|
dtmcli.Logf("grpc server handling: %s %v", info.FullMethod, req)
|
||||||
m, err := handler(ctx, req)
|
m, err := handler(ctx, req)
|
||||||
log := dtmcli.If(err != nil, dtmcli.LogRedf, dtmcli.Logf).(dtmcli.LogFunc)
|
res := fmt.Sprintf("grpc server handled: %s %v result: %v err: %v", info.FullMethod, req, m, err)
|
||||||
log("grpc server handled: %s %v result: %v err: %v", info.FullMethod, req, m, err)
|
if err != nil {
|
||||||
|
dtmcli.LogRedf("%s", res)
|
||||||
|
} else {
|
||||||
|
dtmcli.Logf("%s", res)
|
||||||
|
}
|
||||||
return m, err
|
return m, err
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -56,7 +61,11 @@ func GrpcServerLog(ctx context.Context, req interface{}, info *grpc.UnaryServerI
|
|||||||
func GrpcClientLog(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {
|
func GrpcClientLog(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {
|
||||||
dtmcli.Logf("grpc client calling: %s%s %v", cc.Target(), method, req)
|
dtmcli.Logf("grpc client calling: %s%s %v", cc.Target(), method, req)
|
||||||
err := invoker(ctx, method, req, reply, cc, opts...)
|
err := invoker(ctx, method, req, reply, cc, opts...)
|
||||||
log := dtmcli.If(err != nil, dtmcli.LogRedf, dtmcli.Logf).(dtmcli.LogFunc)
|
res := fmt.Sprintf("grpc client called: %s%s %v result: %v err: %v", cc.Target(), method, req, reply, err)
|
||||||
log("grpc client called: %s%s %v result: %v err: %v", cc.Target(), method, req, reply, err)
|
if err != nil {
|
||||||
|
dtmcli.LogRedf("%s", res)
|
||||||
|
} else {
|
||||||
|
dtmcli.Logf("%s", res)
|
||||||
|
}
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|||||||
@ -18,4 +18,5 @@ func TestExamples(t *testing.T) {
|
|||||||
assertSucceed(t, examples.TccFireRequest())
|
assertSucceed(t, examples.TccFireRequest())
|
||||||
assertSucceed(t, examples.TccFireRequestNested())
|
assertSucceed(t, examples.TccFireRequestNested())
|
||||||
assertSucceed(t, examples.XaFireRequest())
|
assertSucceed(t, examples.XaFireRequest())
|
||||||
|
assertSucceed(t, examples.MsgPbFireRequest())
|
||||||
}
|
}
|
||||||
|
|||||||
@ -8,7 +8,7 @@ import (
|
|||||||
"github.com/yedf/dtm/examples"
|
"github.com/yedf/dtm/examples"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestSagaBarrier(t *testing.T) {
|
func TestBarrierSaga(t *testing.T) {
|
||||||
|
|
||||||
sagaBarrierNormal(t)
|
sagaBarrierNormal(t)
|
||||||
sagaBarrierRollback(t)
|
sagaBarrierRollback(t)
|
||||||
@ -14,7 +14,7 @@ import (
|
|||||||
"github.com/yedf/dtm/examples"
|
"github.com/yedf/dtm/examples"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestTccBarrier(t *testing.T) {
|
func TestBarrierTcc(t *testing.T) {
|
||||||
tccBarrierDisorder(t)
|
tccBarrierDisorder(t)
|
||||||
tccBarrierNormal(t)
|
tccBarrierNormal(t)
|
||||||
tccBarrierRollback(t)
|
tccBarrierRollback(t)
|
||||||
8
dtmsvr/trans_pb_msg_test.go
Normal file
8
dtmsvr/trans_pb_msg_test.go
Normal file
@ -0,0 +1,8 @@
|
|||||||
|
package dtmsvr
|
||||||
|
|
||||||
|
import (
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
func TestPbMsg(t *testing.T) {
|
||||||
|
}
|
||||||
@ -8,7 +8,7 @@ import (
|
|||||||
"github.com/yedf/dtm/examples"
|
"github.com/yedf/dtm/examples"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestSagaWait(t *testing.T) {
|
func TestWaitSaga(t *testing.T) {
|
||||||
|
|
||||||
sagaNormalWait(t)
|
sagaNormalWait(t)
|
||||||
sagaCommittedPendingWait(t)
|
sagaCommittedPendingWait(t)
|
||||||
@ -13,21 +13,11 @@ func MsgPbSetup(app *gin.Engine) {
|
|||||||
|
|
||||||
// MsgPbFireRequest 1
|
// MsgPbFireRequest 1
|
||||||
func MsgPbFireRequest() string {
|
func MsgPbFireRequest() string {
|
||||||
dtmcli.Logf("MsgPbFireRequest")
|
|
||||||
// reply, err := DtmClient.Call(context.Background(), &dtmpb.DtmRequest{
|
|
||||||
// Gid: "pb_test",
|
|
||||||
// TransType: "msg",
|
|
||||||
// Method: "submit",
|
|
||||||
// Extra: dtmcli.MS{
|
|
||||||
// "BusiFunc": BusiPb + "/examples.Busi/Call",
|
|
||||||
// },
|
|
||||||
// })
|
|
||||||
// dtmcli.Logf("reply and err is: %v, %v", reply, err)
|
|
||||||
req := dtmcli.MustMarshal(&TransReq{Amount: 30})
|
req := dtmcli.MustMarshal(&TransReq{Amount: 30})
|
||||||
msg := dtmpb.NewMsgGrpc(DtmGrpcServer, dtmcli.MustGenGid(DtmServer)).
|
msg := dtmpb.NewMsgGrpc(DtmGrpcServer, dtmcli.MustGenGid(DtmServer)).
|
||||||
Add(BusiPb+"/examples.Busi/TransOut", req).
|
Add(BusiPb+"/examples.Busi/TransOut", req).
|
||||||
Add(BusiPb+"/examples.Busi/TransIn", req)
|
Add(BusiPb+"/examples.Busi/TransIn", req)
|
||||||
err := msg.Submit()
|
err := msg.Submit()
|
||||||
e2p(err)
|
e2p(err)
|
||||||
return ""
|
return msg.Gid
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user