Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/MHSanaei/3x-ui.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMHSanaei <ho3ein.sanaei@gmail.com>2023-05-23 02:13:15 +0300
committerMHSanaei <ho3ein.sanaei@gmail.com>2023-05-23 02:13:15 +0300
commitc38e1e0cfe9fd95f1cd2ed5f6c6cb10bf820b9b6 (patch)
tree6bfc79026a489ae9095cc69a1425a9125112cd1c /xray/process.go
parentf36034541e3b400c44347e6c73f013224697aa6f (diff)
a lot of improvement
Diffstat (limited to 'xray/process.go')
-rw-r--r--xray/process.go15
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()