YuanHong
/
YHEchoPackage
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 22 Wiki Activity

添加定义系统事件

master v0.0.20
mic 2023-02-17 18:14:38 +08:00
parent 35b91a6004
commit 0c00cf583c
2 changed files with 4 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tcp/gnetserver.go
View File

@ -101,11 +101,8 @@ func (s *GnetServer) OnClose(c gnet.Conn, err error) (action gnet.Action) {
connected := atomic.AddInt32(&s.connected, -1)
logx.Infof("在线：%d,最高在线：%d", connected, atomic.LoadInt32(&s.maxConnected))
if handler, ok := s.handlers.Load(define.SYS_NET_ENV_CLOSE); ok {
_ = s.workerPool.Submit(
func() {
h := handler.(HandlerFunc)
h(c, nil)
})
h := handler.(HandlerFunc)
h(c, nil)
}
return
}

7
ws/gnetserver.go
View File

@ -98,11 +98,8 @@ func (s *GnetServer) OnClose(c gnet.Conn, err error) (action gnet.Action) {
connected := atomic.AddInt32(&s.connected, -1)
logx.Infof("在线：%d,最高在线：%d", connected, atomic.LoadInt32(&s.maxConnected))
if handler, ok := s.handlers.Load(define.SYS_NET_ENV_CLOSE); ok {
_ = s.workerPool.Submit(
func() {
h := handler.(HandlerFunc)
h(c, nil)
})
h := handler.(HandlerFunc)
h(c, nil)
}
return
}