mirror of
https://gitlab.com/pulsechaincom/prysm-pulse.git
synced 2024-12-25 21:07:18 +00:00
3ec2a0f9e0
* implements blocks queue * refactors updateCounter method * fixes deadlock on stop w/o start * refactors updateSchedulerState * more tests on schduler * parseFetchResponse tests * wraps up tests for blocks queue * eod commit * fixes data race in round robin * revamps fetcher * fixes race conditions + livelocks + deadlocks * less verbose output * fixes data race, by isolating critical sections * minor refactoring: resolves blocking calls * implements init-sync queue * udpate fetch/send buffers in blocks fetcher * blockState enum-like type alias * refactors common code into releaseTicket() * better gc * linter * minor fix to round robin * moves original round robin into its own package * adds enableInitSyncQueue flag * fixes issue with init-sync service selection * Update beacon-chain/sync/initial-sync/round_robin.go Co-Authored-By: terence tsao <terence@prysmaticlabs.com> * initsyncv1 -> initsyncold * adds span Co-authored-by: prylabs-bulldozer[bot] <58059840+prylabs-bulldozer[bot]@users.noreply.github.com> Co-authored-by: Raul Jordan <raul@prysmaticlabs.com> Co-authored-by: terence tsao <terence@prysmaticlabs.com> |
||
|---|---|---|
| .. | ||
| initial-sync | ||
| initial-sync-old | ||
| BUILD.bazel | ||
| deadlines.go | ||
| decode_pubsub.go | ||
| doc.go | ||
| error_test.go | ||
| error.go | ||
| log.go | ||
| metrics.go | ||
| pending_attestations_queue_test.go | ||
| pending_attestations_queue.go | ||
| pending_blocks_queue_test.go | ||
| pending_blocks_queue.go | ||
| rpc_beacon_blocks_by_range_test.go | ||
| rpc_beacon_blocks_by_range.go | ||
| rpc_beacon_blocks_by_root_test.go | ||
| rpc_beacon_blocks_by_root.go | ||
| rpc_chunked_response.go | ||
| rpc_goodbye_test.go | ||
| rpc_goodbye.go | ||
| rpc_status_test.go | ||
| rpc_status.go | ||
| rpc_test.go | ||
| rpc.go | ||
| service.go | ||
| subscriber_beacon_aggregate_proof_test.go | ||
| subscriber_beacon_aggregate_proof.go | ||
| subscriber_beacon_blocks_test.go | ||
| subscriber_beacon_blocks.go | ||
| subscriber_committee_index_beacon_attestation_test.go | ||
| subscriber_committee_index_beacon_attestation.go | ||
| subscriber_handlers.go | ||
| subscriber_test.go | ||
| subscriber.go | ||
| validate_aggregate_proof_test.go | ||
| validate_aggregate_proof.go | ||
| validate_attester_slashing_test.go | ||
| validate_attester_slashing.go | ||
| validate_beacon_blocks_test.go | ||
| validate_beacon_blocks.go | ||
| validate_committee_index_beacon_attestation_test.go | ||
| validate_committee_index_beacon_attestation.go | ||
| validate_proposer_slashing_test.go | ||
| validate_proposer_slashing.go | ||
| validate_voluntary_exit_test.go | ||
| validate_voluntary_exit.go | ||