init sync: adds blocks fetcher service (#4978)

* init sync: adds blocks fetcher service * init-sync: rework ctx handling * init-sync: fix long lines * removes redundant method * adds buffer to requests channel * adds jaeger spans * fixes overly long comment line
prysmaticlabs · Mar 4, 2020 · 239efe7 · 239efe7
1 parent e5da756
commit 239efe7
Show file tree

Hide file tree

Showing 3 changed files with 1,064 additions and 1 deletion.
diff --git a/beacon-chain/sync/initial-sync/BUILD.bazel b/beacon-chain/sync/initial-sync/BUILD.bazel
@@ -3,6 +3,7 @@ load("@io_bazel_rules_go//go:def.bzl", "go_library", "go_test")
 go_library(
     name = "go_default_library",
     srcs = [
+        "blocks_fetcher.go",
         "log.go",
         "round_robin.go",
         "service.go",
@@ -32,18 +33,23 @@ go_library(
         "@com_github_pkg_errors//:go_default_library",
         "@com_github_prysmaticlabs_ethereumapis//eth/v1alpha1:go_default_library",
         "@com_github_sirupsen_logrus//:go_default_library",
+        "@io_opencensus_go//trace:go_default_library",
     ],
 )
 
 go_test(
     name = "go_default_test",
-    srcs = ["round_robin_test.go"],
+    srcs = [
+        "blocks_fetcher_test.go",
+        "round_robin_test.go",
+    ],
     embed = [":go_default_library"],
     race = "on",
     tags = ["race_on"],
     deps = [
         "//beacon-chain/blockchain/testing:go_default_library",
         "//beacon-chain/core/helpers:go_default_library",
+        "//beacon-chain/db:go_default_library",
         "//beacon-chain/db/testing:go_default_library",
         "//beacon-chain/p2p/peers:go_default_library",
         "//beacon-chain/p2p/testing:go_default_library",
@@ -54,10 +60,13 @@ go_test(
         "//shared/params:go_default_library",
         "//shared/roughtime:go_default_library",
         "//shared/sliceutil:go_default_library",
+        "//shared/testutil:go_default_library",
         "@com_github_kevinms_leakybucket_go//:go_default_library",
         "@com_github_libp2p_go_libp2p_core//network:go_default_library",
+        "@com_github_libp2p_go_libp2p_core//peer:go_default_library",
         "@com_github_prysmaticlabs_ethereumapis//eth/v1alpha1:go_default_library",
         "@com_github_prysmaticlabs_go_ssz//:go_default_library",
         "@com_github_sirupsen_logrus//:go_default_library",
+        "@com_github_sirupsen_logrus//hooks/test:go_default_library",
     ],
 )