Merge pull request #120 from stepchowfun/1.0.8

Release v1.0.8

Author: stepchowfun

Diff for: CHANGELOG.md

@@ -5,6 +5,11 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [1.0.8] - 2023-07-01
+
+### Changed
+- RPC retry delays have been reduced, and the sleep between Paxos rounds has been removed entirely.
+
 ## [1.0.7] - 2023-07-01
 
 ### Changed

Diff for: Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "paxos"
-version = "1.0.7"
+version = "1.0.8"
 authors = ["Stephan Boyer <[email protected]>"]
 edition = "2021"
 description = "An implementation of single-decree Paxos."

Diff for: Cargo.toml

@@ -8,15 +8,10 @@ use {
         state::{self, ProposalNumber},
     },
     hyper::Client,
-    rand::{thread_rng, Rng},
-    std::{io, net::SocketAddr, path::Path, sync::Arc, time::Duration},
-    tokio::{sync::RwLock, time::sleep},
+    std::{io, net::SocketAddr, path::Path, sync::Arc},
+    tokio::sync::RwLock,
 };
 
-// Duration constants
-const RESTART_DELAY_MIN: Duration = Duration::from_millis(0);
-const RESTART_DELAY_MAX: Duration = Duration::from_millis(100);
-
 // Generate a new proposal number.
 fn generate_proposal_number(
     nodes: &[SocketAddr],
@@ -138,7 +133,6 @@ pub async fn propose(
 
         // The protocol failed. Sleep for a random duration before starting over.
         debug!("Failed to reach consensus. Starting over.");
-        sleep(thread_rng().gen_range(RESTART_DELAY_MIN..RESTART_DELAY_MAX)).await;
     }
 
     Ok(())

Diff for: src/proposer.rs

@@ -7,8 +7,8 @@ use {
 };
 
 // Duration constants
-const EXPONENTIAL_BACKOFF_MIN: Duration = Duration::from_millis(100);
-const EXPONENTIAL_BACKOFF_MAX: Duration = Duration::from_secs(2);
+const EXPONENTIAL_BACKOFF_MIN: Duration = Duration::from_millis(50);
+const EXPONENTIAL_BACKOFF_MAX: Duration = Duration::from_secs(1);
 const EXPONENTIAL_BACKOFF_MULTIPLIER: u32 = 2;
 
 // Send a request without retries.