feat: server.Server 事件消息添加 mark 标记,方便问题定位

This commit is contained in:
kercylan98 2023-07-27 14:39:05 +08:00
parent 8dde18a36e
commit 471ee48644
1 changed files with 7 additions and 7 deletions

View File

@ -85,7 +85,7 @@ func (slf *event) OnConsoleCommandEvent(command string) {
handle(slf.Server) handle(slf.Server)
} }
} }
}) }, "ConsoleCommandEvent")
} }
// RegStartBeforeEvent 在服务器初始化完成启动前立刻执行被注册的事件处理函数 // RegStartBeforeEvent 在服务器初始化完成启动前立刻执行被注册的事件处理函数
@ -117,7 +117,7 @@ func (slf *event) OnStartFinishEvent() {
for _, handle := range slf.startFinishEventHandles { for _, handle := range slf.startFinishEventHandles {
handle(slf.Server) handle(slf.Server)
} }
}) }, "StartFinishEvent")
} }
// RegConnectionClosedEvent 在连接关闭后将立刻执行被注册的事件处理函数 // RegConnectionClosedEvent 在连接关闭后将立刻执行被注册的事件处理函数
@ -136,7 +136,7 @@ func (slf *event) OnConnectionClosedEvent(conn *Conn, err any) {
} }
conn.Close() conn.Close()
slf.Server.online.Delete(conn.GetID()) slf.Server.online.Delete(conn.GetID())
}) }, "ConnectionClosedEvent")
} }
// RegConnectionOpenedEvent 在连接打开后将立刻执行被注册的事件处理函数 // RegConnectionOpenedEvent 在连接打开后将立刻执行被注册的事件处理函数
@ -154,7 +154,7 @@ func (slf *event) OnConnectionOpenedEvent(conn *Conn) {
for _, handle := range slf.connectionOpenedEventHandles { for _, handle := range slf.connectionOpenedEventHandles {
handle(slf.Server, conn) handle(slf.Server, conn)
} }
}) }, "ConnectionOpenedEvent")
} }
// RegConnectionReceivePacketEvent 在接收到数据包时将立刻执行被注册的事件处理函数 // RegConnectionReceivePacketEvent 在接收到数据包时将立刻执行被注册的事件处理函数
@ -195,7 +195,7 @@ func (slf *event) OnMessageErrorEvent(message *Message, err error) {
for _, handle := range slf.messageErrorEventHandles { for _, handle := range slf.messageErrorEventHandles {
handle(slf.Server, message, err) handle(slf.Server, message, err)
} }
}) }, "MessageErrorEvent")
} }
// RegMessageLowExecEvent 在处理消息缓慢时将立即执行被注册的事件处理函数 // RegMessageLowExecEvent 在处理消息缓慢时将立即执行被注册的事件处理函数
@ -209,7 +209,7 @@ func (slf *event) OnMessageLowExecEvent(message *Message, cost time.Duration) {
for _, handle := range slf.messageLowExecEventHandles { for _, handle := range slf.messageLowExecEventHandles {
handle(slf.Server, message, cost) handle(slf.Server, message, cost)
} }
}) }, "MessageLowExecEvent")
} }
// RegConnectionOpenedAfterEvent 在连接打开事件处理完成后将立刻执行被注册的事件处理函数 // RegConnectionOpenedAfterEvent 在连接打开事件处理完成后将立刻执行被注册的事件处理函数
@ -226,7 +226,7 @@ func (slf *event) OnConnectionOpenedAfterEvent(conn *Conn) {
for _, handle := range slf.connectionOpenedAfterEventHandles { for _, handle := range slf.connectionOpenedAfterEventHandles {
handle(slf.Server, conn) handle(slf.Server, conn)
} }
}) }, "ConnectionOpenedAfterEvent")
} }
func (slf *event) check() { func (slf *event) check() {