use std::fmt::Debug; use std::collections::HashMap; use test::Bencher; use rustc_serialize::{Decoder, Decodable}; use serde; use serde::de::{Deserializer, Deserialize}; ////////////////////////////////////////////////////////////////////////////// #[derive(PartialEq, Debug)] pub enum Error { EndOfStream, SyntaxError, MissingField, } impl serde::de::Error for Error { fn syntax_error() -> Error { Error::SyntaxError } fn end_of_stream_error() -> Error { Error::EndOfStream } fn unknown_field_error(_: &str) -> Error { Error::SyntaxError } fn missing_field_error(_: &'static str) -> Error { Error::MissingField } } ////////////////////////////////////////////////////////////////////////////// mod decoder { use std::collections::HashMap; use std::collections::hash_map::IntoIter; use rustc_serialize; use super::Error; use self::Value::{StringValue, IsizeValue}; enum Value { StringValue(String), IsizeValue(isize), } pub struct IsizeDecoder { len: usize, iter: IntoIter, stack: Vec, } impl IsizeDecoder { #[inline] pub fn new(values: HashMap) -> IsizeDecoder { IsizeDecoder { len: values.len(), iter: values.into_iter(), stack: vec!(), } } } impl rustc_serialize::Decoder for IsizeDecoder { type Error = Error; fn error(&mut self, _msg: &str) -> Error { Error::SyntaxError } // Primitive types: fn read_nil(&mut self) -> Result<(), Error> { Err(Error::SyntaxError) } fn read_usize(&mut self) -> Result { Err(Error::SyntaxError) } fn read_u64(&mut self) -> Result { Err(Error::SyntaxError) } fn read_u32(&mut self) -> Result { Err(Error::SyntaxError) } fn read_u16(&mut self) -> Result { Err(Error::SyntaxError) } fn read_u8(&mut self) -> Result { Err(Error::SyntaxError) } #[inline] fn read_isize(&mut self) -> Result { match self.stack.pop() { Some(IsizeValue(x)) => Ok(x), Some(_) => Err(Error::SyntaxError), None => Err(Error::EndOfStream), } } fn read_i64(&mut self) -> Result { Err(Error::SyntaxError) } fn read_i32(&mut self) -> Result { Err(Error::SyntaxError) } fn read_i16(&mut self) -> Result { Err(Error::SyntaxError) } fn read_i8(&mut self) -> Result { Err(Error::SyntaxError) } fn read_bool(&mut self) -> Result { Err(Error::SyntaxError) } fn read_f64(&mut self) -> Result { Err(Error::SyntaxError) } fn read_f32(&mut self) -> Result { Err(Error::SyntaxError) } fn read_char(&mut self) -> Result { Err(Error::SyntaxError) } #[inline] fn read_str(&mut self) -> Result { match self.stack.pop() { Some(StringValue(x)) => Ok(x), Some(_) => Err(Error::SyntaxError), None => Err(Error::EndOfStream), } } // Compound types: fn read_enum(&mut self, _name: &str, _f: F) -> Result where F: FnOnce(&mut IsizeDecoder) -> Result, { Err(Error::SyntaxError) } fn read_enum_variant(&mut self, _names: &[&str], _f: F) -> Result where F: FnOnce(&mut IsizeDecoder, usize) -> Result, { Err(Error::SyntaxError) } fn read_enum_variant_arg(&mut self, _a_idx: usize, _f: F) -> Result where F: FnOnce(&mut IsizeDecoder) -> Result, { Err(Error::SyntaxError) } fn read_enum_struct_variant(&mut self, _names: &[&str], _f: F) -> Result where F: FnOnce(&mut IsizeDecoder, usize) -> Result, { Err(Error::SyntaxError) } fn read_enum_struct_variant_field(&mut self, _f_name: &str, _f_idx: usize, _f: F) -> Result where F: FnOnce(&mut IsizeDecoder) -> Result, { Err(Error::SyntaxError) } fn read_struct(&mut self, _s_name: &str, _len: usize, _f: F) -> Result where F: FnOnce(&mut IsizeDecoder) -> Result, { Err(Error::SyntaxError) } fn read_struct_field(&mut self, _f_name: &str, _f_idx: usize, _f: F) -> Result where F: FnOnce(&mut IsizeDecoder) -> Result, { Err(Error::SyntaxError) } fn read_tuple(&mut self, _len: usize, _f: F) -> Result where F: FnOnce(&mut IsizeDecoder) -> Result, { Err(Error::SyntaxError) } fn read_tuple_arg(&mut self, _a_idx: usize, _f: F) -> Result where F: FnOnce(&mut IsizeDecoder) -> Result, { Err(Error::SyntaxError) } fn read_tuple_struct(&mut self, _s_name: &str, _len: usize, _f: F) -> Result where F: FnOnce(&mut IsizeDecoder) -> Result, { Err(Error::SyntaxError) } fn read_tuple_struct_arg(&mut self, _a_idx: usize, _f: F) -> Result where F: FnOnce(&mut IsizeDecoder) -> Result, { Err(Error::SyntaxError) } // Specialized types: fn read_option(&mut self, _f: F) -> Result where F: FnOnce(&mut IsizeDecoder, bool) -> Result, { Err(Error::SyntaxError) } fn read_seq(&mut self, _f: F) -> Result where F: FnOnce(&mut IsizeDecoder, usize) -> Result, { Err(Error::SyntaxError) } fn read_seq_elt(&mut self, _idx: usize, _f: F) -> Result where F: FnOnce(&mut IsizeDecoder) -> Result, { Err(Error::SyntaxError) } #[inline] fn read_map(&mut self, f: F) -> Result where F: FnOnce(&mut IsizeDecoder, usize) -> Result, { let len = self.len; f(self, len) } #[inline] fn read_map_elt_key(&mut self, _idx: usize, f: F) -> Result where F: FnOnce(&mut IsizeDecoder) -> Result, { match self.iter.next() { Some((key, value)) => { self.stack.push(IsizeValue(value)); self.stack.push(StringValue(key)); f(self) } None => { Err(Error::SyntaxError) } } } #[inline] fn read_map_elt_val(&mut self, _idx: usize, f: F) -> Result where F: FnOnce(&mut IsizeDecoder) -> Result, { f(self) } } } ////////////////////////////////////////////////////////////////////////////// mod deserializer { use std::collections::HashMap; use std::collections::hash_map; use super::Error; use serde::de; #[derive(PartialEq, Debug)] enum State { StartState, KeyState(String), ValueState(isize), } pub struct IsizeDeserializer { stack: Vec, iter: hash_map::IntoIter, } impl IsizeDeserializer { #[inline] pub fn new(values: HashMap) -> IsizeDeserializer { IsizeDeserializer { stack: vec!(State::StartState), iter: values.into_iter(), } } } impl de::Deserializer for IsizeDeserializer { type Error = Error; fn visit(&mut self, mut visitor: V) -> Result where V: de::Visitor, { match self.stack.pop() { Some(State::StartState) => { visitor.visit_map(self) } Some(State::KeyState(key)) => { visitor.visit_string(key) } Some(State::ValueState(value)) => { visitor.visit_isize(value) } None => { Err(Error::EndOfStream) } } } } impl de::MapVisitor for IsizeDeserializer { type Error = Error; fn visit_key(&mut self) -> Result, Error> where K: de::Deserialize, { match self.iter.next() { Some((key, value)) => { self.stack.push(State::ValueState(value)); self.stack.push(State::KeyState(key)); Ok(Some(try!(de::Deserialize::deserialize(self)))) } None => { Ok(None) } } } fn visit_value(&mut self) -> Result where V: de::Deserialize, { de::Deserialize::deserialize(self) } fn end(&mut self) -> Result<(), Error> { match self.iter.next() { Some(_) => Err(Error::SyntaxError), None => Ok(()), } } fn size_hint(&self) -> (usize, Option) { self.iter.size_hint() } } /* impl Iterator for IsizeDeserializer { type Item = Result; #[inline] fn next(&mut self) -> Option> { match self.stack.pop() { Some(StartState) => { self.stack.push(KeyOrEndState); Some(Ok(de::Token::MapStart(self.len))) } Some(KeyOrEndState) => { match self.iter.next() { Some((key, value)) => { self.stack.push(ValueState(value)); Some(Ok(de::Token::String(key))) } None => { self.stack.push(EndState); Some(Ok(de::Token::End)) } } } Some(ValueState(x)) => { self.stack.push(KeyOrEndState); Some(Ok(de::Token::Isize(x))) } Some(EndState) => { None } None => { None } } } } impl de::Deserializer for IsizeDeserializer { #[inline] fn end_of_stream_error(&mut self) -> Error { EndOfStream } #[inline] fn syntax_error(&mut self, _token: de::Token, _expected: &[de::TokenKind]) -> Error { SyntaxError } #[inline] fn unexpected_name_error(&mut self, _token: de::Token) -> Error { SyntaxError } #[inline] fn conversion_error(&mut self, _token: de::Token) -> Error { SyntaxError } #[inline] fn missing_field< T: de::Deserialize >(&mut self, _field: &'static str) -> Result { Err(Error::SyntaxError) } } */ } ////////////////////////////////////////////////////////////////////////////// fn run_decoder< D: Decoder, T: Clone + PartialEq + Debug + Decodable >(mut d: D, value: T) { let v = Decodable::decode(&mut d); assert_eq!(Ok(value), v); } #[bench] fn bench_decoder_000(b: &mut Bencher) { b.iter(|| { let m: HashMap = HashMap::new(); run_decoder(decoder::IsizeDecoder::new(m.clone()), m) }) } #[bench] fn bench_decoder_003(b: &mut Bencher) { b.iter(|| { let mut m: HashMap = HashMap::new(); for i in (0 .. 3) { m.insert(i.to_string(), i); } run_decoder(decoder::IsizeDecoder::new(m.clone()), m) }) } #[bench] fn bench_decoder_100(b: &mut Bencher) { b.iter(|| { let mut m: HashMap = HashMap::new(); for i in (0 .. 100) { m.insert(i.to_string(), i); } run_decoder(decoder::IsizeDecoder::new(m.clone()), m) }) } fn run_deserializer< D: Deserializer, E: Debug, T: Clone + PartialEq + Debug + Deserialize >(mut d: D, value: T) { let v: T = Deserialize::deserialize(&mut d).unwrap(); assert_eq!(value, v); } #[bench] fn bench_deserializer_000(b: &mut Bencher) { b.iter(|| { let m: HashMap = HashMap::new(); run_deserializer(deserializer::IsizeDeserializer::new(m.clone()), m) }) } #[bench] fn bench_deserializer_003(b: &mut Bencher) { b.iter(|| { let mut m: HashMap = HashMap::new(); for i in (0 .. 3) { m.insert(i.to_string(), i); } run_deserializer(deserializer::IsizeDeserializer::new(m.clone()), m) }) } #[bench] fn bench_deserializer_100(b: &mut Bencher) { b.iter(|| { let mut m: HashMap = HashMap::new(); for i in (0 .. 100) { m.insert(i.to_string(), i); } run_deserializer(deserializer::IsizeDeserializer::new(m.clone()), m) }) }