mirror/prysm-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/prysm-pulse.git synced 2025-01-13 13:43:30 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix spans in regular_sync (#2031)

Browse Source 
* Fix spans in regular_sync

* more regular sync ctx fixes

* rename
This commit is contained in:
Preston Van Loon 2019-03-19 17:35:01 -04:00 committed by GitHub
parent 7f5b6eb3fc
commit eb080799ec
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
beacon-chain/sync/regular_sync.go
View File

@ -307,7 +307,7 @@ func (rs *RegularSync) receiveBlock(msg p2p.Message) {
return
}
beaconState, err := rs.db.State(msg.Ctx)
beaconState, err := rs.db.State(ctx)
if err != nil {
log.Errorf("Failed to get beacon state: %v", err)
return
@ -519,7 +519,7 @@ func (rs *RegularSync) receiveAttestation(msg p2p.Message) {
}
// Skip if attestation slot is older than last finalized slot in state.
beaconState, err := rs.db.State(msg.Ctx)
beaconState, err := rs.db.State(ctx)
if err != nil {
log.Errorf("Failed to get beacon state: %v", err)
return
@ -531,7 +531,7 @@ func (rs *RegularSync) receiveAttestation(msg p2p.Message) {
return
}
_, sendAttestationSpan := trace.StartSpan(ctx, "beacon-chain.sync.sendAttestation")
ctx, sendAttestationSpan := trace.StartSpan(ctx, "beacon-chain.sync.sendAttestation")
log.WithField("attestationHash", fmt.Sprintf("%#x", attestationRoot)).Debug("Sending newly received attestation to subscribers")
rs.operationsService.IncomingAttFeed().Send(attestation)
sentAttestation.Inc()
@ -556,7 +556,7 @@ func (rs *RegularSync) receiveExitRequest(msg p2p.Message) {
log.Debugf("Received, skipping exit request #%x", h)
return
}
_, sendExitReqSpan := trace.StartSpan(ctx, "sendExitRequest")
ctx, sendExitReqSpan := trace.StartSpan(ctx, "sendExitRequest")
log.WithField("exitReqHash", fmt.Sprintf("%#x", h)).
Debug("Forwarding validator exit request to subscribed services")
rs.operationsService.IncomingExitFeed().Send(exit)
@ -713,12 +713,9 @@ func (rs *RegularSync) handleUnseenAttestationsRequest(msg p2p.Message) {
}
func (rs *RegularSync) broadcastCanonicalBlock(ctx context.Context, announce *pb.BeaconBlockAnnounce) {
_, span := trace.StartSpan(ctx, "beacon-chain.sync.broadcastCanonicalBlock")
ctx, span := trace.StartSpan(ctx, "beacon-chain.sync.broadcastCanonicalBlock")
defer span.End()
_, sendBlockAnnounceSpan := trace.StartSpan(ctx, "beacon-chain.sync.sendBlockAnnounce")
log.Debugf("Announcing canonical block %#x", announce.Hash)
rs.p2p.Broadcast(ctx, announce)
sentBlockAnnounce.Inc()
sendBlockAnnounceSpan.End()
}