mirror of https://github.com/jetkvm/kvm.git
54 lines
1.1 KiB
Go
54 lines
1.1 KiB
Go
package kvm
|
|
|
|
import (
|
|
"strconv"
|
|
"time"
|
|
|
|
"github.com/jetkvm/kvm/internal/timesync"
|
|
)
|
|
|
|
var (
|
|
timeSync *timesync.TimeSync
|
|
builtTimestamp string
|
|
)
|
|
|
|
func isTimeSyncNeeded() bool {
|
|
if builtTimestamp == "" {
|
|
timesyncLogger.Warn().Msg("built timestamp is not set, time sync is needed")
|
|
return true
|
|
}
|
|
|
|
ts, err := strconv.Atoi(builtTimestamp)
|
|
if err != nil {
|
|
timesyncLogger.Warn().Str("error", err.Error()).Msg("failed to parse built timestamp")
|
|
return true
|
|
}
|
|
|
|
// builtTimestamp is UNIX timestamp in seconds
|
|
builtTime := time.Unix(int64(ts), 0)
|
|
now := time.Now()
|
|
|
|
if now.Sub(builtTime) < 0 {
|
|
timesyncLogger.Warn().
|
|
Str("built_time", builtTime.Format(time.RFC3339)).
|
|
Str("now", now.Format(time.RFC3339)).
|
|
Msg("system time is behind the built time, time sync is needed")
|
|
return true
|
|
}
|
|
|
|
return false
|
|
}
|
|
|
|
func initTimeSync() {
|
|
timeSync = timesync.NewTimeSync(×ync.TimeSyncOptions{
|
|
Logger: timesyncLogger,
|
|
NetworkConfig: config.NetworkConfig,
|
|
PreCheckFunc: func() (bool, error) {
|
|
if !networkState.IsOnline() {
|
|
return false, nil
|
|
}
|
|
return true, nil
|
|
},
|
|
})
|
|
}
|