chenyh
/
vRp.CD2g_test
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

添加获取连接的接口，优化事件参数

This commit is contained in:
kercylan98 2023-05-05 17:01:49 +08:00
parent 30848faebc
commit ec341ecaaa
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
server/event.go
View File

@ -9,9 +9,9 @@ import (
type StartBeforeEventHandle func(srv *Server) type StartBeforeEventHandle func(srv *Server)
type StartFinishEventHandle func(srv *Server) type StartFinishEventHandle func(srv *Server)
type ConnectionReceivePacketEventHandle func(conn *Conn, packet []byte) type ConnectionReceivePacketEventHandle func(srv *Server, conn *Conn, packet []byte)
type ConnectionOpenedEventHandle func(conn *Conn) type ConnectionOpenedEventHandle func(srv *Server, conn *Conn)
type ConnectionClosedEventHandle func(conn *Conn) type ConnectionClosedEventHandle func(srv *Server, conn *Conn)
type event struct { type event struct {
*Server *Server
@ -59,7 +59,7 @@ func (slf *event) OnConnectionClosedEvent(conn *Conn) {
log.Debug("Server", zap.String("ConnectionClosed", conn.GetID())) log.Debug("Server", zap.String("ConnectionClosed", conn.GetID()))
slf.Server.connections.Delete(conn.ip) slf.Server.connections.Delete(conn.ip)
for _, handle := range slf.connectionClosedEventHandles { for _, handle := range slf.connectionClosedEventHandles {
handle(conn) handle(slf.Server, conn)
} }
} }
@ -76,7 +76,7 @@ func (slf *event) OnConnectionOpenedEvent(conn *Conn) {
log.Debug("Server", zap.String("ConnectionOpened", conn.GetID())) log.Debug("Server", zap.String("ConnectionOpened", conn.GetID()))
slf.Server.connections.Set(conn.ip, conn) slf.Server.connections.Set(conn.ip, conn)
for _, handle := range slf.connectionOpenedEventHandles { for _, handle := range slf.connectionOpenedEventHandles {
handle(conn) handle(slf.Server, conn)
} }
} }
@ -91,7 +91,7 @@ func (slf *event) RegConnectionReceivePacketEvent(handle ConnectionReceivePacket
func (slf *event) OnConnectionReceivePacketEvent(conn *Conn, packet []byte) { func (slf *event) OnConnectionReceivePacketEvent(conn *Conn, packet []byte) {
for _, handle := range slf.connectionReceivePacketEventHandles { for _, handle := range slf.connectionReceivePacketEventHandles {
handle(conn, packet) handle(slf.Server, conn, packet)
} }
} }