diff --git a/src/header/mod.rs b/src/header/mod.rs index 40fa0718..49a25dd8 100644 --- a/src/header/mod.rs +++ b/src/header/mod.rs @@ -356,11 +356,21 @@ mod tests { use test::Bencher; + // Slice.position_elem is unstable + fn index_of(slice: &[u8], byte: u8) -> Option { + for (index, &b) in slice.iter().enumerate() { + if b == byte { + return Some(index); + } + } + None + } + macro_rules! raw { ($($line:expr),*) => ({ [$({ let line = $line; - let pos = line.position_elem(&b':').expect("raw splits on :, not found"); + let pos = index_of(line, b':').expect("raw splits on ':', not found"); httparse::Header { name: ::std::str::from_utf8(&line[..pos]).unwrap(), value: &line[pos + 2..] diff --git a/src/header/shared/entity.rs b/src/header/shared/entity.rs index 18b05ce9..5d193f56 100644 --- a/src/header/shared/entity.rs +++ b/src/header/shared/entity.rs @@ -47,29 +47,29 @@ impl FromStr for EntityTag { // Early exits: // 1. The string is empty, or, // 2. it doesn't terminate in a DQUOTE. - if slice.is_empty() || !slice.ends_with("\"") { + if slice.is_empty() || !slice.ends_with('"') { return Err(()); } // The etag is weak if its first char is not a DQUOTE. - if slice.chars().next().unwrap() == '"' /* '"' */ { + if slice.starts_with('"') /* '"' */ { // No need to check if the last char is a DQUOTE, // we already did that above. - if check_slice_validity(slice.slice_chars(1, length-1)) { + if check_slice_validity(&slice[1..length-1]) { return Ok(EntityTag { weak: false, - tag: slice.slice_chars(1, length-1).to_string() + tag: slice[1..length-1].to_string() }); } else { return Err(()); } } - if slice.slice_chars(0, 3) == "W/\"" { - if check_slice_validity(slice.slice_chars(3, length-1)) { + if slice.starts_with("W/\"") { + if check_slice_validity(&slice[3..length-1]) { return Ok(EntityTag { weak: true, - tag: slice.slice_chars(3, length-1).to_string() + tag: slice[3..length-1].to_string() }); } else { return Err(()); diff --git a/src/lib.rs b/src/lib.rs index 076b3682..9325539d 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -1,5 +1,5 @@ #![doc(html_root_url = "https://hyperium.github.io/hyper/hyper/index.html")] -#![feature(core, collections, io, +#![feature(core, io, box_syntax, unsafe_destructor, into_cow, convert)] #![deny(missing_docs)] #![cfg_attr(test, deny(warnings))] diff --git a/src/server/listener.rs b/src/server/listener.rs index 86e64a19..a2e0714c 100644 --- a/src/server/listener.rs +++ b/src/server/listener.rs @@ -1,6 +1,5 @@ use std::thread::{self, JoinGuard}; use std::sync::mpsc; -use std::collections::VecMap; use net::NetworkListener; pub struct ListenerPool { @@ -24,22 +23,16 @@ impl<'a, A: NetworkListener + Send + 'a> ListenerPool { let (super_tx, supervisor_rx) = mpsc::channel(); - let counter = &mut 0; let work = &work; - let mut spawn = move || { - let id = *counter; - let guard = spawn_with(super_tx.clone(), work, self.acceptor.clone(), id); - *counter += 1; - (id, guard) + let spawn = move |id| { + spawn_with(super_tx.clone(), work, self.acceptor.clone(), id) }; // Go - let mut guards: VecMap<_> = (0..threads).map(|_| spawn()).collect(); + let mut guards: Vec<_> = (0..threads).map(|id| spawn(id)).collect(); for id in supervisor_rx.iter() { - guards.remove(&id); - let (id, guard) = spawn(); - guards.insert(id, guard); + guards[id] = spawn(id); } } }