Method Start

backend/xray/core.go:180–263

(xConfig *Config, debugMode bool)

}

func (c *Core) Start(xConfig *Config, debugMode bool) error {
	accessFile, errorFile := xConfig.GetLogFiles()

	bytesConfig, err := xConfig.ToBytes()
	if debugMode {
		if err = c.GenerateConfigFile(bytesConfig); err != nil {
			return err
		}
	}

	c.mu.Lock()
	defer c.mu.Unlock()

	// Check if already started after acquiring lock to prevent race condition
	if c.Started() {
		return errors.New("xray is started already")
	}

	c.runtimeMu.Lock()
	c.runtimeLogs.reset()
	c.runtimeMu.Unlock()

	c.EnableStartupDiagnostics(c.startupLogSize)
	c.setStartupLogPhase()

	// Clean up any orphaned xray processes before starting new one
	if err := c.cleanupOrphanedProcesses(); err != nil {
		log.Printf("warning: failed to cleanup orphaned processes: %v", err)
	}

	// Force kill any orphaned process in this Core instance before starting new one
	if c.process != nil && c.process.Process != nil {
		pid := c.process.Process.Pid
		_ = c.process.Process.Kill()
		_ = killProcessTree(pid)
		c.process = nil
		c.processPID = 0
	}

	socketPaths := collectUnixSocketPaths(xConfig)
	removeUnixSocketFiles(socketPaths)

	cmd := exec.Command(c.executablePath, "-c", "stdin:")
	cmd.Env = append(os.Environ(), "XRAY_LOCATION_ASSET="+c.assetsPath)
	// Set process attributes for proper process management
	setProcAttributes(cmd)

	stdout, err := cmd.StdoutPipe()
	if err != nil {
		return err
	}

	// Create a new logger for this core instance
	c.logger = nodeLogger.New(debugMode)
	if err = c.logger.SetLogFile(accessFile, errorFile); err != nil {
		return err
	}