diff --git a/src/bin/client-demo.rs b/src/bin/client-demo.rs index e193c1d794..bc2a87da71 100755 --- a/src/bin/client-demo.rs +++ b/src/bin/client-demo.rs @@ -9,7 +9,7 @@ use bincode::serialize; use clap::{App, Arg}; use rayon::prelude::*; use solana::crdt::{Crdt, NodeInfo}; -use solana::drone::DroneRequest; +use solana::drone::{DroneRequest, DRONE_PORT}; use solana::fullnode::Config; use solana::hash::Hash; use solana::nat::{udp_public_bind, udp_random_bind}; @@ -220,7 +220,7 @@ fn main() { } let mut drone_addr = leader.contact_info.tpu; - drone_addr.set_port(9900); + drone_addr.set_port(DRONE_PORT); let signal = Arc::new(AtomicBool::new(false)); let mut c_threads = vec![]; diff --git a/src/bin/drone.rs b/src/bin/drone.rs index 21c140bf10..92cc289bf1 100644 --- a/src/bin/drone.rs +++ b/src/bin/drone.rs @@ -10,7 +10,7 @@ extern crate tokio_io; use bincode::deserialize; use clap::{App, Arg}; use solana::crdt::NodeInfo; -use solana::drone::{Drone, DroneRequest}; +use solana::drone::{Drone, DroneRequest, DRONE_PORT}; use solana::fullnode::Config; use solana::metrics::set_panic_hook; use solana::signature::read_keypair; @@ -85,7 +85,7 @@ fn main() { request_cap = None; } - let drone_addr: SocketAddr = "0.0.0.0:9900".parse().unwrap(); + let drone_addr: SocketAddr = format!("0.0.0.0:{}", DRONE_PORT).parse().unwrap(); let drone = Arc::new(Mutex::new(Drone::new( mint_keypair, diff --git a/src/bin/wallet.rs b/src/bin/wallet.rs index 7e1266fa5f..1c3c0c2e0a 100644 --- a/src/bin/wallet.rs +++ b/src/bin/wallet.rs @@ -10,7 +10,7 @@ extern crate solana; use bincode::serialize; use clap::{App, Arg, SubCommand}; use solana::crdt::NodeInfo; -use solana::drone::DroneRequest; +use solana::drone::{DroneRequest, DRONE_PORT}; use solana::fullnode::Config; use solana::signature::{read_keypair, KeyPair, KeyPairUtil, PublicKey, Signature}; use solana::thin_client::ThinClient; @@ -164,7 +164,7 @@ fn parse_args() -> Result> { })?; let mut drone_addr = leader.contact_info.tpu; - drone_addr.set_port(9900); + drone_addr.set_port(DRONE_PORT); let command = match matches.subcommand() { ("airdrop", Some(airdrop_matches)) => { diff --git a/src/drone.rs b/src/drone.rs index 6f4fcc67f0..d7a166c922 100644 --- a/src/drone.rs +++ b/src/drone.rs @@ -16,6 +16,7 @@ use transaction::Transaction; pub const TIME_SLICE: u64 = 60; pub const REQUEST_CAP: u64 = 1_000_000; +pub const DRONE_PORT: u16 = 9900; #[derive(Serialize, Deserialize, Debug, Clone, Copy)] pub enum DroneRequest {