From b0aaa8680619d31100c45d6aa8b87b15eae406db Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=96=E7=95=8C?= Date: Tue, 25 Jun 2024 13:10:25 +0800 Subject: [PATCH] Minor fixes --- box.go | 6 +++--- inbound/tun.go | 5 +++-- outbound/urltest.go | 4 ++-- 3 files changed, 8 insertions(+), 7 deletions(-) diff --git a/box.go b/box.go index b4d5cb5d..70235fd3 100644 --- a/box.go +++ b/box.go @@ -203,7 +203,7 @@ func (s *Box) PreStart() error { defer func() { v := recover() if v != nil { - log.Error(E.Cause(err, "origin error")) + println(err.Error()) debug.PrintStack() panic("panic on early close: " + fmt.Sprint(v)) } @@ -222,9 +222,9 @@ func (s *Box) Start() error { defer func() { v := recover() if v != nil { - log.Error(E.Cause(err, "origin error")) + println(err.Error()) debug.PrintStack() - panic("panic on early close: " + fmt.Sprint(v)) + println("panic on early start: " + fmt.Sprint(v)) } }() s.Close() diff --git a/inbound/tun.go b/inbound/tun.go index e82ea122..7bd700d3 100644 --- a/inbound/tun.go +++ b/inbound/tun.go @@ -174,7 +174,7 @@ func (t *Tun) Start() error { forwarderBindInterface = true includeAllNetworks = t.platformInterface.IncludeAllNetworks() } - t.tunStack, err = tun.NewStack(t.stack, tun.StackOptions{ + tunStack, err := tun.NewStack(t.stack, tun.StackOptions{ Context: t.ctx, Tun: tunInterface, TunOptions: t.tunOptions, @@ -190,8 +190,9 @@ func (t *Tun) Start() error { return err } monitor.Start("initiating tun stack") - err = t.tunStack.Start() + err = tunStack.Start() monitor.Finish() + t.tunStack = tunStack if err != nil { return err } diff --git a/outbound/urltest.go b/outbound/urltest.go index aa7cff6c..c6e38ec5 100644 --- a/outbound/urltest.go +++ b/outbound/urltest.go @@ -385,9 +385,9 @@ func (g *URLTestGroup) urlTest(ctx context.Context, force bool) (map[string]uint continue } b.Go(realTag, func() (any, error) { - ctx, cancel := context.WithTimeout(context.Background(), C.TCPTimeout) + testCtx, cancel := context.WithTimeout(g.ctx, C.TCPTimeout) defer cancel() - t, err := urltest.URLTest(ctx, g.link, p) + t, err := urltest.URLTest(testCtx, g.link, p) if err != nil { g.logger.Debug("outbound ", tag, " unavailable: ", err) g.history.DeleteURLTestHistory(realTag)