Bring in refactored p2p sentry interface and adjust downloader for it (#1497)
* Initial commit * Add sentry gRPC interface * p2psentry directory * Update README.md * Update README.md * Update README.md * Add go package * Correct syntax * add external downloader interface (#2) * Add txpool (#3) * Add private API (#4) * Invert control.proto, add PeerMinBlock, Separare incoming Tx message into a separate stream (#5) Co-authored-by:Alexey Sharp <alexeysharp@Alexeys-iMac.local> * Use new p2psentry interface * Remove * Fix lint * Fix lint * Separate upload messages into its own stream (#6) Co-authored-by:
Alexey Sharp <alexeysharp@Alexeys-iMac.local> * Add header upload * Remove * Add upload of block headers * Add block bodies upload * Fix lint * Bugfix for blockBodies * Fix for body upload logging * Print peerId for GetBlockHeaders * Invoke block hashes stage to enable block body upload * Fix test * Fix stuck bodies download Co-authored-by:
Artem Vorotnikov <artem@vorotnikov.me> Co-authored-by:
b00ris <b00ris@mail.ru> Co-authored-by:
Alexey Sharp <alexeysharp@Alexeys-iMac.local>
Showing
- Makefile 2 additions, 2 deletionsMakefile
- cmd/headers/core/control.pb.go 0 additions, 416 deletionscmd/headers/core/control.pb.go
- cmd/headers/core/control_grpc.pb.go 0 additions, 134 deletionscmd/headers/core/control_grpc.pb.go
- cmd/headers/download/downloader.go 388 additions, 130 deletionscmd/headers/download/downloader.go
- cmd/headers/download/grpc-direct.go 49 additions, 12 deletionscmd/headers/download/grpc-direct.go
- cmd/headers/download/sentry.go 166 additions, 218 deletionscmd/headers/download/sentry.go
- cmd/headers/main.go 0 additions, 1 deletioncmd/headers/main.go
- cmd/headers/sentry/sentry.pb.go 475 additions, 102 deletionscmd/headers/sentry/sentry.pb.go
- cmd/headers/sentry/sentry_grpc.pb.go 263 additions, 1 deletioncmd/headers/sentry/sentry_grpc.pb.go
- eth/stagedsync/stage_blockhashes.go 12 additions, 7 deletionseth/stagedsync/stage_blockhashes.go
- eth/stagedsync/stage_blockhashes_test.go 11 additions, 4 deletionseth/stagedsync/stage_blockhashes_test.go
- interfaces/p2psentry/control.proto 0 additions, 35 deletionsinterfaces/p2psentry/control.proto
- interfaces/p2psentry/sentry.proto 33 additions, 3 deletionsinterfaces/p2psentry/sentry.proto
- turbo/stages/bodydownload/body_algos.go 3 additions, 0 deletionsturbo/stages/bodydownload/body_algos.go
- turbo/stages/bodydownload/forward.go 7 additions, 4 deletionsturbo/stages/bodydownload/forward.go
- turbo/stages/headerdownload/forward.go 1 addition, 0 deletionsturbo/stages/headerdownload/forward.go
- turbo/stages/stageloop.go 21 additions, 3 deletionsturbo/stages/stageloop.go
Loading
Please register or sign in to comment