summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorStuart Stock <stuart@int08h.com>2017-07-06 08:26:10 -0500
committerStuart Stock <stuart@int08h.com>2017-07-06 08:26:10 -0500
commit824a9ca7130d359014a35b5b180f6b72298f2f7b (patch)
tree1a5106f7a454fe830b827592556476e26d77ab83
parentab92db34774b89146012121ce584a59924562b76 (diff)
downloadroughenough-824a9ca7130d359014a35b5b180f6b72298f2f7b.zip
rustfmt
-rw-r--r--src/bin/server.rs30
1 files changed, 14 insertions, 16 deletions
diff --git a/src/bin/server.rs b/src/bin/server.rs
index 187a86a..03e8b54 100644
--- a/src/bin/server.rs
+++ b/src/bin/server.rs
@@ -9,9 +9,9 @@ extern crate roughenough;
extern crate time;
extern crate untrusted;
extern crate fern;
+extern crate ctrlc;
#[macro_use]
extern crate log;
-extern crate ctrlc;
use std::io;
use std::net::UdpSocket;
@@ -157,16 +157,15 @@ fn nonce_from_request(buf: &[u8], num_bytes: usize) -> Result<&[u8], Error> {
}
fn init_logging() {
- fern::Dispatch::new()
- .format(|out, message, record| {
- out.finish(format_args!("{} [{}] {}",
- time::now().asctime(),
- record.level(),
- message))
+ fern::Dispatch::new()
+ .format(|out, message, record| {
+ out.finish(
+ format_args!("{} [{}] {}", time::now().asctime(), record.level(), message)
+ )
})
- .level(log::LogLevelFilter::Info)
- .chain(std::io::stdout())
- .apply()
+ .level(log::LogLevelFilter::Info)
+ .chain(std::io::stdout())
+ .apply()
.unwrap();
}
@@ -203,9 +202,8 @@ fn main() {
let keep_running = Arc::new(AtomicBool::new(true));
let kr = keep_running.clone();
- ctrlc::set_handler(move || {
- kr.store(false, Ordering::Release);
- }).expect("failed setting Ctrl-C handler");
+ ctrlc::set_handler(move || { kr.store(false, Ordering::Release); })
+ .expect("failed setting Ctrl-C handler");
loop {
if !keep_running.load(Ordering::Acquire) {
@@ -229,13 +227,13 @@ fn main() {
info!("invalid request ({} bytes) from {}", num_bytes, src_addr);
bad_requests += 1;
}
- },
- Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => {
+ }
+ Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => {
loops += 1;
if loops % 600 == 0 {
info!("responses {}, invalid requests {}", responses, bad_requests);
}
- },
+ }
Err(ref e) => error!("Error {:?}: {:?}", e.kind(), e),
}
}