drop log

Author: null

proxy/tun/stack_gvisor.go

@@ -112,8 +112,16 @@ func (t *stackGVisor) Start() error {
 		// source/destination of the packet we process as incoming, on gVisor side are Remote/Local
 		// in other terms, src is the side behind tun, dst is the side behind gVisor
 		// this function handle packets passing from the tun to the gVisor, therefore the src/dst assignement
-		src := net.UDPDestination(net.IPAddress(id.RemoteAddress.AsSlice()), net.Port(id.RemotePort))
-		dst := net.UDPDestination(net.IPAddress(id.LocalAddress.AsSlice()), net.Port(id.LocalPort))
+		srcIP := net.IPAddress(id.RemoteAddress.AsSlice())
+		dstIP := net.IPAddress(id.LocalAddress.AsSlice())
+		if srcIP == nil {
+			errors.LogDebug(context.Background(), "drop udp with size ", len(data), " > invalid src address ", id.RemoteAddress.AsSlice())
+		}
+		if dstIP == nil {
+			errors.LogDebug(context.Background(), "drop udp with size ", len(data), " > invalid dst address ", id.LocalAddress.AsSlice())
+		}
+		src := net.UDPDestination(srcIP, net.Port(id.RemotePort))
+		dst := net.UDPDestination(dstIP, net.Port(id.LocalPort))
 
 		return udpForwarder.HandlePacket(src, dst, data)
 	})

proxy/tun/udp_fullcone.go

@@ -48,6 +48,7 @@ func (u *udpConnectionHandler) HandlePacket(src net.Destination, dst net.Destina
 			dest: &dst,
 		}:
 		default:
+			errors.LogDebug(context.Background(), "drop udp with size ", len(data), " to ", dst.NetAddr(), " original ", conn.dst.NetAddr(), " > queue full")
 		}
 		u.RUnlock()
 		return true
@@ -73,6 +74,7 @@ func (u *udpConnectionHandler) HandlePacket(src net.Destination, dst net.Destina
 		dest: &dst,
 	}:
 	default:
+		errors.LogDebug(context.Background(), "drop udp with size ", len(data), " to ", dst.NetAddr(), " original ", conn.dst.NetAddr(), " > queue full")
 	}
 
 	return true
@@ -108,7 +110,7 @@ func (c *udpConn) ReadMultiBuffer() (buf.MultiBuffer, error) {
 
 		_, err := b.Write(e.data)
 		if err != nil {
-			errors.LogInfoInner(context.Background(), err, "drop udp with size ", len(e.data), " to ", e.dest.NetAddr(), " original ", c.dst.NetAddr())
+			errors.LogDebugInner(context.Background(), err, "drop udp with size ", len(e.data), " to ", e.dest.NetAddr(), " original ", c.dst.NetAddr())
 			b.Release()
 			continue
 		}