curben
/
cloudflared-mirror
mirror of https://github.com/cloudflare/cloudflared.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

TUN-7378: Remove RPC debug logs

This commit is contained in:
Devin Carr 2023-04-19 10:52:25 -07:00
parent e426693330
commit 4de1bc4bba
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tunnelrpc/logtransport.go
View File

@ -24,17 +24,17 @@ func NewTransportLogger(log *zerolog.Logger, t rpc.Transport) rpc.Transport {
} }
func (t *transport) SendMessage(ctx context.Context, msg rpccapnp.Message) error { func (t *transport) SendMessage(ctx context.Context, msg rpccapnp.Message) error {
t.log.Debug().Msgf("rpcconnect: tx %s", formatMsg(msg)) t.log.Trace().Msgf("rpc tx: %s", formatMsg(msg))
return t.Transport.SendMessage(ctx, msg) return t.Transport.SendMessage(ctx, msg)
} }
func (t *transport) RecvMessage(ctx context.Context) (rpccapnp.Message, error) { func (t *transport) RecvMessage(ctx context.Context) (rpccapnp.Message, error) {
msg, err := t.Transport.RecvMessage(ctx) msg, err := t.Transport.RecvMessage(ctx)
if err != nil { if err != nil {
t.log.Debug().Msgf("rpcconnect: rx error: %s", err) t.log.Debug().Msgf("rpc rx error: %s", err)
return msg, err return msg, err
} }
t.log.Debug().Msgf("rpcconnect: rx %s", formatMsg(msg)) t.log.Trace().Msgf("rpc rx: %s", formatMsg(msg))
return msg, nil return msg, nil
} }