mirror/prysm-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/prysm-pulse.git synced 2024-12-26 05:17:22 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Handle Attestations in a Separate Goroutine (#3487)

Browse Source 
* move into separate routine

* preston's review

* use opencensus
This commit is contained in:
Nishant Das 2019-09-17 21:47:21 +05:30 committed by Raul Jordan
parent b63e938cfb
commit b1b76ac87c
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
beacon-chain/rpc/attester_server.go
View File

@ -37,11 +37,12 @@ func (as *AttesterServer) SubmitAttestation(ctx context.Context, att *ethpb.Atte
return nil, errors.Wrap(err, "failed to sign root attestation") return nil, errors.Wrap(err, "failed to sign root attestation")
} }
if err := as.operationsHandler.HandleAttestation(ctx, att); err != nil {
return nil, err
}
go func() { go func() {
ctx = trace.NewContext(context.Background(), trace.FromContext(ctx))
if err := as.operationsHandler.HandleAttestation(ctx, att); err != nil {
log.WithError(err).Error("could not handle attestation in operations service")
return
}
if err := as.attReceiver.ReceiveAttestation(ctx, att); err != nil { if err := as.attReceiver.ReceiveAttestation(ctx, att); err != nil {
log.WithError(err).Error("could not receive attestation in chain service") log.WithError(err).Error("could not receive attestation in chain service")
} }