Mirrors/cloud-game
1
0
Fork 0
mirror of https://github.com/giongto35/cloud-game.git synced 2026-07-17 16:50:31 +00:00
Code Issues Projects Releases Packages Wiki Activity

Guard debug log calls with level checks

Browse source
This commit is contained in:
sergystepanov 2026-07-06 15:48:25 +03:00
parent 8f233f2eaa
commit 6823adbb9c
2 changed files with 21 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

12
pkg/com/com.go
View file

@ -56,7 +56,9 @@ func NewConnection[T ~uint8, P Packet[T], X any, P2 Packet2[X]](conn *Connection
func (c *SocketClient[T, P, _, _]) ProcessPackets(fn func(in P) error) chan struct{} {
c.rpc = NewRPC[T, P]()
c.rpc.Handler = func(p P) {
c.log.Debug().Str(logger.DirectionField, logger.MarkIn).Msgf("%v", p.GetType())
if c.log.GetLevel() <= logger.DebugLevel {
c.log.Debug().Str(logger.DirectionField, logger.MarkIn).Msgf("%v", p.GetType())
}
if err := fn(p); err != nil { // 3rd handler
c.log.Error().Err(err).Send()
}
@ -92,7 +94,9 @@ func (c *SocketClient[_, P, X, P2]) Route(in P, out P2) {
// Send makes a blocking call.
func (c *SocketClient[T, P, X, P2]) Send(t T, data any) ([]byte, error) {
c.log.Debug().Str(logger.DirectionField, logger.MarkOut).Msgf("ᵇ%v", t)
if c.log.GetLevel() <= logger.DebugLevel {
c.log.Debug().Str(logger.DirectionField, logger.MarkOut).Msgf("ᵇ%v", t)
}
rq := P2(new(X))
rq.SetType(uint8(t))
rq.SetPayload(data)
@ -101,7 +105,9 @@ func (c *SocketClient[T, P, X, P2]) Send(t T, data any) ([]byte, error) {
// Notify just sends a message and goes further.
func (c *SocketClient[T, P, X, P2]) Notify(t T, data any) {
c.log.Debug().Str(logger.DirectionField, logger.MarkOut).Msgf("%v", t)
if c.log.GetLevel() <= logger.DebugLevel {
c.log.Debug().Str(logger.DirectionField, logger.MarkOut).Msgf("%v", t)
}
rq := P2(new(X))
rq.SetType(uint8(t))
rq.SetPayload(data)

16
pkg/worker/caged/libretro/nanoarch/nanoarch.go
View file

@ -721,13 +721,21 @@ func coreLog(level C.enum_retro_log_level, msg *C.char) {
switch level {
// with debug level cores have too much logs
case C.RETRO_LOG_DEBUG:
Nan0.log.Debug().MsgFunc(func() string { return m(msg) })
if Nan0.log.GetLevel() <= logger.DebugLevel {
Nan0.log.Debug().MsgFunc(func() string { return m(msg) })
}
case C.RETRO_LOG_INFO:
Nan0.log.Info().MsgFunc(func() string { return m(msg) })
if Nan0.log.GetLevel() <= logger.InfoLevel {
Nan0.log.Info().MsgFunc(func() string { return m(msg) })
}
case C.RETRO_LOG_WARN:
Nan0.log.Warn().MsgFunc(func() string { return m(msg) })
if Nan0.log.GetLevel() <= logger.WarnLevel {
Nan0.log.Warn().MsgFunc(func() string { return m(msg) })
}
case C.RETRO_LOG_ERROR:
Nan0.log.Error().MsgFunc(func() string { return m(msg) })
if Nan0.log.GetLevel() <= logger.ErrorLevel {
Nan0.log.Error().MsgFunc(func() string { return m(msg) })
}
default:
Nan0.log.Log().MsgFunc(func() string { return m(msg) })
// RETRO_LOG_DUMMY = INT_MAX