mirror of
https://github.com/fankes/komari-agent.git
synced 2025-10-18 18:49:23 +08:00
fix: 上报丢包
This commit is contained in:
@@ -235,9 +235,11 @@ func NewPingTask(conn *ws.SafeConn, taskID uint, pingType, pingTarget string) {
|
|||||||
"value": pingResult,
|
"value": pingResult,
|
||||||
"finished_at": time.Now(),
|
"finished_at": time.Now(),
|
||||||
}
|
}
|
||||||
if pingResult == -1 {
|
// https://github.com/komari-monitor/komari/commit/eb87a4fc330b7d1c407fa4ff70177615a4f50a1f
|
||||||
return
|
// -1 代表丢包,服务端计算
|
||||||
}
|
//if pingResult == -1 {
|
||||||
|
// return
|
||||||
|
//}
|
||||||
if err := conn.WriteJSON(payload); err != nil {
|
if err := conn.WriteJSON(payload); err != nil {
|
||||||
log.Printf("Failed to write JSON to WebSocket: %v", err)
|
log.Printf("Failed to write JSON to WebSocket: %v", err)
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user