From 8e5bccaf919153dafe473ef65058b3d51004f9e9 Mon Sep 17 00:00:00 2001 From: Sean Bowe Date: Sun, 25 Sep 2016 17:28:25 -0600 Subject: [PATCH] Minor changes/improvements. --- src/consts.rs | 1 + src/coordinator.rs | 1 - src/network.rs | 25 +++++++++++-------------- src/verifier.rs | 4 +++- 4 files changed, 15 insertions(+), 16 deletions(-) diff --git a/src/consts.rs b/src/consts.rs index c2767be..84ab8ce 100644 --- a/src/consts.rs +++ b/src/consts.rs @@ -1 +1,2 @@ pub const NETWORK_MAGIC: [u8; 8] = [0xee, 0xee, 0x1f, 0xcc, 0x1c, 0xee, 0xcc, 0x19]; +pub const USE_DUMMY_CS: bool = true; diff --git a/src/coordinator.rs b/src/coordinator.rs index 667422a..b8a60d0 100644 --- a/src/coordinator.rs +++ b/src/coordinator.rs @@ -34,7 +34,6 @@ use bincode::SizeLimit::Infinite; use bincode::rustc_serialize::{encode_into, decode_from}; use std::time::Duration; -const USE_DUMMY_CS: bool = true; const LISTEN_ADDR: &'static str = "0.0.0.0:65530"; const PLAYERS: usize = 3; pub const THREADS: usize = 8; diff --git a/src/network.rs b/src/network.rs index a87a58e..17b9abd 100644 --- a/src/network.rs +++ b/src/network.rs @@ -13,14 +13,11 @@ use self::consts::*; mod dvd; use self::dvd::*; -use bn::*; -use rand::{SeedableRng, Rng}; -use std::io::{Read, Write, self}; +use rand::Rng; +use std::io::Read; use std::net::{TcpStream}; use std::thread; use std::time::Duration; -use std::fs::{self, File}; -use std::process::Command; use bincode::SizeLimit::Infinite; use bincode::rustc_serialize::{encode_into, decode_from}; use rustc_serialize::{Decodable, Encodable}; @@ -49,11 +46,11 @@ impl ConnectionHandler { } fn handshake(&mut self) { - self.s.set_read_timeout(Some(Duration::from_secs(60))); - self.s.set_write_timeout(Some(Duration::from_secs(60))); - self.s.write(&NETWORK_MAGIC); - self.s.write(&self.peerid); - self.s.flush(); + let _ = self.s.set_read_timeout(Some(Duration::from_secs(60))); + let _ = self.s.set_write_timeout(Some(Duration::from_secs(60))); + let _ = self.s.write(&NETWORK_MAGIC); + let _ = self.s.write(&self.peerid); + let _ = self.s.flush(); } fn do_with_stream Result>(&mut self, cb: F) -> T @@ -106,7 +103,7 @@ impl ConnectionHandler { } fn main() { - let mut comm; + let comm; { let mut entered_wrong = false; loop { @@ -127,7 +124,7 @@ fn main() { handler.write(&comm); println!("Waiting to receive disc 'A' from coordinator server..."); - let mut stage1_before = handler.read::(); + let stage1_before = handler.read::(); let (pubkey, stage1_after): (PublicKey, Stage1Contents) = exchange_disc( "A", @@ -151,7 +148,7 @@ fn main() { drop(stage1_after); println!("Waiting to receive disc 'C' from coordinator server..."); - let mut stage2_before = handler.read::(); + let stage2_before = handler.read::(); let stage2_after: Stage2Contents = exchange_disc( "C", @@ -171,7 +168,7 @@ fn main() { drop(stage2_after); println!("Waiting to receive disc 'E' from coordinator server..."); - let mut stage3_before = handler.read::(); + let stage3_before = handler.read::(); let stage3_after: Stage3Contents = exchange_disc( "E", diff --git a/src/verifier.rs b/src/verifier.rs index a432f30..531eec8 100644 --- a/src/verifier.rs +++ b/src/verifier.rs @@ -9,6 +9,9 @@ extern crate byteorder; mod protocol; +mod consts; +use self::consts::*; + use std::fs::File; use std::io::{Read, Write}; use protocol::*; @@ -17,7 +20,6 @@ use snark::*; use bincode::SizeLimit::Infinite; use bincode::rustc_serialize::{encode_into, decode_from}; -const USE_DUMMY_CS: bool = true; pub const THREADS: usize = 8; fn main() {