We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b23181d commit 9327d63Copy full SHA for 9327d63
1 file changed
cake-core/src/cake/sharding/proto/message.rs
@@ -266,12 +266,12 @@ impl Message {
266
let mut header = [0u8; 8];
267
reader.read_exact(&mut header).await?;
268
269
- let magic = u32::from_be_bytes([header[0], header[1], header[2], header[3]]);
+ let magic = u32::from_be_bytes(header[..4].try_into().unwrap());
270
if magic != super::PROTO_MAGIC {
271
return Err(anyhow!("invalid magic value: {magic}"));
272
}
273
274
- let req_size = u32::from_be_bytes([header[4], header[5], header[6], header[7]]);
+ let req_size = u32::from_be_bytes(header[4..8].try_into().unwrap());
275
if req_size > super::MESSAGE_MAX_SIZE {
276
return Err(anyhow!("request size {req_size} > MESSAGE_MAX_SIZE"));
277
0 commit comments