fixed xray restarting after being manually stopped

This commit is contained in:
fgsfds 2025-08-07 18:03:16 +05:00
parent 4f25eb230e
commit a72c86d0f3
No known key found for this signature in database
GPG key ID: 264C1B9113012917
4 changed files with 31 additions and 10 deletions

View file

@ -169,9 +169,6 @@
<a-col> <a-col>
<a-icon type="bars" :style="{ cursor: 'pointer', float: 'right' }" @click="openLogs()"></a-icon> <a-icon type="bars" :style="{ cursor: 'pointer', float: 'right' }" @click="openLogs()"></a-icon>
</a-col> </a-col>
<a-col>
<a-icon type="bars" :style="{ cursor: 'pointer', float: 'right' }" @click="openXrayLogs()"></a-icon>
</a-col>
</a-row> </a-row>
</span> </span>
<template slot="content"> <template slot="content">

View file

@ -16,7 +16,7 @@ func NewCheckXrayRunningJob() *CheckXrayRunningJob {
} }
func (j *CheckXrayRunningJob) Run() { func (j *CheckXrayRunningJob) Run() {
if j.xrayService.IsXrayRunning() { if !j.xrayService.IsNeedToResurrect() {
j.checkTime = 0 j.checkTime = 0
} else { } else {
j.checkTime++ j.checkTime++

View file

@ -347,7 +347,6 @@ func (s *ServerService) StopXrayService() error {
} }
func (s *ServerService) RestartXrayService() error { func (s *ServerService) RestartXrayService() error {
s.xrayService.StopXray()
err := s.xrayService.RestartXray(true) err := s.xrayService.RestartXray(true)
if err != nil { if err != nil {
logger.Error("start xray failed:", err) logger.Error("start xray failed:", err)

View file

@ -3,6 +3,7 @@ package service
import ( import (
"encoding/json" "encoding/json"
"errors" "errors"
"runtime"
"sync" "sync"
"x-ui/logger" "x-ui/logger"
@ -14,7 +15,8 @@ import (
var ( var (
p *xray.Process p *xray.Process
lock sync.Mutex lock sync.Mutex
isNeedXrayRestart atomic.Bool isNeedXrayRestart atomic.Bool // Indicates that restart was requested for Xray
isManuallyStopped atomic.Bool // Indicates that Xray was stopped manually (i.e. didn't crash)
result string result string
) )
@ -32,7 +34,15 @@ func (s *XrayService) GetXrayErr() error {
if p == nil { if p == nil {
return nil return nil
} }
return p.GetErr()
err := p.GetErr()
if runtime.GOOS == "windows" && err.Error() == "exit status 1" {
// exit status 1 on Windows means that Xray process was killed
return nil
}
return err
} }
func (s *XrayService) GetXrayResult() string { func (s *XrayService) GetXrayResult() string {
@ -45,7 +55,14 @@ func (s *XrayService) GetXrayResult() string {
if p == nil { if p == nil {
return "" return ""
} }
result = p.GetResult() result = p.GetResult()
if runtime.GOOS == "windows" && result == "exit status 1" {
// exit status 1 on Windows means that Xray process was killed
return ""
}
return result return result
} }
@ -184,7 +201,8 @@ func (s *XrayService) GetXrayTraffic() ([]*xray.Traffic, []*xray.ClientTraffic,
func (s *XrayService) RestartXray(isForce bool) error { func (s *XrayService) RestartXray(isForce bool) error {
lock.Lock() lock.Lock()
defer lock.Unlock() defer lock.Unlock()
logger.Debug("restart xray, force:", isForce) logger.Debug("restart Xray, force:", isForce)
isManuallyStopped.Store(false)
xrayConfig, err := s.GetXrayConfig() xrayConfig, err := s.GetXrayConfig()
if err != nil { if err != nil {
@ -192,8 +210,8 @@ func (s *XrayService) RestartXray(isForce bool) error {
} }
if s.IsXrayRunning() { if s.IsXrayRunning() {
if !isForce && p.GetConfig().Equals(xrayConfig) { if !isForce && p.GetConfig().Equals(xrayConfig) && !isNeedXrayRestart.Load() {
logger.Debug("It does not need to restart xray") logger.Debug("It does not need to restart Xray")
return nil return nil
} }
p.Stop() p.Stop()
@ -205,12 +223,14 @@ func (s *XrayService) RestartXray(isForce bool) error {
if err != nil { if err != nil {
return err return err
} }
return nil return nil
} }
func (s *XrayService) StopXray() error { func (s *XrayService) StopXray() error {
lock.Lock() lock.Lock()
defer lock.Unlock() defer lock.Unlock()
isManuallyStopped.Store(true)
logger.Debug("Attempting to stop Xray...") logger.Debug("Attempting to stop Xray...")
if s.IsXrayRunning() { if s.IsXrayRunning() {
return p.Stop() return p.Stop()
@ -225,3 +245,8 @@ func (s *XrayService) SetToNeedRestart() {
func (s *XrayService) IsNeedRestartAndSetFalse() bool { func (s *XrayService) IsNeedRestartAndSetFalse() bool {
return isNeedXrayRestart.CompareAndSwap(true, false) return isNeedXrayRestart.CompareAndSwap(true, false)
} }
// Check if Xray is not running and wasn't stopped manually
func (s *XrayService) IsNeedToResurrect() bool {
return !s.IsXrayRunning() && !isManuallyStopped.Load()
}