cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

record global time in client

Browse Source
This commit is contained in:
Lucas Molas 2020-08-06 12:38:31 -03:00
parent ac25502308
commit 2c43138043
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
chain/blocksync/client.go
View File

@ -96,8 +96,9 @@ func (client *BlockSync) doRequest(
// return on the first successful response. // return on the first successful response.
// FIXME: Doing this serially isn't great, but fetching in parallel // FIXME: Doing this serially isn't great, but fetching in parallel
// may not be a good idea either. Think about this more. // may not be a good idea either. Think about this more.
startTime := build.Clock.Now() globalTime := build.Clock.Now()
// FIXME: Should we track time per peer instead of a global one? // Global time used to track what is the expected time we will need to get
// a response if a client fails us.
for _, peer := range peers { for _, peer := range peers {
select { select {
case <-ctx.Done(): case <-ctx.Done():
@ -123,7 +124,7 @@ func (client *BlockSync) doRequest(
continue continue
} }
client.peerTracker.logGlobalSuccess(build.Clock.Since(startTime)) client.peerTracker.logGlobalSuccess(build.Clock.Since(globalTime))
client.host.ConnManager().TagPeer(peer, "bsync", SUCCESS_PEER_TAG_VALUE) client.host.ConnManager().TagPeer(peer, "bsync", SUCCESS_PEER_TAG_VALUE)
return validRes, nil return validRes, nil
} }