[INFO] fetching crate almost-raft 0.3.0... [INFO] testing almost-raft-0.3.0 against 1.55.0 for beta-1.56-1 [INFO] extracting crate almost-raft 0.3.0 into /workspace/builds/worker-108/source [INFO] validating manifest of crates.io crate almost-raft 0.3.0 on toolchain 1.55.0 [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+1.55.0" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] started tweaking crates.io crate almost-raft 0.3.0 [INFO] finished tweaking crates.io crate almost-raft 0.3.0 [INFO] tweaked toml for crates.io crate almost-raft 0.3.0 written to /workspace/builds/worker-108/source/Cargo.toml [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+1.55.0" "generate-lockfile" "--manifest-path" "Cargo.toml" "-Zno-index-update", kill_on_drop: false }` [INFO] [stderr] Blocking waiting for file lock on package cache [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+1.55.0" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Blocking waiting for file lock on package cache [INFO] [stderr] Blocking waiting for file lock on package cache [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-108/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-108/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:a89201d6b5b9fd45c15d5952ece0a0129e7e80cb26ec023fd59cf09bc26f1604" "/opt/rustwide/cargo-home/bin/cargo" "+1.55.0" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 5ae62f98e99aacd4beca130e085c5d0810dbade080b44033df1953b0a13f336e [INFO] running `Command { std: "docker" "start" "-a" "5ae62f98e99aacd4beca130e085c5d0810dbade080b44033df1953b0a13f336e", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "5ae62f98e99aacd4beca130e085c5d0810dbade080b44033df1953b0a13f336e", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "5ae62f98e99aacd4beca130e085c5d0810dbade080b44033df1953b0a13f336e", kill_on_drop: false }` [INFO] [stdout] 5ae62f98e99aacd4beca130e085c5d0810dbade080b44033df1953b0a13f336e [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-108/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-108/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:a89201d6b5b9fd45c15d5952ece0a0129e7e80cb26ec023fd59cf09bc26f1604" "/opt/rustwide/cargo-home/bin/cargo" "+1.55.0" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 352e2012a5e5090dc257e7b2aa396b0dfca1394bde4529577c124a2eea597ff2 [INFO] running `Command { std: "docker" "start" "-a" "352e2012a5e5090dc257e7b2aa396b0dfca1394bde4529577c124a2eea597ff2", kill_on_drop: false }` [INFO] [stderr] Compiling proc-macro2 v1.0.29 [INFO] [stderr] Compiling syn v1.0.76 [INFO] [stderr] Compiling futures-core v0.3.17 [INFO] [stderr] Compiling proc-macro-nested v0.1.7 [INFO] [stderr] Compiling futures-task v0.3.17 [INFO] [stderr] Compiling pin-project-lite v0.2.7 [INFO] [stderr] Compiling async-trait v0.1.51 [INFO] [stderr] Compiling tokio v1.11.0 [INFO] [stderr] Compiling futures-macro v0.3.17 [INFO] [stderr] Compiling futures-util v0.3.17 [INFO] [stderr] Compiling serde_derive v1.0.130 [INFO] [stderr] Compiling serde v1.0.130 [INFO] [stderr] Compiling log v0.4.14 [INFO] [stderr] Compiling getrandom v0.2.3 [INFO] [stderr] Compiling rand_core v0.6.3 [INFO] [stderr] Compiling rand_chacha v0.3.1 [INFO] [stderr] Compiling rand v0.8.4 [INFO] [stderr] Compiling quote v1.0.9 [INFO] [stderr] Compiling tokio-macros v1.3.0 [INFO] [stderr] Compiling tokio-stream v0.1.7 [INFO] [stderr] Compiling almost-raft v0.3.0 (/opt/rustwide/workdir) [INFO] [stderr] Finished dev [unoptimized + debuginfo] target(s) in 33.50s [INFO] running `Command { std: "docker" "inspect" "352e2012a5e5090dc257e7b2aa396b0dfca1394bde4529577c124a2eea597ff2", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "352e2012a5e5090dc257e7b2aa396b0dfca1394bde4529577c124a2eea597ff2", kill_on_drop: false }` [INFO] [stdout] 352e2012a5e5090dc257e7b2aa396b0dfca1394bde4529577c124a2eea597ff2 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-108/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-108/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:a89201d6b5b9fd45c15d5952ece0a0129e7e80cb26ec023fd59cf09bc26f1604" "/opt/rustwide/cargo-home/bin/cargo" "+1.55.0" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] f74932be9ad5e7f1da5437b249a4bc14f6c50cc143442a3f59699a9b9e38c239 [INFO] running `Command { std: "docker" "start" "-a" "f74932be9ad5e7f1da5437b249a4bc14f6c50cc143442a3f59699a9b9e38c239", kill_on_drop: false }` [INFO] [stderr] Compiling regex-syntax v0.6.25 [INFO] [stderr] Compiling serde_json v1.0.67 [INFO] [stderr] Compiling once_cell v1.8.0 [INFO] [stderr] Compiling smallvec v1.6.1 [INFO] [stderr] Compiling ansi_term v0.12.1 [INFO] [stderr] Compiling num-traits v0.2.14 [INFO] [stderr] Compiling num-integer v0.1.44 [INFO] [stderr] Compiling tracing-core v0.1.19 [INFO] [stderr] Compiling sharded-slab v0.1.3 [INFO] [stderr] Compiling uuid v0.8.2 [INFO] [stderr] Compiling thread_local v1.1.3 [INFO] [stderr] Compiling tracing-serde v0.1.2 [INFO] [stderr] Compiling tracing-log v0.1.2 [INFO] [stderr] Compiling tracing v0.1.26 [INFO] [stderr] Compiling chrono v0.4.19 [INFO] [stderr] Compiling regex-automata v0.1.10 [INFO] [stderr] Compiling regex v1.5.4 [INFO] [stderr] Compiling matchers v0.0.1 [INFO] [stderr] Compiling tracing-subscriber v0.2.20 [INFO] [stderr] Compiling almost-raft v0.3.0 (/opt/rustwide/workdir) [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:530:13 [INFO] [stdout] | [INFO] [stdout] 530 | self.sender.send(msg).await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_must_use)]` on by default [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:566:9 [INFO] [stdout] | [INFO] [stdout] 566 | tx.send(Message::ControlAddNode(dummy)).await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:568:9 [INFO] [stdout] | [INFO] [stdout] 568 | tx.send(Message::ControlAddNode(dummy)).await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:578:9 [INFO] [stdout] | [INFO] [stdout] 578 | tx.send(Message::ControlAddNode(dummy)).await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:631:9 [INFO] [stdout] | [INFO] [stdout] 631 | / tx_to_raft [INFO] [stdout] 632 | | .send(Message::RequestVoteResponse { [INFO] [stdout] 633 | | vote: true, [INFO] [stdout] 634 | | term: 1, [INFO] [stdout] 635 | | }) [INFO] [stdout] 636 | | .await; [INFO] [stdout] | |___________________^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:637:9 [INFO] [stdout] | [INFO] [stdout] 637 | / tx_to_raft [INFO] [stdout] 638 | | .send(Message::RequestVoteResponse { [INFO] [stdout] 639 | | vote: true, [INFO] [stdout] 640 | | term: 1, [INFO] [stdout] 641 | | }) [INFO] [stdout] 642 | | .await; [INFO] [stdout] | |___________________^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:643:9 [INFO] [stdout] | [INFO] [stdout] 643 | / tx_to_raft [INFO] [stdout] 644 | | .send(Message::RequestVoteResponse { [INFO] [stdout] 645 | | vote: true, [INFO] [stdout] 646 | | term: 1, [INFO] [stdout] 647 | | }) [INFO] [stdout] 648 | | .await; [INFO] [stdout] | |___________________^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:701:9 [INFO] [stdout] | [INFO] [stdout] 701 | / tx_to_raft [INFO] [stdout] 702 | | .send(Message::RequestVoteResponse { [INFO] [stdout] 703 | | vote: true, [INFO] [stdout] 704 | | term: 1, [INFO] [stdout] 705 | | }) [INFO] [stdout] 706 | | .await; [INFO] [stdout] | |___________________^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:730:13 [INFO] [stdout] | [INFO] [stdout] 730 | / tx_to_raft [INFO] [stdout] 731 | | .send(Message::RequestVoteResponse { [INFO] [stdout] 732 | | vote: true, [INFO] [stdout] 733 | | term: 2, [INFO] [stdout] 734 | | }) [INFO] [stdout] 735 | | .await; [INFO] [stdout] | |_______________________^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:791:9 [INFO] [stdout] | [INFO] [stdout] 791 | / tx_to_raft_node_1 [INFO] [stdout] 792 | | .send(Message::ControlAddNode(new_node( [INFO] [stdout] 793 | | self_id_2.as_str(), [INFO] [stdout] 794 | | tx_to_raft_node_2.clone(), [INFO] [stdout] 795 | | ))) [INFO] [stdout] 796 | | .await; [INFO] [stdout] | |___________________^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:797:9 [INFO] [stdout] | [INFO] [stdout] 797 | / tx_to_raft_node_1 [INFO] [stdout] 798 | | .send(Message::ControlAddNode(new_node( [INFO] [stdout] 799 | | self_id_3.as_str(), [INFO] [stdout] 800 | | tx_to_raft_node_3.clone(), [INFO] [stdout] 801 | | ))) [INFO] [stdout] 802 | | .await; [INFO] [stdout] | |___________________^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:804:9 [INFO] [stdout] | [INFO] [stdout] 804 | / tx_to_raft_node_2 [INFO] [stdout] 805 | | .send(Message::ControlAddNode(new_node( [INFO] [stdout] 806 | | self_id_1.as_str(), [INFO] [stdout] 807 | | tx_to_raft_node_1.clone(), [INFO] [stdout] 808 | | ))) [INFO] [stdout] 809 | | .await; [INFO] [stdout] | |___________________^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:810:9 [INFO] [stdout] | [INFO] [stdout] 810 | / tx_to_raft_node_2 [INFO] [stdout] 811 | | .send(Message::ControlAddNode(new_node( [INFO] [stdout] 812 | | self_id_3.as_str(), [INFO] [stdout] 813 | | tx_to_raft_node_3.clone(), [INFO] [stdout] 814 | | ))) [INFO] [stdout] 815 | | .await; [INFO] [stdout] | |___________________^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:816:9 [INFO] [stdout] | [INFO] [stdout] 816 | / tx_to_raft_node_3 [INFO] [stdout] 817 | | .send(Message::ControlAddNode(new_node( [INFO] [stdout] 818 | | self_id_1.as_str(), [INFO] [stdout] 819 | | tx_to_raft_node_1.clone(), [INFO] [stdout] 820 | | ))) [INFO] [stdout] 821 | | .await; [INFO] [stdout] | |___________________^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` that must be used [INFO] [stdout] --> src/election/mod.rs:822:9 [INFO] [stdout] | [INFO] [stdout] 822 | / tx_to_raft_node_3 [INFO] [stdout] 823 | | .send(Message::ControlAddNode(new_node( [INFO] [stdout] 824 | | self_id_2.as_str(), [INFO] [stdout] 825 | | tx_to_raft_node_2.clone(), [INFO] [stdout] 826 | | ))) [INFO] [stdout] 827 | | .await; [INFO] [stdout] | |___________________^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: 15 warnings emitted [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Finished test [unoptimized + debuginfo] target(s) in 15.82s [INFO] running `Command { std: "docker" "inspect" "f74932be9ad5e7f1da5437b249a4bc14f6c50cc143442a3f59699a9b9e38c239", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "f74932be9ad5e7f1da5437b249a4bc14f6c50cc143442a3f59699a9b9e38c239", kill_on_drop: false }` [INFO] [stdout] f74932be9ad5e7f1da5437b249a4bc14f6c50cc143442a3f59699a9b9e38c239 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-108/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-108/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:a89201d6b5b9fd45c15d5952ece0a0129e7e80cb26ec023fd59cf09bc26f1604" "/opt/rustwide/cargo-home/bin/cargo" "+1.55.0" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] 128ebad54f5e4d57a129c1ca79e23a69f89f46a349b169964c8229bc404116cc [INFO] running `Command { std: "docker" "start" "-a" "128ebad54f5e4d57a129c1ca79e23a69f89f46a349b169964c8229bc404116cc", kill_on_drop: false }` [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:530:13 [INFO] [stderr] | [INFO] [stderr] 530 | self.sender.send(msg).await; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_must_use)]` on by default [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:566:9 [INFO] [stderr] | [INFO] [stderr] 566 | tx.send(Message::ControlAddNode(dummy)).await; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:568:9 [INFO] [stderr] | [INFO] [stderr] 568 | tx.send(Message::ControlAddNode(dummy)).await; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:578:9 [INFO] [stderr] | [INFO] [stderr] 578 | tx.send(Message::ControlAddNode(dummy)).await; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:631:9 [INFO] [stderr] | [INFO] [stderr] 631 | / tx_to_raft [INFO] [stderr] 632 | | .send(Message::RequestVoteResponse { [INFO] [stderr] 633 | | vote: true, [INFO] [stderr] 634 | | term: 1, [INFO] [stderr] 635 | | }) [INFO] [stderr] 636 | | .await; [INFO] [stderr] | |___________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:637:9 [INFO] [stderr] | [INFO] [stderr] 637 | / tx_to_raft [INFO] [stderr] 638 | | .send(Message::RequestVoteResponse { [INFO] [stderr] 639 | | vote: true, [INFO] [stderr] 640 | | term: 1, [INFO] [stderr] 641 | | }) [INFO] [stderr] 642 | | .await; [INFO] [stderr] | |___________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:643:9 [INFO] [stderr] | [INFO] [stderr] 643 | / tx_to_raft [INFO] [stderr] 644 | | .send(Message::RequestVoteResponse { [INFO] [stderr] 645 | | vote: true, [INFO] [stderr] 646 | | term: 1, [INFO] [stderr] 647 | | }) [INFO] [stderr] 648 | | .await; [INFO] [stderr] | |___________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:701:9 [INFO] [stderr] | [INFO] [stderr] 701 | / tx_to_raft [INFO] [stderr] 702 | | .send(Message::RequestVoteResponse { [INFO] [stderr] 703 | | vote: true, [INFO] [stderr] 704 | | term: 1, [INFO] [stderr] 705 | | }) [INFO] [stderr] 706 | | .await; [INFO] [stderr] | |___________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:730:13 [INFO] [stderr] | [INFO] [stderr] 730 | / tx_to_raft [INFO] [stderr] 731 | | .send(Message::RequestVoteResponse { [INFO] [stderr] 732 | | vote: true, [INFO] [stderr] 733 | | term: 2, [INFO] [stderr] 734 | | }) [INFO] [stderr] 735 | | .await; [INFO] [stderr] | |_______________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:791:9 [INFO] [stderr] | [INFO] [stderr] 791 | / tx_to_raft_node_1 [INFO] [stderr] 792 | | .send(Message::ControlAddNode(new_node( [INFO] [stderr] 793 | | self_id_2.as_str(), [INFO] [stderr] 794 | | tx_to_raft_node_2.clone(), [INFO] [stderr] 795 | | ))) [INFO] [stderr] 796 | | .await; [INFO] [stderr] | |___________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:797:9 [INFO] [stderr] | [INFO] [stderr] 797 | / tx_to_raft_node_1 [INFO] [stderr] 798 | | .send(Message::ControlAddNode(new_node( [INFO] [stderr] 799 | | self_id_3.as_str(), [INFO] [stderr] 800 | | tx_to_raft_node_3.clone(), [INFO] [stderr] 801 | | ))) [INFO] [stderr] 802 | | .await; [INFO] [stderr] | |___________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:804:9 [INFO] [stderr] | [INFO] [stderr] 804 | / tx_to_raft_node_2 [INFO] [stderr] 805 | | .send(Message::ControlAddNode(new_node( [INFO] [stderr] 806 | | self_id_1.as_str(), [INFO] [stderr] 807 | | tx_to_raft_node_1.clone(), [INFO] [stderr] 808 | | ))) [INFO] [stderr] 809 | | .await; [INFO] [stderr] | |___________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:810:9 [INFO] [stderr] | [INFO] [stderr] 810 | / tx_to_raft_node_2 [INFO] [stderr] 811 | | .send(Message::ControlAddNode(new_node( [INFO] [stderr] 812 | | self_id_3.as_str(), [INFO] [stderr] 813 | | tx_to_raft_node_3.clone(), [INFO] [stderr] 814 | | ))) [INFO] [stderr] 815 | | .await; [INFO] [stderr] | |___________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:816:9 [INFO] [stderr] | [INFO] [stderr] 816 | / tx_to_raft_node_3 [INFO] [stderr] 817 | | .send(Message::ControlAddNode(new_node( [INFO] [stderr] 818 | | self_id_1.as_str(), [INFO] [stderr] 819 | | tx_to_raft_node_1.clone(), [INFO] [stderr] 820 | | ))) [INFO] [stderr] 821 | | .await; [INFO] [stderr] | |___________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: unused `Result` that must be used [INFO] [stderr] --> src/election/mod.rs:822:9 [INFO] [stderr] | [INFO] [stderr] 822 | / tx_to_raft_node_3 [INFO] [stderr] 823 | | .send(Message::ControlAddNode(new_node( [INFO] [stderr] 824 | | self_id_2.as_str(), [INFO] [stderr] 825 | | tx_to_raft_node_2.clone(), [INFO] [stderr] 826 | | ))) [INFO] [stderr] 827 | | .await; [INFO] [stderr] | |___________________^ [INFO] [stderr] | [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: `almost-raft` (lib test) generated 15 warnings [INFO] [stderr] Finished test [unoptimized + debuginfo] target(s) in 0.13s [INFO] [stderr] Running unittests (/opt/rustwide/target/debug/deps/almost_raft-f6f152d6252a0484) [INFO] [stdout] [INFO] [stdout] running 4 tests [INFO] [stdout] Sep 10 18:25:14.622  INFO almost_raft::election: [node: raft-node-1] starting election process... [INFO] [stdout] Sep 10 18:25:14.623 TRACE almost_raft::election: [node: raft-node-1] setting new timeout to 60 [INFO] [stdout] Sep 10 18:25:14.623 TRACE almost_raft::election: [node: raft-node-1] got message Some(ControlAddNode(NodeDummy { id: "raft-node-2", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7584004790, tail_position: 2 }, semaphore: (Semaphore { permits: 8 }, 10), rx_waker: AtomicWaker, tx_count: 4, rx_fields: "..." } } } })) [INFO] [stdout] Sep 10 18:25:14.623 TRACE almost_raft::election: [node: raft-node-1] remaining_election_timeout: 60, remaining_heartbeat_interval: 20 [INFO] [stdout] Sep 10 18:25:14.623 TRACE almost_raft::election: [node: raft-node-1] setting new timeout to 60 [INFO] [stdout] Sep 10 18:25:14.623 TRACE almost_raft::election: [node: raft-node-1] got message Some(ControlAddNode(NodeDummy { id: "raft-node-3", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7584005520, tail_position: 2 }, semaphore: (Semaphore { permits: 8 }, 10), rx_waker: AtomicWaker, tx_count: 4, rx_fields: "..." } } } })) [INFO] [stdout] Sep 10 18:25:14.623 TRACE almost_raft::election: [node: raft-node-1] remaining_election_timeout: 60, remaining_heartbeat_interval: 20 [INFO] [stdout] Sep 10 18:25:14.623 TRACE almost_raft::election: [node: raft-node-1] setting new timeout to 60 [INFO] [stdout] Sep 10 18:25:14.623  INFO almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] starting election process... [INFO] [stdout] Sep 10 18:25:14.623  INFO almost_raft::election: [node: raft-node-2] starting election process... [INFO] [stdout] Sep 10 18:25:14.623 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] setting new timeout to 7432 [INFO] [stdout] Sep 10 18:25:14.623 TRACE almost_raft::election: [node: raft-node-2] setting new timeout to 70 [INFO] [stdout] Sep 10 18:25:14.623 TRACE almost_raft::election: [node: raft-node-2] got message Some(ControlAddNode(NodeDummy { id: "raft-node-1", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7584003a00, tail_position: 2 }, semaphore: (Semaphore { permits: 10 }, 10), rx_waker: AtomicWaker, tx_count: 4, rx_fields: "..." } } } })) [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: raft-node-2] remaining_election_timeout: 70, remaining_heartbeat_interval: 20 [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: raft-node-2] setting new timeout to 70 [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: raft-node-2] got message Some(ControlAddNode(NodeDummy { id: "raft-node-3", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7584005520, tail_position: 2 }, semaphore: (Semaphore { permits: 8 }, 10), rx_waker: AtomicWaker, tx_count: 4, rx_fields: "..." } } } })) [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: raft-node-2] remaining_election_timeout: 70, remaining_heartbeat_interval: 20 [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: raft-node-2] setting new timeout to 70 [INFO] [stdout] Sep 10 18:25:14.624  INFO almost_raft::election: [node: raft-node-3] starting election process... [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: raft-node-3] setting new timeout to 80 [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: raft-node-3] got message Some(ControlAddNode(NodeDummy { id: "raft-node-1", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7584003a00, tail_position: 2 }, semaphore: (Semaphore { permits: 10 }, 10), rx_waker: AtomicWaker, tx_count: 4, rx_fields: "..." } } } })) [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: raft-node-3] remaining_election_timeout: 80, remaining_heartbeat_interval: 20 [INFO] [stdout] Sep 10 18:25:14.622 TRACE almost_raft::election::test: 8622 [INFO] [stdout] Sep 10 18:25:14.622  INFO almost_raft::election: [node: raft-node] starting election process... [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: raft-node-3] setting new timeout to 80 [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: raft-node] setting new timeout to 6844 [INFO] [stdout] Sep 10 18:25:14.624  INFO almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] starting election process... [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: raft-node-3] got message Some(ControlAddNode(NodeDummy { id: "raft-node-2", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7584004790, tail_position: 2 }, semaphore: (Semaphore { permits: 10 }, 10), rx_waker: AtomicWaker, tx_count: 4, rx_fields: "..." } } } })) [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] setting new timeout to 8622 [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: raft-node-3] remaining_election_timeout: 80, remaining_heartbeat_interval: 20 [INFO] [stdout] Sep 10 18:25:14.624 TRACE almost_raft::election: [node: raft-node-3] setting new timeout to 80 [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] got message Some(ControlAddNode(NodeDummy { id: "1", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7588005490, tail_position: 0 }, semaphore: (Semaphore { permits: 10 }, 10), rx_waker: AtomicWaker, tx_count: 3, rx_fields: "..." } } } })) [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] remaining_election_timeout: 0, remaining_heartbeat_interval: 1000 [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] setting new timeout to 0 [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] got message Some(ControlAddNode(NodeDummy { id: "2", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7588005490, tail_position: 0 }, semaphore: (Semaphore { permits: 10 }, 10), rx_waker: AtomicWaker, tx_count: 3, rx_fields: "..." } } } })) [INFO] [stdout] Sep 10 18:25:14.625 DEBUG almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] updating node state to NodeState::Candidate [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] remaining_election_timeout: 0, remaining_heartbeat_interval: 1000 [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] setting new timeout to 0 [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] updating term from 0 to 1 [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] not enough node [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] sending vote request for term 1 to: NodeDummy { id: "1", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7580003360, tail_position: 0 }, semaphore: (Semaphore { permits: 10 }, 10), rx_waker: AtomicWaker, tx_count: 5, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] remaining_election_timeout: 8622, remaining_heartbeat_interval: 1000 [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] setting new timeout to 8622 [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election::test: [node: 1] sending message RequestVote { node_id: "7cb01aa2-41e7-4c68-934a-6fb452aff6f6", term: 1 } [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] sending vote request for term 1 to: NodeDummy { id: "2", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7580003360, tail_position: 1 }, semaphore: (Semaphore { permits: 9 }, 10), rx_waker: AtomicWaker, tx_count: 5, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.625 TRACE almost_raft::election::test: [node: 2] sending message RequestVote { node_id: "7cb01aa2-41e7-4c68-934a-6fb452aff6f6", term: 1 } [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] sending vote request for term 1 to: NodeDummy { id: "3", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7580003360, tail_position: 2 }, semaphore: (Semaphore { permits: 8 }, 10), rx_waker: AtomicWaker, tx_count: 5, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.626 DEBUG almost_raft::election: [node: raft-node] updating node state to NodeState::Candidate [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election::test: [node: 3] sending message RequestVote { node_id: "7cb01aa2-41e7-4c68-934a-6fb452aff6f6", term: 1 } [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election: [node: raft-node] updating term from 0 to 1 [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] sending vote request for term 1 to: NodeDummy { id: "3", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7580003360, tail_position: 3 }, semaphore: (Semaphore { permits: 7 }, 10), rx_waker: AtomicWaker, tx_count: 5, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election: [node: raft-node] sending vote request for term 1 to: NodeDummy { id: "1", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7578003360, tail_position: 0 }, semaphore: (Semaphore { permits: 10 }, 10), rx_waker: AtomicWaker, tx_count: 5, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election::test: [node: 1] sending message RequestVote { node_id: "raft-node", term: 1 } [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election::test: [node: 3] sending message RequestVote { node_id: "7cb01aa2-41e7-4c68-934a-6fb452aff6f6", term: 1 } [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election: [node: raft-node] sending vote request for term 1 to: NodeDummy { id: "2", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7578003360, tail_position: 1 }, semaphore: (Semaphore { permits: 9 }, 10), rx_waker: AtomicWaker, tx_count: 5, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] remaining_election_timeout: 7432, remaining_heartbeat_interval: 1000 [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election::test: [node: 2] sending message RequestVote { node_id: "raft-node", term: 1 } [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election: [node: raft-node] sending vote request for term 1 to: NodeDummy { id: "3", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7578003360, tail_position: 2 }, semaphore: (Semaphore { permits: 8 }, 10), rx_waker: AtomicWaker, tx_count: 5, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] setting new timeout to 7432 [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election::test: [node: 3] sending message RequestVote { node_id: "raft-node", term: 1 } [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election: [node: raft-node] sending vote request for term 1 to: NodeDummy { id: "4", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7578003360, tail_position: 3 }, semaphore: (Semaphore { permits: 7 }, 10), rx_waker: AtomicWaker, tx_count: 5, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election::test: Some(RequestVote { node_id: "7cb01aa2-41e7-4c68-934a-6fb452aff6f6", term: 1 }) [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election::test: [node: 4] sending message RequestVote { node_id: "raft-node", term: 1 } [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election::test: Some(RequestVote { node_id: "7cb01aa2-41e7-4c68-934a-6fb452aff6f6", term: 1 }) [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election: [node: raft-node] remaining_election_timeout: 6844, remaining_heartbeat_interval: 1000 [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election: [node: raft-node] setting new timeout to 6844 [INFO] [stdout] Sep 10 18:25:14.626 TRACE almost_raft::election::test: Some(RequestVote { node_id: "7cb01aa2-41e7-4c68-934a-6fb452aff6f6", term: 1 }) [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election::test: Some(RequestVote { node_id: "7cb01aa2-41e7-4c68-934a-6fb452aff6f6", term: 1 }) [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election: [node: raft-node] got message Some(RequestVoteResponse { term: 1, vote: true }) [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election: [node: raft-node] remaining_election_timeout: 6844, remaining_heartbeat_interval: 1000 [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] got message Some(RequestVoteResponse { term: 1, vote: true }) [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election: [node: raft-node] setting new timeout to 6844 [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] remaining_election_timeout: 7432, remaining_heartbeat_interval: 1000 [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] setting new timeout to 7432 [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] got message Some(RequestVoteResponse { term: 1, vote: true }) [INFO] [stdout] Sep 10 18:25:14.627 DEBUG almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] updating node state to NodeState::Leader [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election::test: [node: 1] sending message HeartBeat { leader_node_id: "7cb01aa2-41e7-4c68-934a-6fb452aff6f6", term: 1 } [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] sent heartbeat [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election::test: [node: 2] sending message HeartBeat { leader_node_id: "7cb01aa2-41e7-4c68-934a-6fb452aff6f6", term: 1 } [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] sent heartbeat [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election::test: [node: 3] sending message HeartBeat { leader_node_id: "7cb01aa2-41e7-4c68-934a-6fb452aff6f6", term: 1 } [INFO] [stdout] Sep 10 18:25:14.627 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] sent heartbeat [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election::test: [node: 3] sending message HeartBeat { leader_node_id: "7cb01aa2-41e7-4c68-934a-6fb452aff6f6", term: 1 } [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] sent heartbeat [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] remaining_election_timeout: 7432, remaining_heartbeat_interval: 1000 [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] setting new timeout to 1000 [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] got message Some(RequestVoteResponse { term: 1, vote: true }) [INFO] [stdout] Sep 10 18:25:14.628 DEBUG almost_raft::election: [node: raft-node] updating node state to NodeState::Candidate [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] remaining_election_timeout: 7432, remaining_heartbeat_interval: 7432 [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election: [node: raft-node] updating term from 1 to 2 [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election: [node: 7cb01aa2-41e7-4c68-934a-6fb452aff6f6] setting new timeout to 7432 [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election: [node: raft-node] sending vote request for term 2 to: NodeDummy { id: "1", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7578003360, tail_position: 4 }, semaphore: (Semaphore { permits: 10 }, 10), rx_waker: AtomicWaker, tx_count: 5, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election::test: [node: 1] sending message RequestVote { node_id: "raft-node", term: 2 } [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election: [node: raft-node] sending vote request for term 2 to: NodeDummy { id: "2", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7578003360, tail_position: 5 }, semaphore: (Semaphore { permits: 9 }, 10), rx_waker: AtomicWaker, tx_count: 5, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election::test: [node: 2] sending message RequestVote { node_id: "raft-node", term: 2 } [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election: [node: raft-node] sending vote request for term 2 to: NodeDummy { id: "3", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7578003360, tail_position: 6 }, semaphore: (Semaphore { permits: 8 }, 10), rx_waker: AtomicWaker, tx_count: 5, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election::test: [node: 3] sending message RequestVote { node_id: "raft-node", term: 2 } [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election: [node: raft-node] sending vote request for term 2 to: NodeDummy { id: "4", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7578003360, tail_position: 7 }, semaphore: (Semaphore { permits: 7 }, 10), rx_waker: AtomicWaker, tx_count: 5, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.628 TRACE almost_raft::election::test: [node: 4] sending message RequestVote { node_id: "raft-node", term: 2 } [INFO] [stdout] Sep 10 18:25:14.629 TRACE almost_raft::election: [node: raft-node] remaining_election_timeout: 6844, remaining_heartbeat_interval: 1000 [INFO] [stdout] Sep 10 18:25:14.629 TRACE almost_raft::election: [node: raft-node] setting new timeout to 6844 [INFO] [stdout] Sep 10 18:25:14.629 TRACE almost_raft::election::test: multi-term: RequestVote { node_id: "raft-node", term: 2 } [INFO] [stdout] Sep 10 18:25:14.629 TRACE almost_raft::election::test: Some(RequestVote { node_id: "raft-node", term: 2 }) [INFO] [stdout] Sep 10 18:25:14.629 TRACE almost_raft::election::test: Some(RequestVote { node_id: "raft-node", term: 2 }) [INFO] [stdout] Sep 10 18:25:14.629 TRACE almost_raft::election::test: Some(RequestVote { node_id: "raft-node", term: 2 }) [INFO] [stdout] Sep 10 18:25:14.629 TRACE almost_raft::election: [node: raft-node] got message Some(RequestVoteResponse { term: 2, vote: true }) [INFO] [stdout] Sep 10 18:25:14.629 TRACE almost_raft::election: [node: raft-node] remaining_election_timeout: 6844, remaining_heartbeat_interval: 1000 [INFO] [stdout] Sep 10 18:25:14.629 TRACE almost_raft::election: [node: raft-node] setting new timeout to 6844 [INFO] [stdout] Sep 10 18:25:14.629 TRACE almost_raft::election: [node: raft-node] got message Some(RequestVoteResponse { term: 2, vote: true }) [INFO] [stdout] Sep 10 18:25:14.629 DEBUG almost_raft::election: [node: raft-node] updating node state to NodeState::Leader [INFO] [stdout] Sep 10 18:25:14.629 TRACE almost_raft::election::test: [node: 1] sending message HeartBeat { leader_node_id: "raft-node", term: 2 } [INFO] [stdout] Sep 10 18:25:14.629 TRACE almost_raft::election: [node: raft-node] sent heartbeat [INFO] [stdout] Sep 10 18:25:14.629 TRACE almost_raft::election::test: [node: 2] sending message HeartBeat { leader_node_id: "raft-node", term: 2 } [INFO] [stdout] Sep 10 18:25:14.630 TRACE almost_raft::election: [node: raft-node] sent heartbeat [INFO] [stdout] Sep 10 18:25:14.630 TRACE almost_raft::election::test: [node: 3] sending message HeartBeat { leader_node_id: "raft-node", term: 2 } [INFO] [stdout] Sep 10 18:25:14.630 TRACE almost_raft::election: [node: raft-node] sent heartbeat [INFO] [stdout] Sep 10 18:25:14.630 TRACE almost_raft::election::test: [node: 4] sending message HeartBeat { leader_node_id: "raft-node", term: 2 } [INFO] [stdout] Sep 10 18:25:14.630 TRACE almost_raft::election: [node: raft-node] sent heartbeat [INFO] [stdout] Sep 10 18:25:14.630 TRACE almost_raft::election: [node: raft-node] remaining_election_timeout: 6844, remaining_heartbeat_interval: 1000 [INFO] [stdout] Sep 10 18:25:14.630 TRACE almost_raft::election: [node: raft-node] setting new timeout to 1000 [INFO] [stdout] test election::test::test_raft_election_multi_term ... ok [INFO] [stdout] test election::test::test_raft_election ... ok [INFO] [stdout] Sep 10 18:25:14.634 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] got message Some(ControlAddNode(NodeDummy { id: "3", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7588005490, tail_position: 0 }, semaphore: (Semaphore { permits: 10 }, 10), rx_waker: AtomicWaker, tx_count: 4, rx_fields: "..." } } } })) [INFO] [stdout] Sep 10 18:25:14.635 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] remaining_election_timeout: 8614, remaining_heartbeat_interval: 1000 [INFO] [stdout] Sep 10 18:25:14.635 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] setting new timeout to 8614 [INFO] [stdout] Sep 10 18:25:14.635 DEBUG almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] updating node state to NodeState::Candidate [INFO] [stdout] Sep 10 18:25:14.635 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] updating term from 0 to 1 [INFO] [stdout] Sep 10 18:25:14.635 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] sending vote request for term 1 to: NodeDummy { id: "1", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7588005490, tail_position: 0 }, semaphore: (Semaphore { permits: 10 }, 10), rx_waker: AtomicWaker, tx_count: 4, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.635 TRACE almost_raft::election::test: [node: 1] sending message RequestVote { node_id: "737418e5-95a4-4023-a705-3cf4d67b7db2", term: 1 } [INFO] [stdout] Sep 10 18:25:14.635 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] sending vote request for term 1 to: NodeDummy { id: "2", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7588005490, tail_position: 1 }, semaphore: (Semaphore { permits: 9 }, 10), rx_waker: AtomicWaker, tx_count: 4, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.635 TRACE almost_raft::election::test: [node: 2] sending message RequestVote { node_id: "737418e5-95a4-4023-a705-3cf4d67b7db2", term: 1 } [INFO] [stdout] Sep 10 18:25:14.635 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] sending vote request for term 1 to: NodeDummy { id: "3", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7588005490, tail_position: 2 }, semaphore: (Semaphore { permits: 8 }, 10), rx_waker: AtomicWaker, tx_count: 4, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.635 TRACE almost_raft::election::test: [node: 3] sending message RequestVote { node_id: "737418e5-95a4-4023-a705-3cf4d67b7db2", term: 1 } [INFO] [stdout] Sep 10 18:25:14.635 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] remaining_election_timeout: 8622, remaining_heartbeat_interval: 1000 [INFO] [stdout] Sep 10 18:25:14.635 TRACE almost_raft::election: [node: 737418e5-95a4-4023-a705-3cf4d67b7db2] setting new timeout to 8622 [INFO] [stdout] Sep 10 18:25:14.635 TRACE almost_raft::election::test: Ok(Some(RequestVote { node_id: "737418e5-95a4-4023-a705-3cf4d67b7db2", term: 1 })) [INFO] [stdout] test election::test::test_min_node ... ok [INFO] [stdout] Sep 10 18:25:14.685 DEBUG almost_raft::election: [node: raft-node-1] updating node state to NodeState::Candidate [INFO] [stdout] Sep 10 18:25:14.685 TRACE almost_raft::election: [node: raft-node-1] updating term from 0 to 1 [INFO] [stdout] Sep 10 18:25:14.685 TRACE almost_raft::election: [node: raft-node-1] sending vote request for term 1 to: NodeDummy { id: "raft-node-2", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7584004790, tail_position: 2 }, semaphore: (Semaphore { permits: 10 }, 10), rx_waker: AtomicWaker, tx_count: 4, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.685 TRACE almost_raft::election::test: [node: raft-node-2] sending message RequestVote { node_id: "raft-node-1", term: 1 } [INFO] [stdout] Sep 10 18:25:14.686 TRACE almost_raft::election: [node: raft-node-1] sending vote request for term 1 to: NodeDummy { id: "raft-node-3", sender: Sender { chan: Tx { inner: Chan { tx: Tx { block_tail: 0x7f7584005520, tail_position: 2 }, semaphore: (Semaphore { permits: 10 }, 10), rx_waker: AtomicWaker, tx_count: 4, rx_fields: "..." } } } } [INFO] [stdout] Sep 10 18:25:14.686 TRACE almost_raft::election::test: [node: raft-node-3] sending message RequestVote { node_id: "raft-node-1", term: 1 } [INFO] [stdout] Sep 10 18:25:14.686 TRACE almost_raft::election: [node: raft-node-1] remaining_election_timeout: 60, remaining_heartbeat_interval: 20 [INFO] [stdout] Sep 10 18:25:14.686 TRACE almost_raft::election: [node: raft-node-1] setting new timeout to 60 [INFO] [stdout] Sep 10 18:25:14.686 TRACE almost_raft::election: [node: raft-node-2] got message Some(RequestVote { node_id: "raft-node-1", term: 1 }) [INFO] [stdout] Sep 10 18:25:14.686 TRACE almost_raft::election: [node: raft-node-2] updating term from 0 to 1 [INFO] [stdout] Sep 10 18:25:14.686 TRACE almost_raft::election: [node: raft-node-2] current term: 1, sending vote to node: raft-node-1, for term: 1 [INFO] [stdout] Sep 10 18:25:14.686 TRACE almost_raft::election::test: [node: raft-node-1] sending message RequestVoteResponse { term: 1, vote: true } [INFO] [stdout] Sep 10 18:25:14.686 TRACE almost_raft::election: [node: raft-node-2] remaining_election_timeout: 8, remaining_heartbeat_interval: 20 [INFO] [stdout] Sep 10 18:25:14.687 TRACE almost_raft::election: [node: raft-node-2] setting new timeout to 8 [INFO] [stdout] Sep 10 18:25:14.687 TRACE almost_raft::election: [node: raft-node-3] got message Some(RequestVote { node_id: "raft-node-1", term: 1 }) [INFO] [stdout] Sep 10 18:25:14.687 TRACE almost_raft::election: [node: raft-node-3] updating term from 0 to 1 [INFO] [stdout] Sep 10 18:25:14.687 TRACE almost_raft::election: [node: raft-node-3] current term: 1, sending vote to node: raft-node-1, for term: 1 [INFO] [stdout] Sep 10 18:25:14.687 TRACE almost_raft::election::test: [node: raft-node-1] sending message RequestVoteResponse { term: 1, vote: true } [INFO] [stdout] Sep 10 18:25:14.687 TRACE almost_raft::election: [node: raft-node-3] remaining_election_timeout: 18, remaining_heartbeat_interval: 20 [INFO] [stdout] Sep 10 18:25:14.687 TRACE almost_raft::election: [node: raft-node-3] setting new timeout to 18 [INFO] [stdout] Sep 10 18:25:14.687 TRACE almost_raft::election: [node: raft-node-1] got message Some(RequestVoteResponse { term: 1, vote: true }) [INFO] [stdout] Sep 10 18:25:14.687 DEBUG almost_raft::election: [node: raft-node-1] updating node state to NodeState::Leader [INFO] [stdout] Sep 10 18:25:14.687 TRACE almost_raft::election::test: [node: raft-node-2] sending message HeartBeat { leader_node_id: "raft-node-1", term: 1 } [INFO] [stdout] Sep 10 18:25:14.688 TRACE almost_raft::election: [node: raft-node-1] sent heartbeat [INFO] [stdout] Sep 10 18:25:14.688 TRACE almost_raft::election::test: [node: raft-node-3] sending message HeartBeat { leader_node_id: "raft-node-1", term: 1 } [INFO] [stdout] Sep 10 18:25:14.688 TRACE almost_raft::election: [node: raft-node-1] sent heartbeat [INFO] [stdout] Sep 10 18:25:14.688 TRACE almost_raft::election: [node: raft-node-1] remaining_election_timeout: 59, remaining_heartbeat_interval: 20 [INFO] [stdout] Sep 10 18:25:14.688 TRACE almost_raft::election: [node: raft-node-1] setting new timeout to 20 [INFO] [stdout] Sep 10 18:25:14.688 TRACE almost_raft::election: [node: raft-node-1] got message Some(RequestVoteResponse { term: 1, vote: true }) [INFO] [stdout] Sep 10 18:25:14.688 TRACE almost_raft::election: [node: raft-node-1] remaining_election_timeout: 59, remaining_heartbeat_interval: 59 [INFO] [stdout] Sep 10 18:25:14.688 TRACE almost_raft::election: [node: raft-node-1] setting new timeout to 59 [INFO] [stdout] Sep 10 18:25:14.688 TRACE almost_raft::election: [node: raft-node-2] got message Some(HeartBeat { leader_node_id: "raft-node-1", term: 1 }) [INFO] [stdout] Sep 10 18:25:14.688 TRACE almost_raft::election: [node: raft-node-2] updating term to 1 [INFO] [stdout] Sep 10 18:25:14.688 DEBUG almost_raft::election: [node: raft-node-2] leader changed to node: raft-node-1 [INFO] [stdout] Sep 10 18:25:14.688 TRACE almost_raft::election: [node: raft-node-2] remaining_election_timeout: 70, remaining_heartbeat_interval: 20 [INFO] [stdout] Sep 10 18:25:14.689 TRACE almost_raft::election: [node: raft-node-2] setting new timeout to 70 [INFO] [stdout] Sep 10 18:25:14.689 TRACE almost_raft::election: [node: raft-node-3] got message Some(HeartBeat { leader_node_id: "raft-node-1", term: 1 }) [INFO] [stdout] Sep 10 18:25:14.689 TRACE almost_raft::election: [node: raft-node-3] updating term to 1 [INFO] [stdout] Sep 10 18:25:14.689 DEBUG almost_raft::election: [node: raft-node-3] leader changed to node: raft-node-1 [INFO] [stdout] Sep 10 18:25:14.689 TRACE almost_raft::election: [node: raft-node-3] remaining_election_timeout: 80, remaining_heartbeat_interval: 20 [INFO] [stdout] Sep 10 18:25:14.689 TRACE almost_raft::election: [node: raft-node-3] setting new timeout to 80 [INFO] [stdout] Sep 10 18:25:14.708 TRACE almost_raft::election::test: ControlLeaderChanged("raft-node-1") [INFO] [stdout] test election::test::test_raft_election_multi_node ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.12s [INFO] [stdout] [INFO] [stderr] Doc-tests almost-raft [INFO] [stdout] [INFO] [stdout] running 5 tests [INFO] [stdout] test src/lib.rs - (line 21) ... ignored [INFO] [stdout] test src/lib.rs - (line 43) ... ignored [INFO] [stdout] test src/lib.rs - (line 66) ... ignored [INFO] [stdout] test src/lib.rs - (line 72) ... ignored [INFO] [stdout] test src/lib.rs - (line 85) ... ignored [INFO] [stdout] [INFO] [stdout] test result: ok. 0 passed; 0 failed; 5 ignored; 0 measured; 0 filtered out; finished in 0.00s [INFO] [stdout] [INFO] running `Command { std: "docker" "inspect" "128ebad54f5e4d57a129c1ca79e23a69f89f46a349b169964c8229bc404116cc", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "128ebad54f5e4d57a129c1ca79e23a69f89f46a349b169964c8229bc404116cc", kill_on_drop: false }` [INFO] [stdout] 128ebad54f5e4d57a129c1ca79e23a69f89f46a349b169964c8229bc404116cc