From dd819cec3df249fd434a8c443f32cfde33af89bc Mon Sep 17 00:00:00 2001
From: Rob Walker <rob@solana.com>
Date: Thu, 26 Jul 2018 08:55:00 -0700
Subject: [PATCH] fix off by one in packet.rs

---
 src/crdt.rs     | 2 +-
 src/packet.rs   | 2 +-
 src/streamer.rs | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/crdt.rs b/src/crdt.rs
index 082b66e9c3..3369a08160 100644
--- a/src/crdt.rs
+++ b/src/crdt.rs
@@ -693,7 +693,7 @@ impl Crdt {
                     v.debug_id(),
                 );
                 //TODO profile this, may need multiple sockets for par_iter
-                assert!(rblob.meta.size < BLOB_SIZE);
+                assert!(rblob.meta.size <= BLOB_SIZE);
                 s.send_to(&rblob.data[..rblob.meta.size], &v.contact_info.tvu)
             })
             .collect();
diff --git a/src/packet.rs b/src/packet.rs
index a874a4f938..36741acc46 100644
--- a/src/packet.rs
+++ b/src/packet.rs
@@ -280,7 +280,7 @@ pub fn to_blob<T: Serialize>(
         let mut b = blob.write().unwrap();
         let v = serialize(&resp)?;
         let len = v.len();
-        assert!(len < BLOB_SIZE);
+        assert!(len <= BLOB_SIZE);
         b.data[..len].copy_from_slice(&v);
         b.meta.size = len;
         b.meta.set_addr(&rsp_addr);
diff --git a/src/streamer.rs b/src/streamer.rs
index 54c819e7de..952d19625b 100644
--- a/src/streamer.rs
+++ b/src/streamer.rs
@@ -236,7 +236,7 @@ fn repair_window(
             "{:x}: repair_window request {} {} {}",
             debug_id, consumed, received, to
         );
-        assert!(req.len() < BLOB_SIZE);
+        assert!(req.len() <= BLOB_SIZE);
         sock.send_to(&req, to)?;
     }
     Ok(())