-
Notifications
You must be signed in to change notification settings - Fork 12
/
tx_trace.go
53 lines (43 loc) · 1.75 KB
/
tx_trace.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
package main
import (
"github.com/idealeak/goserver/core/logger"
"github.com/idealeak/goserver/core/netlib"
"github.com/idealeak/goserver/core/transact"
"github.com/idealeak/goserver/examples/protocol"
"github.com/idealeak/goserver/srvlib"
)
type traceTransHandler struct {
}
func init() {
transact.RegisteHandler(protocol.TxTrace, &traceTransHandler{})
srvlib.ServerSessionMgrSington.AddListener(&MyServerSessionRegisteListener{})
}
func (this *traceTransHandler) OnExcute(tNode *transact.TransNode, ud interface{}) transact.TransExeResult {
logger.Logger.Trace("traceTransHandler.OnExcute ")
userData := &protocol.StructA{}
err := netlib.UnmarshalPacketNoPackId(ud.([]byte), userData)
if err == nil {
logger.Logger.Tracef("==========%#v", userData)
}
return transact.TransExeResult_Success
}
func (this *traceTransHandler) OnCommit(tNode *transact.TransNode) transact.TransExeResult {
logger.Logger.Trace("traceTransHandler.OnCommit ")
return transact.TransExeResult_Success
}
func (this *traceTransHandler) OnRollBack(tNode *transact.TransNode) transact.TransExeResult {
logger.Logger.Trace("traceTransHandler.OnRollBack ")
return transact.TransExeResult_Success
}
func (this *traceTransHandler) OnChildTransRep(tNode *transact.TransNode, hChild transact.TransNodeID, retCode int, ud interface{}) transact.TransExeResult {
logger.Logger.Trace("traceTransHandler.OnChildTransRep ")
return transact.TransExeResult_Success
}
type MyServerSessionRegisteListener struct {
}
func (mssrl *MyServerSessionRegisteListener) OnRegiste(*netlib.Session) {
logger.Logger.Trace("MyServerSessionRegisteListener.OnRegiste")
}
func (mssrl *MyServerSessionRegisteListener) OnUnregiste(*netlib.Session) {
logger.Logger.Trace("MyServerSessionRegisteListener.OnUnregiste")
}