Replicator now uses its keypair for gossip
This commit is contained in:
parent
8f034280dc
commit
07a948a0d0
|
@ -110,7 +110,7 @@ impl Replicator {
|
||||||
ledger_path: &str,
|
ledger_path: &str,
|
||||||
node: Node,
|
node: Node,
|
||||||
leader_info: &NodeInfo,
|
leader_info: &NodeInfo,
|
||||||
keypair: &Keypair,
|
keypair: &Arc<Keypair>,
|
||||||
timeout: Option<Duration>,
|
timeout: Option<Duration>,
|
||||||
) -> Result<Self> {
|
) -> Result<Self> {
|
||||||
let exit = Arc::new(AtomicBool::new(false));
|
let exit = Arc::new(AtomicBool::new(false));
|
||||||
|
@ -212,7 +212,7 @@ impl Replicator {
|
||||||
|
|
||||||
let mut client = mk_client(&leader);
|
let mut client = mk_client(&leader);
|
||||||
|
|
||||||
Self::get_airdrop_lamports(&mut client, keypair, &leader_info);
|
Self::get_airdrop_lamports(&mut client, &keypair, &leader_info);
|
||||||
info!("Done downloading ledger at {}", ledger_path);
|
info!("Done downloading ledger at {}", ledger_path);
|
||||||
|
|
||||||
let ledger_path = Path::new(ledger_path);
|
let ledger_path = Path::new(ledger_path);
|
||||||
|
|
|
@ -81,7 +81,8 @@ fn main() {
|
||||||
|
|
||||||
let leader_info = NodeInfo::new_entry_point(&network_addr);
|
let leader_info = NodeInfo::new_entry_point(&network_addr);
|
||||||
|
|
||||||
let replicator = Replicator::new(ledger_path, node, &leader_info, &keypair, None).unwrap();
|
let replicator =
|
||||||
|
Replicator::new(ledger_path, node, &leader_info, &Arc::new(keypair), None).unwrap();
|
||||||
|
|
||||||
replicator.join();
|
replicator.join();
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue