update ping lock
This commit is contained in:
parent
c915170b58
commit
b9cd364535
@ -1446,11 +1446,16 @@ loop:
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
rt := time.Now()
|
|
||||||
ask, err := api.ClientQueryAsk(ctx, *mi.PeerId, miner)
|
ask, err := api.ClientQueryAsk(ctx, *mi.PeerId, miner)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
rt := time.Now()
|
||||||
|
_, err = api.ClientQueryAsk(ctx, *mi.PeerId, miner)
|
||||||
|
if err != nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
pingDuration := time.Now().Sub(rt)
|
pingDuration := time.Now().Sub(rt)
|
||||||
|
|
||||||
atomic.AddInt64(&got, 1)
|
atomic.AddInt64(&got, 1)
|
||||||
|
Loading…
Reference in New Issue
Block a user