mirror of https://github.com/jetkvm/kvm.git
Revert "fix(network): only trigger time sync when network transitions to online rather than every state change"
This reverts commit 86be6df1d3.
This commit is contained in:
parent
8a76a70d9e
commit
ad4f7c09e1
|
|
@ -101,6 +101,11 @@ func supervise() error {
|
||||||
cmd.Args = os.Args
|
cmd.Args = os.Args
|
||||||
|
|
||||||
logFile, err := os.CreateTemp("", "jetkvm-stdout.log")
|
logFile, err := os.CreateTemp("", "jetkvm-stdout.log")
|
||||||
|
defer func() {
|
||||||
|
// we don't care about the errors here
|
||||||
|
_ = logFile.Close()
|
||||||
|
_ = os.Remove(logFile.Name())
|
||||||
|
}()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("failed to create log file: %w", err)
|
return fmt.Errorf("failed to create log file: %w", err)
|
||||||
}
|
}
|
||||||
|
|
@ -128,8 +133,6 @@ func supervise() error {
|
||||||
}
|
}
|
||||||
|
|
||||||
if exiterr, ok := cmdErr.(*exec.ExitError); ok {
|
if exiterr, ok := cmdErr.(*exec.ExitError); ok {
|
||||||
// createErrorDump will close and rename the file if successful
|
|
||||||
// Note: os.Exit bypasses defer, but file is already handled by createErrorDump
|
|
||||||
createErrorDump(logFile)
|
createErrorDump(logFile)
|
||||||
os.Exit(exiterr.ExitCode())
|
os.Exit(exiterr.ExitCode())
|
||||||
}
|
}
|
||||||
|
|
|
||||||
10
network.go
10
network.go
|
|
@ -6,7 +6,6 @@ import (
|
||||||
"net"
|
"net"
|
||||||
"net/http"
|
"net/http"
|
||||||
"reflect"
|
"reflect"
|
||||||
"sync/atomic"
|
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/jetkvm/kvm/internal/confparser"
|
"github.com/jetkvm/kvm/internal/confparser"
|
||||||
|
|
@ -119,10 +118,6 @@ func setPublicIPReadyState(ipv4Ready, ipv6Ready bool) {
|
||||||
publicIPState.SetIPv4AndIPv6(ipv4Ready, ipv6Ready)
|
publicIPState.SetIPv4AndIPv6(ipv4Ready, ipv6Ready)
|
||||||
}
|
}
|
||||||
|
|
||||||
var (
|
|
||||||
isOnline = &atomic.Bool{}
|
|
||||||
)
|
|
||||||
|
|
||||||
func networkStateChanged(_ string, state types.InterfaceState) {
|
func networkStateChanged(_ string, state types.InterfaceState) {
|
||||||
// do not block the main thread
|
// do not block the main thread
|
||||||
go waitCtrlAndRequestDisplayUpdate(true, "network_state_changed")
|
go waitCtrlAndRequestDisplayUpdate(true, "network_state_changed")
|
||||||
|
|
@ -131,10 +126,7 @@ func networkStateChanged(_ string, state types.InterfaceState) {
|
||||||
writeJSONRPCEvent("networkState", state.ToRpcInterfaceState(), currentSession)
|
writeJSONRPCEvent("networkState", state.ToRpcInterfaceState(), currentSession)
|
||||||
}
|
}
|
||||||
|
|
||||||
previousOnline := isOnline.Load()
|
if state.Online {
|
||||||
isOnline.Store(state.Online)
|
|
||||||
|
|
||||||
if state.Online && !previousOnline {
|
|
||||||
networkLogger.Info().Msg("network state changed to online, triggering time sync")
|
networkLogger.Info().Msg("network state changed to online, triggering time sync")
|
||||||
triggerTimeSyncOnNetworkStateChange()
|
triggerTimeSyncOnNetworkStateChange()
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue