in plasma-stream/src/server/sender.rs [163:185]
fn check_object_sizes(&self, objects: &[ObjectBuffer<'_>]) -> Result<(), ObjectSendError> {
for ob in objects {
let meta_size = ob.meta().len();
if meta_size as u64 > MAX_META_SIZE {
let oid: ObjectId = ob.id().to_bytes().try_into().unwrap();
return Err(ObjectSendError::ObjectMetaTooLarge(
self.peer_addr,
oid,
meta_size,
));
}
let data_size = ob.data().len();
if data_size as u64 > MAX_DATA_SIZE {
let oid: ObjectId = ob.id().to_bytes().try_into().unwrap();
return Err(ObjectSendError::ObjectDataTooLarge(
self.peer_addr,
oid,
data_size,
));
}
}
Ok(())
}