Multi-client Scripts

Makefile

@@ -0,0 +1,8 @@
+build:
+	cargo build --release
+
+run_multiple:
+	./run.sh
+
+clean:
+	./stop.sh

run.sh

@@ -0,0 +1,9 @@
+#!/bin/bash
+> pids.txt
+
+cargo build --release
+for i in {1..50}
+do
+	./target/release/snarkos --connect_to_beacon 95.217.56.71:4130 --dev $((i)) --rest_port 
+$((i + 11000)) --node 0.0.0.0:$((i+10000)) & echo "$!" >> pids.txt
+done

snarkos/cli.rs

@@ -51,6 +51,10 @@ pub struct CLI {
     #[clap(long = "connect")]
     pub connect: Option<String>,
 
+    /// Specify the rest API port for the node server.
+    #[clap(long = "rest_port")]
+    pub rest_port: Option<u16>,
+
     /// Specify the IP address and port for the RPC server.
     #[clap(default_value = "0.0.0.0:3033", long = "rpc")]
     pub rpc: SocketAddr,

snarkos/ledger/mod.rs

@@ -54,7 +54,7 @@ pub struct Ledger<N: Network> {
 
 impl<N: Network> Ledger<N> {
     /// Initializes a new instance of the ledger.
-    pub(super) fn new_with_genesis(private_key: PrivateKey<N>, genesis_block: Block<N>, dev: Option<u16>) -> Result<Arc<Self>> {
+    pub(super) fn new_with_genesis(private_key: PrivateKey<N>, genesis_block: Block<N>, dev: Option<u16>, custom_port: Option<u16>) -> Result<Arc<Self>> {
         // Initialize the ledger.
         let ledger = match InternalLedger::new_with_genesis(&genesis_block, genesis_block.signature().to_address(), dev) {
             Ok(ledger) => Arc::new(RwLock::new(ledger)),
@@ -70,19 +70,19 @@ impl<N: Network> Ledger<N> {
         };
 
         // Return the ledger.
-        Self::from(ledger, private_key)
+        Self::from(ledger, private_key, custom_port)
     }
 
     /// Opens an instance of the ledger.
-    pub fn load(private_key: PrivateKey<N>, dev: Option<u16>) -> Result<Arc<Self>> {
+    pub fn load(private_key: PrivateKey<N>, dev: Option<u16>, custom_port: Option<u16>) -> Result<Arc<Self>> {
         // Initialize the ledger.
         let ledger = Arc::new(RwLock::new(InternalLedger::open(dev)?));
         // Return the ledger.
-        Self::from(ledger, private_key)
+        Self::from(ledger, private_key, custom_port)
     }
 
     /// Initializes a new instance of the ledger.
-    pub fn from(ledger: Arc<RwLock<InternalLedger<N>>>, private_key: PrivateKey<N>) -> Result<Arc<Self>> {
+    pub fn from(ledger: Arc<RwLock<InternalLedger<N>>>, private_key: PrivateKey<N>, custom_port: Option<u16>) -> Result<Arc<Self>> {
         // Derive the view key and address.
         let view_key = ViewKey::try_from(private_key)?;
         let address = Address::try_from(&view_key)?;
@@ -125,7 +125,7 @@ impl<N: Network> Ledger<N> {
         };
 
         // Initialize the server.
-        let server = InternalServer::<N>::start(ledger.clone(), Some(additional_routes), None)?;
+        let server = InternalServer::<N>::start(ledger.clone(), Some(additional_routes), custom_port)?;
 
         // Return the ledger.
         Ok(Arc::new(Self {

snarkos/node.rs

@@ -39,7 +39,7 @@ impl<N: Network, E: Environment> Node<N, E> {
         let ledger = match cli.dev {
             None => {
                 // Initialize the ledger.
-                let ledger = Ledger::<N>::load(*account.private_key(), cli.dev)?;
+                let ledger = Ledger::<N>::load(*account.private_key(), cli.dev, cli.rest_port)?;
                 // Sync the ledger with the network.
                 ledger.initial_sync_with_network(cli.beacon_addr.ip()).await?;
 
@@ -52,7 +52,7 @@ impl<N: Network, E: Environment> Node<N, E> {
                 let genesis_block = request_genesis_block::<N>(cli.beacon_addr.ip()).await?;
 
                 // Initialize the ledger from the provided genesis block.
-                Ledger::<N>::new_with_genesis(*account.private_key(), genesis_block, cli.dev)?
+                Ledger::<N>::new_with_genesis(*account.private_key(), genesis_block, cli.dev, cli.rest_port)?
             }
         };
 

stop.sh

@@ -0,0 +1,4 @@
+#!/bin/bash
+
+pkill -f snarkos
+rm -rf .ledger-3-*