From 8ada835f81a85f0d3c01686d654a45c9717446ad Mon Sep 17 00:00:00 2001 From: Joe Ardent Date: Wed, 5 Jun 2024 22:12:51 -0700 Subject: [PATCH] update nebkor-maelstrom dep --- Cargo.lock | 4 ++-- gg-broadcast/src/main.rs | 9 ++------- 2 files changed, 4 insertions(+), 9 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index e411b96..da8e96b 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -67,9 +67,9 @@ checksum = "97b3888a4aecf77e811145cadf6eef5901f4782c53886191b2f693f24761847c" [[package]] name = "nebkor-maelstrom" -version = "0.0.1" +version = "0.0.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "83dd99cc42f1882a9a269091b25a3afb88f6237ed56bc255659e49aaf9e89fc3" +checksum = "aae3eeab09bcb4f923122da7b5962b2f02fcbd7201baf45c679a6c6a258fdb11" dependencies = [ "serde", "serde_json", diff --git a/gg-broadcast/src/main.rs b/gg-broadcast/src/main.rs index f76f493..a39332a 100644 --- a/gg-broadcast/src/main.rs +++ b/gg-broadcast/src/main.rs @@ -90,9 +90,6 @@ impl BCaster { impl Node for BCaster { fn handle(&mut self, runner: &Runner, req: Message) { let typ = req.body.typ.as_str(); - let frm = req.src.as_str(); - let nid = runner.node_id(); - let nid = nid.as_str(); match typ { "do_gossip" => { @@ -116,6 +113,7 @@ impl Node for BCaster { runner.reply(&req, body); } "topology" => { + let nid = runner.node_id(); self.topology(runner.nodes(), nid); let body = Body::from_type("topology_ok"); runner.reply(&req, body); @@ -133,10 +131,7 @@ impl Node for BCaster { .collect::>(); self.store.extend(goss.clone()); - self.gossips - .entry(frm.to_string()) - .or_default() - .extend(goss); + self.gossips.entry(req.src).or_default().extend(goss); } _ => {