本文整理汇总了Golang中github.com/idealeak/goserver/core/logger.Trace函数的典型用法代码示例。如果您正苦于以下问题:Golang Trace函数的具体用法?Golang Trace怎么用?Golang Trace使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了Trace函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: Start
func (tm *TimerMgr) Start() {
logger.Trace("Timer Start")
defer logger.Trace("Timer Start [ok]")
tm.Object = basic.NewObject(core.ObjId_TimerId,
"timer",
Config.Options,
tm)
tm.UserData = tm
core.LaunchChild(TimerModule.Object)
}
开发者ID:zwczou,项目名称:goserver,代码行数:12,代码来源:timer.go
示例2: init
func (this *ModuleMgr) init() {
logger.Trace("Start Initialize Modules")
defer logger.Trace("Start Initialize Modules [ok]")
for e := this.modules.Front(); e != nil; e = e.Next() {
if me, ok := e.Value.(*ModuleEntity); ok && !me.quited {
logger.Trace(me.module.ModuleName(), " Init...")
me.module.Init()
logger.Trace(me.module.ModuleName(), " Init [ok]")
}
}
this.state = ModuleStateRun
}
开发者ID:zwczou,项目名称:goserver,代码行数:12,代码来源:modulemgr.go
示例3: sendRoutine
func (s *TcpSession) sendRoutine() {
defer func() {
if err := recover(); err != nil {
logger.Trace(s.Id, " ->close: Session.procSend err: ", err)
}
s.sc.encoder.FinishEncode(&s.Session)
s.shutWrite()
s.shutRead()
s.Close()
}()
s.waitor.Add(1)
defer s.waitor.Done()
var (
err error
data []byte
)
for !s.quit || len(s.sendBuffer) != 0 {
select {
case msg, ok := <-s.sendBuffer:
if !ok {
panic("[comm expt]sendBuffer chan closed")
}
if msg == nil {
panic("[comm expt]normal close send")
}
if s.sc.IsInnerLink {
var timeZero time.Time
s.conn.SetWriteDeadline(timeZero)
} else {
if s.sc.WriteTimeout != 0 {
s.conn.SetWriteDeadline(time.Now().Add(s.sc.WriteTimeout))
}
}
data, err = s.sc.encoder.Encode(&s.Session, msg, s.conn)
if err != nil {
logger.Trace("s.sc.encoder.Encode err", err)
if s.sc.IsInnerLink == false {
panic(err)
}
}
s.FirePacketSent(data)
s.lastSndTime = time.Now()
}
}
}
开发者ID:zwczou,项目名称:goserver,代码行数:52,代码来源:tcp_session.go
示例4: Start
func (e *Executor) Start() {
logger.Trace("Executor Start")
defer logger.Trace("Executor Start [ok]")
e.Object = basic.NewObject(core.ObjId_ExecutorId,
"executor",
Config.Options,
nil)
e.c.NumberOfReplicas = WorkerVirtualNum
e.UserData = e
e.AddWorker(Config.Worker.WorkerCnt)
core.LaunchChild(TaskExecutor.Object)
}
开发者ID:zwczou,项目名称:goserver,代码行数:14,代码来源:executor.go
示例5: SendTransStart
func (tcs *TxCommSkeleton) SendTransStart(parent, me *transact.TransNodeParam, ud interface{}) bool {
logger.Trace("TxCommSkeleton.SendTransStart")
p := action.ContructTxStartPacket(parent, me, ud)
if p == nil {
return false
}
s := ServerSessionMgrSington.GetSession(me.AreaID, int(me.Ot), me.Oid)
if s == nil {
logger.Trace("TxCommSkeleton.SendTransStart s=nil")
return false
}
s.Send(p)
return true
}
开发者ID:zwczou,项目名称:goserver,代码行数:15,代码来源:txcommskeleton.go
示例6: SendTransResult
func (tcs *TxCommSkeleton) SendTransResult(parent, me *transact.TransNodeParam, tr *transact.TransResult) bool {
logger.Trace("TxCommSkeleton.SendTransResult")
p := action.ContructTxResultPacket(parent, me, tr)
if p == nil {
return false
}
s := ServerSessionMgrSington.GetSession(parent.AreaID, int(parent.Ot), parent.Oid)
if s == nil {
logger.Trace("TxCommSkeleton.SendTransResult s=nil")
return false
}
s.Send(p)
return true
}
开发者ID:zwczou,项目名称:goserver,代码行数:15,代码来源:txcommskeleton.go
示例7: SendCmdToTransNode
func (tcs *TxCommSkeleton) SendCmdToTransNode(tnp *transact.TransNodeParam, c transact.TransCmd) bool {
logger.Trace("TxCommSkeleton.SendCmdToTransNode")
p := action.ConstructTxCmdPacket(tnp, c)
if p == nil {
return false
}
s := ServerSessionMgrSington.GetSession(tnp.AreaID, int(tnp.Ot), tnp.Oid)
if s == nil {
logger.Trace("TxCommSkeleton.SendCmdToTransNode s=nil")
return false
}
s.Send(p)
return true
}
开发者ID:zwczou,项目名称:goserver,代码行数:15,代码来源:txcommskeleton.go
示例8: OnRegiste
func (this *serviceMgr) OnRegiste(s *netlib.Session) {
if this == nil || s == nil {
return
}
if s.GetAttribute(SessionAttributeServiceFlag) == nil {
return
}
attr := s.GetAttribute(SessionAttributeServerInfo)
if attr != nil {
if srvInfo, ok := attr.(*protocol.SSSrvRegiste); ok && srvInfo != nil {
services := GetCareServicesBySession(srvInfo.GetType())
for _, v1 := range services {
if v2, has := this.servicesPool[v1]; has {
for _, v3 := range v2 {
func(si *protocol.ServiceInfo, sInfo *protocol.SSSrvRegiste) {
pack := &protocol.SSServiceInfo{}
proto.SetDefaults(pack)
pack.Service = si
logger.Trace("serviceMgr.OnRegiste Server Type=", sInfo.GetType(), " Id=", sInfo.GetId(), " Name=", sInfo.GetName(), " careful => Service=", si)
s.Send(pack)
}(v3, srvInfo)
}
}
}
}
}
}
开发者ID:zwczou,项目名称:goserver,代码行数:28,代码来源:servicemgr.go
示例9: init
func init() {
netlib.RegisterFactory(int(protocol.MmoPacketID_PACKET_SC_GATEINFO), netlib.PacketFactoryWrapper(func() interface{} {
return &protocol.SCGateInfo{}
}))
netlib.RegisterHandler(int(protocol.MmoPacketID_PACKET_SC_GATEINFO), netlib.HandlerWrapper(func(s *netlib.Session, pack interface{}) error {
logger.Trace("receive gateinfo==", pack)
if sr, ok := pack.(*protocol.SCGateInfo); ok {
sc := &netlib.SessionConfig{
Id: int(sr.GetSrvId()),
Type: int(sr.GetSrvType()),
Ip: sr.GetIp(),
Port: int(sr.GetPort()),
AuthKey: sr.GetAuthKey(),
WriteTimeout: 30,
ReadTimeout: 30,
IdleTimeout: 30,
MaxDone: 20,
MaxPend: 20,
MaxPacket: 1024,
RcvBuff: 1024,
SndBuff: 1024,
IsClient: true,
NoDelay: true,
FilterChain: []string{"session-filter-trace", "session-filter-auth"},
}
sc.Init()
err := netlib.Connect(core.CoreObject(), sc)
if err != nil {
logger.Warn("connect server failed err:", err)
}
}
return nil
}))
}
开发者ID:zwczou,项目名称:goserver,代码行数:34,代码来源:packet_scgateinfo.go
示例10: RegisteHandler
func RegisteHandler(tt TransType, th TransHandler) {
if _, exist := transactionHandlerPool[tt]; exist {
panic(fmt.Sprintf("TransHandlerFactory repeate registe handler, type=%v", tt))
return
}
logger.Trace("transact.RegisteHandler:", tt)
transactionHandlerPool[tt] = th
}
开发者ID:zwczou,项目名称:goserver,代码行数:8,代码来源:transfactory.go
示例11: OnExcute
func (this *traceTransHandler) OnExcute(tNode *transact.TransNode, ud interface{}) transact.TransExeResult {
logger.Trace("traceTransHandler.OnExcute ")
userData := &protocol.StructA{}
err := netlib.UnmarshalPacketNoPackId(ud.([]byte), userData)
if err == nil {
logger.Tracef("==========%#v", userData)
}
return transact.TransExeResult_Success
}
开发者ID:zwczou,项目名称:goserver,代码行数:9,代码来源:tx_trace.go
示例12: Process
func (this *TxCtrlCmdHandler) Process(session *netlib.Session, data interface{}) error {
logger.Trace("TxCtrlCmdHandler.Process")
if txcmd, ok := data.(*protocol.TransactCtrlCmd); ok {
if !transact.ProcessTransCmd(transact.TransNodeID(txcmd.GetTId()), transact.TransCmd(txcmd.GetCmd())) {
return errors.New("TxCtrlCmdHandler error, tid=" + strconv.FormatInt(txcmd.GetTId(), 16) + " cmd=" + strconv.Itoa(int(txcmd.GetCmd())))
}
}
return nil
}
开发者ID:zwczou,项目名称:goserver,代码行数:9,代码来源:txctrlcmd.go
示例13: Process
func (this *TxResultHandler) Process(session *netlib.Session, data interface{}) error {
logger.Trace("TxResultHandler.Process")
if tr, ok := data.(*protocol.TransactResult); ok {
if !transact.ProcessTransResult(transact.TransNodeID(tr.GetMyTId()), transact.TransNodeID(tr.GetChildTId()), int(tr.GetRetCode()), tr.GetCustomData()) {
return errors.New("TxResultHandler error, tid=" + strconv.FormatInt(tr.GetMyTId(), 16))
}
}
return nil
}
开发者ID:zwczou,项目名称:goserver,代码行数:9,代码来源:txresult.go
示例14: shutRead
func (s *TcpSession) shutRead() {
if s.shutRecv {
return
}
logger.Trace(s.Id, " shutRead")
s.shutRecv = true
if tcpconn, ok := s.conn.(*net.TCPConn); ok {
tcpconn.CloseRead()
}
}
开发者ID:zwczou,项目名称:goserver,代码行数:10,代码来源:tcp_session.go
示例15: Process
func (this *PacketTransitHandler) Process(s *netlib.Session, data interface{}) error {
logger.Trace("PacketTransitHandler.Process")
if pr, ok := data.(*protocol.SSPacketTransit); ok {
targetS := srvlib.ServerSessionMgrSington.GetSession(int(pr.GetSArea()), int(pr.GetSType()), int(pr.GetSId()))
if targetS != nil {
targetS.Send(pr.GetData())
}
}
return nil
}
开发者ID:zwczou,项目名称:goserver,代码行数:10,代码来源:transithandler.go
示例16: shutRead
func (s *WsSession) shutRead() {
if s.shutRecv {
return
}
logger.Trace(s.Id, " shutRead")
s.shutRecv = true
if s.conn != nil {
s.conn.Close()
s.conn = nil
}
}
开发者ID:zwczou,项目名称:goserver,代码行数:11,代码来源:ws_session.go
示例17: Start
func (this *ModuleMgr) Start() *utils.Waitor {
logger.Trace("Startup PreloadModules")
for e := this.preloadModule.Front(); e != nil; e = e.Next() {
if me, ok := e.Value.(*PreloadModuleEntity); ok {
me.module.Start()
}
}
logger.Trace("Startup PreloadModules [ok]")
this.Object = basic.NewObject(core.ObjId_CoreId,
"core",
Config.Options,
this)
this.UserData = this
core.LaunchChild(this.Object)
this.state = ModuleStateInit
//给模块预留调度的空间,防止主线程直接跑过去
select {
case <-time.After(time.Second):
}
return this.Object.Waitor
}
开发者ID:zwczou,项目名称:goserver,代码行数:23,代码来源:modulemgr.go
示例18: OnRegiste
func (mssrl *MyServerSessionRegisteListener) OnRegiste(*netlib.Session) {
logger.Trace("MyServerSessionRegisteListener.OnRegiste")
tnp := &transact.TransNodeParam{
Tt: protocol.TxTrace,
Ot: transact.TransOwnerType(2),
Oid: 202,
AreaID: 1,
}
tNode := transact.DTCModule.StartTrans(tnp, nil, transact.DefaultTransactTimeout)
if tNode != nil {
tNode.Go(core.CoreObject())
}
}
开发者ID:zwczou,项目名称:goserver,代码行数:14,代码来源:tx_trace.go
示例19: shutWrite
func (s *TcpSession) shutWrite() {
if s.shutSend {
return
}
logger.Trace(s.Id, " shutWrite")
rest := len(s.sendBuffer)
for rest > 0 {
<-s.sendBuffer
rest--
}
s.shutSend = true
if tcpconn, ok := s.conn.(*net.TCPConn); ok {
tcpconn.CloseWrite()
}
}
开发者ID:zwczou,项目名称:goserver,代码行数:16,代码来源:tcp_session.go
示例20: shutWrite
func (s *WsSession) shutWrite() {
if s.shutSend {
return
}
logger.Trace(s.Id, " shutWrite")
rest := len(s.sendBuffer)
for rest > 0 {
<-s.sendBuffer
rest--
}
s.shutSend = true
if s.conn != nil {
s.conn.Close()
s.conn = nil
}
}
开发者ID:zwczou,项目名称:goserver,代码行数:17,代码来源:ws_session.go
注:本文中的github.com/idealeak/goserver/core/logger.Trace函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论