@@ -306,8 +306,7 @@ where
306306 }
307307 message. state = TransmissionState :: InProgress ;
308308 // Transform message into chunks.
309- let mut chunks =
310- Vec :: with_capacity ( ( message. len + AVERAGE_CHUNK_SIZE - 1 ) / AVERAGE_CHUNK_SIZE ) ;
309+ let mut chunks = Vec :: with_capacity ( message. len . div_ceil ( AVERAGE_CHUNK_SIZE ) ) ;
311310 for ( chunk_idx, data_chunk) in
312311 message. msg . data . chunks ( AVERAGE_CHUNK_SIZE ) . enumerate ( )
313312 {
@@ -382,8 +381,7 @@ where
382381 // Otherwise unilaterally reset the state. The message id space is large enough to
383382 // avoid accidental collisions.
384383 let mi = MessageInit :: new ( mp) ;
385- let expected_chunks =
386- ( mi. length ( ) as usize + AVERAGE_CHUNK_SIZE - 1 ) / AVERAGE_CHUNK_SIZE ;
384+ let expected_chunks = ( mi. length ( ) as usize ) . div_ceil ( AVERAGE_CHUNK_SIZE ) ;
387385 let chunks = vec ! [ None ; expected_chunks] ;
388386 let message = ReceivedMessageInfo {
389387 id : message_id,
@@ -418,8 +416,7 @@ where
418416 return ;
419417 }
420418 // Check max chunk idx.
421- let max_chunk_idx =
422- ( ( message. len + MINIMUM_CHUNK_SIZE - 1 ) / MINIMUM_CHUNK_SIZE ) - 1 ;
419+ let max_chunk_idx = message. len . div_ceil ( MINIMUM_CHUNK_SIZE ) ;
423420 if mc. chunk_idx ( ) > max_chunk_idx {
424421 debug ! ( "Dropping CHUNK because index is too high" ) ;
425422 return ;
@@ -1132,7 +1129,7 @@ impl Serialize for MessageId {
11321129
11331130struct MessageIdVisitor ;
11341131
1135- impl < ' de > Visitor < ' de > for MessageIdVisitor {
1132+ impl Visitor < ' _ > for MessageIdVisitor {
11361133 type Value = MessageId ;
11371134
11381135 fn expecting ( & self , formatter : & mut std:: fmt:: Formatter ) -> std:: fmt:: Result {
@@ -1234,7 +1231,7 @@ struct Flags<'a> {
12341231 _marker : PhantomData < & ' a MessagePacketHeader < ' a > > ,
12351232}
12361233
1237- impl < ' a > Flags < ' a > {
1234+ impl Flags < ' _ > {
12381235 /// Check if the MESSAGE_INIT flag is set on the header.
12391236 fn init ( & self ) -> bool {
12401237 self . flags & FLAG_MESSAGE_INIT != 0
@@ -1334,7 +1331,7 @@ impl FlagsMut<'_, '_> {
13341331// - 8 bytes message id
13351332// - 2 bytes flags
13361333// - 2 bytes reserved
1337- impl < ' a > MessagePacketHeader < ' a > {
1334+ impl MessagePacketHeader < ' _ > {
13381335 /// Get the [`MessageId`] from the buffer.
13391336 fn message_id ( & self ) -> MessageId {
13401337 MessageId (
@@ -1400,23 +1397,23 @@ impl<'a> MessagePacketHeaderMut<'a> {
14001397 }
14011398}
14021399
1403- impl < ' a > Deref for MessagePacketHeader < ' a > {
1400+ impl Deref for MessagePacketHeader < ' _ > {
14041401 type Target = [ u8 ; MESSAGE_HEADER_SIZE ] ;
14051402
14061403 fn deref ( & self ) -> & Self :: Target {
14071404 self . header
14081405 }
14091406}
14101407
1411- impl < ' a > Deref for MessagePacketHeaderMut < ' a > {
1408+ impl Deref for MessagePacketHeaderMut < ' _ > {
14121409 type Target = [ u8 ; MESSAGE_HEADER_SIZE ] ;
14131410
14141411 fn deref ( & self ) -> & Self :: Target {
14151412 self . header
14161413 }
14171414}
14181415
1419- impl < ' a > DerefMut for MessagePacketHeaderMut < ' a > {
1416+ impl DerefMut for MessagePacketHeaderMut < ' _ > {
14201417 fn deref_mut ( & mut self ) -> & mut Self :: Target {
14211418 self . header
14221419 }
0 commit comments