Amend XUDP related logs

- Useful for debug XUDP improvements
- Move XUDP log in core log
- Freedom connection log show local port

Author: yuhan6665

common/mux/server.go

@@ -2,7 +2,6 @@ package mux
 
 import (
 	"context"
-	"fmt"
 	"io"
 
 	"github.com/xtls/xray-core/common"
@@ -12,7 +11,6 @@ import (
 	"github.com/xtls/xray-core/common/net"
 	"github.com/xtls/xray-core/common/protocol"
 	"github.com/xtls/xray-core/common/session"
-	"github.com/xtls/xray-core/common/xudp"
 	"github.com/xtls/xray-core/core"
 	"github.com/xtls/xray-core/features/routing"
 	"github.com/xtls/xray-core/transport"
@@ -148,9 +146,7 @@ func (w *ServerWorker) handleStatusNew(ctx context.Context, meta *FrameMetadata,
 		} else {
 			if x.Status == Initializing { // nearly impossible
 				XUDPManager.Unlock()
-				if xudp.Show {
-					fmt.Printf("XUDP hit: %v err: conflict\n", meta.GlobalID)
-				}
+				newError("XUDP hit ", meta.GlobalID).Base(newError("conflict")).AtWarning().WriteToLog(session.ExportIDToError(ctx))
 				// It's not a good idea to return an err here, so just let client wait.
 				// Client will receive an End frame after sending a Keep frame.
 				return nil
@@ -168,9 +164,7 @@ func (w *ServerWorker) handleStatusNew(ctx context.Context, meta *FrameMetadata,
 				b.Release()
 				mb = nil
 			}
-			if xudp.Show {
-				fmt.Printf("XUDP hit: %v err: %v\n", meta.GlobalID, err)
-			}
+			newError("XUDP hit ", meta.GlobalID).Base(err).WriteToLog(session.ExportIDToError(ctx))
 		}
 		if mb != nil {
 			ctx = session.ContextWithTimeoutOnly(ctx, true)
@@ -180,20 +174,15 @@ func (w *ServerWorker) handleStatusNew(ctx context.Context, meta *FrameMetadata,
 				XUDPManager.Lock()
 				delete(XUDPManager.Map, x.GlobalID)
 				XUDPManager.Unlock()
-				err = newError("failed to dispatch request to ", meta.Target).Base(err)
-				if xudp.Show {
-					fmt.Printf("XUDP new: %v err: %v\n", meta.GlobalID, err)
-				}
+				err = newError("XUDP new ", meta.GlobalID).Base(newError("failed to dispatch request to ", meta.Target).Base(err))
 				return err // it will break the whole Mux connection
 			}
 			link.Writer.WriteMultiBuffer(mb) // it's meaningless to test a new pipe
 			x.Mux = &Session{
 				input:  link.Reader,
 				output: link.Writer,
 			}
-			if xudp.Show {
-				fmt.Printf("XUDP new: %v err: %v\n", meta.GlobalID, err)
-			}
+			newError("XUDP new ", meta.GlobalID).Base(err).WriteToLog(session.ExportIDToError(ctx))
 		}
 		x.Mux = &Session{
 			input:        x.Mux.input,

common/mux/session.go

@@ -183,7 +183,7 @@ func (s *Session) Close(locked bool) error {
 			s.XUDP.Expire = time.Now().Add(time.Minute)
 			s.XUDP.Status = Expiring
 			if xudp.Show {
-				fmt.Printf("XUDP put: %v\n", s.XUDP.GlobalID)
+				fmt.Printf("XUDP put %v\n", s.XUDP.GlobalID)
 			}
 		}
 		XUDPManager.Unlock()
@@ -235,7 +235,7 @@ func init() {
 					x.Interrupt()
 					delete(XUDPManager.Map, id)
 					if xudp.Show {
-						fmt.Printf("XUDP del: %v\n", id)
+						fmt.Printf("XUDP del %v\n", id)
 					}
 				}
 			}

proxy/freedom/freedom.go

@@ -117,7 +117,6 @@ func (h *Handler) Process(ctx context.Context, link *transport.Link, dialer inte
 			UDPOverride.Port = destination.Port
 		}
 	}
-	newError("opening connection to ", destination).WriteToLog(session.ExportIDToError(ctx))
 
 	input := link.Reader
 	output := link.Writer
@@ -148,6 +147,7 @@ func (h *Handler) Process(ctx context.Context, link *transport.Link, dialer inte
 		return newError("failed to open connection to ", destination).Base(err)
 	}
 	defer conn.Close()
+	newError("connection opened to ", destination, ", local endpoint ", conn.LocalAddr(), ", remote endpoint ", conn.RemoteAddr()).WriteToLog(session.ExportIDToError(ctx))
 
 	var newCtx context.Context
 	var newCancel context.CancelFunc