From: Matt Corallo <git@bluematt.me>
Date: Sun, 16 Sep 2018 02:06:13 +0000 (-0400)
Subject: Split out Vec<u8> and Vec<Signature> ser impls cause there's 2
X-Git-Tag: v0.0.12~306^2~3
X-Git-Url: http://git.bitcoin.ninja/?a=commitdiff_plain;h=ee9533a9057c0dc0cf78a37ecb767f6981e8f734;p=rust-lightning

Split out Vec<u8> and Vec<Signature> ser impls cause there's 2

Should resolve any performance issues with Vec<u8> serialization.
---

diff --git a/src/util/ser.rs b/src/util/ser.rs
index 7f795fe46..6c4082090 100644
--- a/src/util/ser.rs
+++ b/src/util/ser.rs
@@ -2,7 +2,6 @@ use std::result::Result;
 use std::io::Read;
 use std::collections::HashMap;
 use std::hash::Hash;
-use std::mem;
 
 use secp256k1::{Secp256k1, Signature};
 use secp256k1::key::PublicKey;
@@ -163,17 +162,34 @@ impl<R, K, V> Readable<R> for HashMap<K, V>
 }
 
 // Vectors
-impl<W: Writer, T: Writeable<W>> Writeable<W> for Vec<T> {
+impl<W: Writer> Writeable<W> for Vec<u8> {
+	#[inline]
+	fn write(&self, w: &mut W) -> Result<(), DecodeError> {
+		(self.len() as u16).write(w)?;
+		Ok(w.write_all(&self)?)
+	}
+}
+
+impl<R: Read> Readable<R> for Vec<u8> {
+	#[inline]
+	fn read(r: &mut R) -> Result<Self, DecodeError> {
+		let len: u16 = Readable::read(r)?;
+		let mut ret = Vec::with_capacity(len as usize);
+		ret.resize(len as usize, 0);
+		r.read_exact(&mut ret)?;
+		Ok(ret)
+	}
+}
+impl<W: Writer> Writeable<W> for Vec<Signature> {
 	#[inline]
 	fn write(&self, w: &mut W) -> Result<(), DecodeError> {
 		let byte_size = (self.len() as usize)
-		                .checked_mul(mem::size_of::<T>())
+		                .checked_mul(33)
 		                .ok_or(DecodeError::BadLengthDescriptor)?;
 		if byte_size > MAX_BUF_SIZE {
 			return Err(DecodeError::BadLengthDescriptor);
 		}
 		(self.len() as u16).write(w)?;
-		// performance with Vec<u8>
 		for e in self.iter() {
 			e.write(w)?;
 		}
@@ -181,25 +197,26 @@ impl<W: Writer, T: Writeable<W>> Writeable<W> for Vec<T> {
 	}
 }
 
-impl<R: Read, T: Readable<R>> Readable<R> for Vec<T> {
+impl<R: Read> Readable<R> for Vec<Signature> {
 	#[inline]
 	fn read(r: &mut R) -> Result<Self, DecodeError> {
 		let len: u16 = Readable::read(r)?;
 		let byte_size = (len as usize)
-		                .checked_mul(mem::size_of::<T>())
+		                .checked_mul(33)
 		                .ok_or(DecodeError::BadLengthDescriptor)?;
 		if byte_size > MAX_BUF_SIZE {
 			return Err(DecodeError::BadLengthDescriptor);
 		}
 		let mut ret = Vec::with_capacity(len as usize);
-		for _ in 0..len { ret.push(T::read(r)?); }
+		for _ in 0..len { ret.push(Signature::read(r)?); }
 		Ok(ret)
 	}
 }
 
 impl<W: Writer> Writeable<W> for Script {
 	fn write(&self, w: &mut W) -> Result<(), DecodeError> {
-		self.to_bytes().to_vec().write(w)
+		(self.len() as u16).write(w)?;
+		Ok(w.write_all(self.as_bytes())?)
 	}
 }