Method Sync

internal/utils/clock/manager.go:71–131

Sync 自动校对时间

()

// Sync 自动校对时间
func (this *ClockManager) Sync() error {
	if runtime.GOOS != "linux" {
		return nil
	}

	nodeConfig, _ := nodeconfigs.SharedNodeConfig()
	if nodeConfig == nil {
		return nil
	}

	var config = nodeConfig.Clock
	if config == nil || !config.AutoSync {
		return nil
	}

	// check chrony
	if config.CheckChrony {
		chronycExe, err := executils.LookPath("chronyc")
		if err == nil && len(chronycExe) > 0 {
			var chronyCmd = executils.NewTimeoutCmd(3*time.Second, chronycExe, "tracking")
			err = chronyCmd.Run()
			if err == nil {
				return nil
			}
		}
	}

	var server = config.Server
	if len(server) == 0 {
		server = "pool.ntp.org"
	}

	ntpdate, err := executils.LookPath("ntpdate")
	if err != nil {
		// 使用 date 命令设置
		// date --set TIME
		dateExe, err := executils.LookPath("date")
		if err == nil {
			currentTime, err := this.ReadServer(server)
			if err != nil {
				return fmt.Errorf("read server failed: %w", err)
			}

			var delta = time.Now().Unix() - currentTime.Unix()
			if delta > 1 || delta < -1 { // 相差比较大的时候才会同步
				var err = executils.NewTimeoutCmd(3*time.Second, dateExe, "--set", timeutil.Format("Y-m-d H:i:s+P", currentTime)).
					Run()
				if err != nil {
					return err
				}
			}
		}

		return nil
	}
	if len(ntpdate) > 0 {
		return this.syncNtpdate(ntpdate, server)
	}