Check size on insertion

ledger/src/blockstore.rs

@@ -1381,6 +1381,7 @@ impl Blockstore {
         shred: &Shred,
         write_batch: &mut WriteBatch,
     ) -> Result<Vec<(u32, u32)>> {
+        use crate::shred::SHRED_PAYLOAD_SIZE;
         let slot = shred.slot();
         let index = u64::from(shred.index());
 
@@ -1414,6 +1415,14 @@ impl Blockstore {
 
         // Commit step: commit all changes to the mutable structures at once, or none at all.
         // We don't want only a subset of these changes going through.
+        if shred.payload.len() > SHRED_PAYLOAD_SIZE {
+            return Err(BlockstoreError::InvalidShredData(Box::new(
+                bincode::ErrorKind::Custom(format!(
+                    "Data shred with slot {}, index {} has payload that is too large to be valid.",
+                    slot, index
+                )),
+            )));
+        }
         write_batch.put_bytes::<cf::ShredData>(
             (slot, index),
             // Payload will be padded out to SHRED_PAYLOAD_SIZE