reduce tunnel debug logging
This commit is contained in:
parent
5385ef65bb
commit
cf3cf1791e
|
@ -15,7 +15,6 @@ import (
|
||||||
refs "go.mindeco.de/ssb-refs"
|
refs "go.mindeco.de/ssb-refs"
|
||||||
|
|
||||||
kitlog "github.com/go-kit/kit/log"
|
kitlog "github.com/go-kit/kit/log"
|
||||||
"github.com/go-kit/kit/log/level"
|
|
||||||
"go.cryptoscope.co/muxrpc/v2"
|
"go.cryptoscope.co/muxrpc/v2"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -29,18 +28,15 @@ type Handler struct {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (h *Handler) isRoom(context.Context, *muxrpc.Request) (interface{}, error) {
|
func (h *Handler) isRoom(context.Context, *muxrpc.Request) (interface{}, error) {
|
||||||
level.Debug(h.logger).Log("called", "isRoom")
|
|
||||||
return true, nil
|
return true, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (h *Handler) ping(context.Context, *muxrpc.Request) (interface{}, error) {
|
func (h *Handler) ping(context.Context, *muxrpc.Request) (interface{}, error) {
|
||||||
now := time.Now().UnixNano() / 1000
|
now := time.Now().UnixNano() / 1000
|
||||||
level.Debug(h.logger).Log("called", "ping")
|
|
||||||
return now, nil
|
return now, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (h *Handler) announce(_ context.Context, req *muxrpc.Request) (interface{}, error) {
|
func (h *Handler) announce(_ context.Context, req *muxrpc.Request) (interface{}, error) {
|
||||||
level.Debug(h.logger).Log("called", "announce")
|
|
||||||
ref, err := network.GetFeedRefFromAddr(req.RemoteAddr())
|
ref, err := network.GetFeedRefFromAddr(req.RemoteAddr())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
@ -63,8 +59,6 @@ func (h *Handler) leave(_ context.Context, req *muxrpc.Request) (interface{}, er
|
||||||
}
|
}
|
||||||
|
|
||||||
func (h *Handler) endpoints(ctx context.Context, req *muxrpc.Request, snk *muxrpc.ByteSink) error {
|
func (h *Handler) endpoints(ctx context.Context, req *muxrpc.Request, snk *muxrpc.ByteSink) error {
|
||||||
level.Debug(h.logger).Log("called", "endpoints")
|
|
||||||
|
|
||||||
toPeer := newForwarder(snk)
|
toPeer := newForwarder(snk)
|
||||||
|
|
||||||
// for future updates
|
// for future updates
|
||||||
|
|
Loading…
Reference in New Issue