Fix lint

Author: logist322

srtp/benches/srtp_bench.rs

@@ -4,8 +4,8 @@ use util::Marshal;
 use webrtc_srtp::{context::Context, protection_profile::ProtectionProfile};
 
 const RAW_RTCP: Bytes = Bytes::from_static(&[
-    0x81, 0xc8, 0x00, 0x0b, 0xca, 0xfe, 0xba, 0xbe, 0xab, 0xab, 0xab, 0xab, 0xab, 0xab, 0xab,
-    0xab, 0xab, 0xab, 0xab, 0xab, 0xab, 0xab, 0xab, 0xab,
+    0x81, 0xc8, 0x00, 0x0b, 0xca, 0xfe, 0xba, 0xbe, 0xab, 0xab, 0xab, 0xab, 0xab, 0xab, 0xab, 0xab,
+    0xab, 0xab, 0xab, 0xab, 0xab, 0xab, 0xab, 0xab,
 ]);
 
 fn benchmark_encrypt_rtp_aes_128_cm_hmac_sha1(c: &mut Criterion) {
@@ -121,8 +121,7 @@ fn benchmark_encrypt_rtcp_aes_128_cm_hmac_sha1(c: &mut Criterion) {
 
     c.bench_function("Benchmark RTCP encrypt", |b| {
         b.iter(|| {
-            ctx.encrypt_rtcp(&RAW_RTCP)
-            .unwrap();
+            ctx.encrypt_rtcp(&RAW_RTCP).unwrap();
         });
     });
 }

srtp/src/cipher/cipher_aead_aes_gcm.rs

@@ -34,8 +34,7 @@ impl Cipher for CipherAeadAesGcm {
     ) -> Result<Bytes> {
         // Grow the given buffer to fit the output.
         let header_len = header.marshal_size();
-        let mut writer =
-            BytesMut::with_capacity(payload.len() + self.auth_tag_len());
+        let mut writer = BytesMut::with_capacity(payload.len() + self.auth_tag_len());
 
         // Copy header unencrypted.
         writer.extend_from_slice(&payload[..header_len]);

srtp/src/cipher/cipher_aes_cm_hmac_sha1/ctrcipher.rs

@@ -104,7 +104,7 @@ impl Cipher for CtrCipher {
 
         // See if the auth tag actually matches.
         // We use a constant time comparison to prevent timing attacks.
-        if actual_tag.ct_eq(&expected_tag).unwrap_u8() != 1 {
+        if actual_tag.ct_eq(expected_tag).unwrap_u8() != 1 {
             return Err(Error::RtpFailedToVerifyAuthTag);
         }
 
@@ -147,9 +147,7 @@ impl Cipher for CtrCipher {
         let nonce = GenericArray::from_slice(&counter);
         let mut stream = Aes128Ctr::new(key, nonce);
 
-        stream.apply_keystream(
-            &mut writer[HEADER_LENGTH + SSRC_LENGTH..],
-        );
+        stream.apply_keystream(&mut writer[HEADER_LENGTH + SSRC_LENGTH..]);
 
         // Add SRTCP index and set Encryption bit
         writer.put_u32(srtcp_index as u32 | (1u32 << 31));
@@ -197,7 +195,7 @@ impl Cipher for CtrCipher {
 
         // See if the auth tag actually matches.
         // We use a constant time comparison to prevent timing attacks.
-        if actual_tag.ct_eq(&expected_tag).unwrap_u8() != 1 {
+        if actual_tag.ct_eq(expected_tag).unwrap_u8() != 1 {
             return Err(Error::RtcpFailedToVerifyAuthTag);
         }
 
@@ -213,9 +211,7 @@ impl Cipher for CtrCipher {
         let mut stream = Aes128Ctr::new(key, nonce);
 
         stream.seek(0);
-        stream.apply_keystream(
-            &mut writer[HEADER_LENGTH + SSRC_LENGTH..],
-        );
+        stream.apply_keystream(&mut writer[HEADER_LENGTH + SSRC_LENGTH..]);
 
         Ok(Bytes::from(writer))
     }

srtp/src/context/srtp.rs

@@ -48,13 +48,14 @@ impl Context {
         payload: &[u8],
         header: &rtp::header::Header,
     ) -> Result<Bytes> {
-        let roc = self.get_srtp_ssrc_state(header.ssrc).next_rollover_count(header.sequence_number);
+        let roc = self
+            .get_srtp_ssrc_state(header.ssrc)
+            .next_rollover_count(header.sequence_number);
 
-        let dst = self
-            .cipher
-            .encrypt_rtp(&payload, header, roc)?;
+        let dst = self.cipher.encrypt_rtp(payload, header, roc)?;
 
-        self.get_srtp_ssrc_state(header.ssrc).update_rollover_count(header.sequence_number);
+        self.get_srtp_ssrc_state(header.ssrc)
+            .update_rollover_count(header.sequence_number);
 
         Ok(dst)
     }