Fixed build

Cargo.toml

@@ -11,6 +11,7 @@ memmap = "*"
 rmp = "*"
 rmp-serde = "*"
 serde = "*"
+serde_bytes = "*"
 tempdir = "*"
 tempfile = "*"
 time = "*"

src/lib.rs

@@ -6,6 +6,7 @@ extern crate byteorder;
 pub extern crate rmp;
 pub extern crate rmp_serde;
 extern crate serde;
+extern crate serde_bytes;
 extern crate tempdir;
 extern crate tempfile;
 extern crate time;

src/msg.rs

@@ -3,7 +3,8 @@ use std;
 use rmp;
 pub use rmp_serde;
 use serde;
-use serde::bytes::ByteBuf;
+use serde_bytes;
+use serde_bytes::ByteBuf;
 pub use serde::{Deserialize, Serialize};
 
 use errors::*;
@@ -66,8 +67,8 @@ macro_rules! error_response {
 
 pub const NIL: Option<u32> = None;
 
-pub fn bytes(data: &[u8]) -> serde::bytes::Bytes {
-    serde::bytes::Bytes::new(data)
+pub fn bytes(data: &[u8]) -> serde_bytes::Bytes {
+    serde_bytes::Bytes::new(data)
 }
 
 #[derive(Debug, PartialEq)]
@@ -158,7 +159,7 @@ impl<T: io::Read> ZeoIter<T> {
 
 fn pre_parse(mut reader: &mut io::Read)
              -> Result<(i64, String)> {
-    let array_size = try!(rmp::decode::read_array_size(&mut reader)
+    let array_size = try!(rmp::decode::read_array_len(&mut reader)
                           .chain_err(|| "get mess size"));
     if array_size != 3 {
         return Err(format!("Bad array size {}", array_size).into());

src/reader.rs

@@ -2,6 +2,7 @@
 use std;
 use std::collections::BTreeMap;
 use serde;
+use serde_bytes::Bytes;
 
 use storage;
 use writer;
@@ -84,7 +85,7 @@ pub fn reader<R: io::Read>(
             },
             Zeo::NewOids(id) => {
                 let oids = fs.new_oids();
-                let oids: Vec<serde::bytes::Bytes> =
+                let oids: Vec<Bytes> =
                     oids.iter().map(| oid | bytes(oid)).collect();
                 respond!(sender, id, oids)
             },

src/writer.rs

@@ -2,6 +2,7 @@ use std;
 use std::collections::{BTreeMap, HashMap};
 
 use serde;
+use serde_bytes;
 
 use storage;
 use transaction;
@@ -132,10 +133,10 @@ pub fn writer<W: io::Write>(
                     try!(trans.locked());
                     let conflicts = try!(fs.stage(&mut trans));
                     let conflict_maps:
-                    Vec<BTreeMap<String, serde::bytes::Bytes>> =
+                    Vec<BTreeMap<String, serde_bytes::Bytes>> =
                         conflicts.iter()
                         .map(| c | {
-                            let mut m: BTreeMap<String, serde::bytes::Bytes> =
+                            let mut m: BTreeMap<String, serde_bytes::Bytes> =
                                 BTreeMap::new();
                             m.insert("oid".to_string(), bytes(&c.oid)); 
                             m.insert("serial".to_string(), bytes(&c.serial)); 
@@ -168,7 +169,7 @@ pub fn writer<W: io::Write>(
                 async!(writer, "info", (info,));
             },
             Zeo::Invalidate(tid, oids) => {
-                let oids: Vec<serde::bytes::Bytes> =
+                let oids: Vec<serde_bytes::Bytes> =
                     oids.iter().map(| oid | bytes(oid)).collect();
                 async!(writer, "invalidateTransaction", (bytes(&tid), oids));
             },

tests/reader.rs

@@ -2,14 +2,15 @@
 
 extern crate byteorder;
 extern crate serde;
+extern crate serde_bytes;
 
 #[macro_use]
 extern crate byteserver;
 extern crate pipe;
 
 use std::collections::BTreeMap;
 
-use serde::bytes::ByteBuf;
+use serde_bytes::ByteBuf;
 
 use byteserver::msg::*;
 use byteserver::util::*;

tests/writer.rs

@@ -3,14 +3,15 @@
 
 extern crate byteorder;
 extern crate serde;
+extern crate serde_bytes;
 
 #[macro_use]
 extern crate byteserver;
 extern crate pipe;
 
 use std::collections::BTreeMap;
 
-use serde::bytes::ByteBuf;
+use serde_bytes::ByteBuf;
 
 use byteserver::msg::*;
 use byteserver::util::*;