From 0c6df5d6cfcd3c8adb43ec0418a6b3c3822e0f31 Mon Sep 17 00:00:00 2001 From: mykola2312 <49044616+mykola2312@users.noreply.github.com> Date: Fri, 17 Jan 2025 08:25:43 +0200 Subject: [PATCH] do some todos --- net/lux_router.go | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/net/lux_router.go b/net/lux_router.go index 5ca1254..0ea0d7d 100644 --- a/net/lux_router.go +++ b/net/lux_router.go @@ -294,7 +294,6 @@ func (r *LuxRouter) Recv() (LuxPacket, error) { key, _ := r.GetRouteKey(route) packet, err = DecryptLuxPacket(dgram, key) if err != nil { - // do we really fail here? log.Debugf("DecryptLuxPacket err %v for route %v", err, route) return packet, err } @@ -388,8 +387,11 @@ func (r *LuxRouter) Send(packet LuxPacket) error { return err } - // TODO: close route if it fails? - return route.Associated.Send(dgram) + if err := route.Associated.Send(dgram); err != nil { + log.Warningf("multicast to %s failed: %v", dgram.Target, err) + return err + } + return nil } // In multicast we send packet to all routes by group. Group is lux peer type @@ -408,8 +410,8 @@ func (r *LuxRouter) Multicast(packet LuxPacket, group proto.LuxType) error { } if err = route.Associated.Send(dgram); err != nil { - // TODO: close route if it fails? - return err + log.Warningf("multicast to %s failed: %v", dgram.Target, err) + continue } } }