TRKJ/EdgeNode
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeNode.git synced 2025-12-01 13:13:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化时钟同步相关代码

Browse Source
This commit is contained in:
刘祥超
2022-09-25 14:26:46 +08:00
parent 2cd1bb7f95
commit 8bec1cf68e
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
internal/utils/clock/manager.go
View File

@@ -83,7 +83,7 @@ func (this *ClockManager) Sync() error {
// date --set TIME // date --set TIME
dateExe, err := exec.LookPath("date") dateExe, err := exec.LookPath("date")
if err == nil { if err == nil {
currentTime, err := this.readServer(server) currentTime, err := this.ReadServer(server)
if err != nil { if err != nil {
return errors.New("read server failed: " + err.Error()) return errors.New("read server failed: " + err.Error())
} }
@@ -119,7 +119,7 @@ func (this *ClockManager) syncNtpdate(ntpdate string, server string) error {
} }
// 参考自：https://medium.com/learning-the-go-programming-language/lets-make-an-ntp-client-in-go-287c4b9a969f // 参考自：https://medium.com/learning-the-go-programming-language/lets-make-an-ntp-client-in-go-287c4b9a969f
func (this *ClockManager) readServer(server string) (time.Time, error) { func (this *ClockManager) ReadServer(server string) (time.Time, error) {
conn, err := net.Dial("udp", server+":123") conn, err := net.Dial("udp", server+":123")
if err != nil { if err != nil {
return time.Time{}, errors.New("connect to server failed: " + err.Error()) return time.Time{}, errors.New("connect to server failed: " + err.Error())

3
internal/utils/clock/manager_test.go
View File

@@ -3,9 +3,10 @@
package clock_test package clock_test
import ( import (
"github.com/TeaOSLab/EdgeNode/internal/utils/clock"
"testing" "testing"
) )
func TestReadServer(t *testing.T) { func TestReadServer(t *testing.T) {
t.Log(clock.NewClockManager().ReadServer("pool.ntp.org"))
} }