diff options
| author | MHSanaei <ho3ein.sanaei@gmail.com> | 2023-05-23 02:13:15 +0300 |
|---|---|---|
| committer | MHSanaei <ho3ein.sanaei@gmail.com> | 2023-05-23 02:13:15 +0300 |
| commit | c38e1e0cfe9fd95f1cd2ed5f6c6cb10bf820b9b6 (patch) | |
| tree | 6bfc79026a489ae9095cc69a1425a9125112cd1c /xray | |
| parent | f36034541e3b400c44347e6c73f013224697aa6f (diff) | |
a lot of improvement
Diffstat (limited to 'xray')
| -rw-r--r-- | xray/process.go | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/xray/process.go b/xray/process.go index 3ce016ed..3f6bf294 100644 --- a/xray/process.go +++ b/xray/process.go @@ -13,6 +13,7 @@ import ( "regexp" "runtime" "strings" + "sync" "time" "x-ui/config" "x-ui/util/common" @@ -184,11 +185,11 @@ func (p *process) Start() (err error) { return err } + var wg sync.WaitGroup + wg.Add(2) + go func() { - defer func() { - common.Recover("") - stdReader.Close() - }() + defer wg.Done() reader := bufio.NewReaderSize(stdReader, 8192) for { line, _, err := reader.ReadLine() @@ -203,10 +204,7 @@ func (p *process) Start() (err error) { }() go func() { - defer func() { - common.Recover("") - errReader.Close() - }() + defer wg.Done() reader := bufio.NewReaderSize(errReader, 8192) for { line, _, err := reader.ReadLine() @@ -225,6 +223,7 @@ func (p *process) Start() (err error) { if err != nil { p.exitErr = err } + wg.Wait() }() p.refreshVersion() |
