Browse Source

优化ping过程的延迟计算

gitlink
Sydonian 2 years ago
parent
commit
3c4696ee42
1 changed files with 12 additions and 0 deletions
  1. +12
    -0
      common/pkgs/connectivity/collector.go

+ 12
- 0
common/pkgs/connectivity/collector.go View File

@@ -177,6 +177,18 @@ func (r *Collector) ping(node cdssdk.Node) Connectivity {
}
defer stgglb.AgentRPCPool.Release(agtCli)

// 第一次ping保证网络连接建立成功
err = agtCli.Ping(*stgglb.Local.NodeID)
if err != nil {
log.Warnf("pre ping: %v", err)
return Connectivity{
ToNodeID: node.NodeID,
Delay: nil,
TestTime: time.Now(),
}
}

// 第二次ping计算延迟
start := time.Now()
err = agtCli.Ping(*stgglb.Local.NodeID)
if err != nil {


Loading…
Cancel
Save