Refactor RPC subscriptions account handling (#9888) (#9912)

automerge
2020-05-07 01:14:58 -07:00
parent 9a5fc3513a
commit 558324b861
10 changed files with 464 additions and 277 deletions
--- a/core/src/validator.rs
+++ b/core/src/validator.rs
@@ -241,7 +241,11 @@ impl Validator {
            BlockCommitmentCache::default_with_blockstore(blockstore.clone()),
        ));

-        let subscriptions = Arc::new(RpcSubscriptions::new(&exit, block_commitment_cache.clone()));
+        let subscriptions = Arc::new(RpcSubscriptions::new(
+            &exit,
+            bank_forks.clone(),
+            block_commitment_cache.clone(),
+        ));

        let rpc_service = config.rpc_ports.map(|(rpc_port, rpc_pubsub_port)| {
            if ContactInfo::is_valid_address(&node.info.rpc) {