Clippy fixes

src/extensions/filter_manager.rs

@@ -34,8 +34,8 @@ pub struct FilterManager {
 
 /// ListenerManagerArgs contains arguments when invoking the LDS resource manager.
 pub(crate) struct ListenerManagerArgs {
-    pub filter_registry: Arc<FilterRegistry>,
     pub filter_chain_updates_tx: mpsc::Sender<Arc<FilterChain>>,
+    pub filter_registry: Arc<FilterRegistry>,
     pub metrics_registry: Registry,
 }
 
@@ -46,9 +46,9 @@ impl ListenerManagerArgs {
         filter_chain_updates_tx: mpsc::Sender<Arc<FilterChain>>,
     ) -> ListenerManagerArgs {
         ListenerManagerArgs {
-            metrics_registry,
-            filter_registry,
             filter_chain_updates_tx,
+            filter_registry,
+            metrics_registry,
         }
     }
 }

src/extensions/filter_registry.rs

@@ -237,9 +237,9 @@ impl fmt::Display for Error {
     }
 }
 
-impl Into<ValidationError> for Error {
-    fn into(self) -> ValidationError {
-        ValidationError::FilterInvalid(self)
+impl From<Error> for ValidationError {
+    fn from(error: Error) -> Self {
+        Self::FilterInvalid(error)
     }
 }
 

src/extensions/filters/local_rate_limit/mod.rs

@@ -135,10 +135,12 @@ impl RateLimitFilter {
                         while !refilled {
                             let remaining_tokens = available_tokens.load(Ordering::Relaxed);
 
-                            refilled = available_tokens.compare_and_swap(
+                            refilled = available_tokens.compare_exchange(
                                 remaining_tokens,
                                 max_tokens,
-                                Ordering::Relaxed) == remaining_tokens;
+                                Ordering::Relaxed,
+                                Ordering::Relaxed,
+                                ).unwrap_or_else(|b| b) == remaining_tokens;
                         }
                     },
                     _ = &mut shutdown_rx => {
@@ -166,11 +168,16 @@ impl RateLimitFilter {
                 return None;
             }
 
-            if self.available_tokens.compare_and_swap(
-                remaining_tokens,
-                remaining_tokens - 1,
-                Ordering::Relaxed,
-            ) == remaining_tokens
+            if self
+                .available_tokens
+                .compare_exchange(
+                    remaining_tokens,
+                    remaining_tokens - 1,
+                    Ordering::Relaxed,
+                    Ordering::Relaxed,
+                )
+                .unwrap_or_else(|b| b)
+                == remaining_tokens
             {
                 return Some(());
             }

src/proxy/server/mod.rs

@@ -611,14 +611,8 @@ mod tests {
         // since we don't know what the session ephemeral port is, we'll just
         // search for the filter strings.
         let result = endpoint.packet_rx.await.unwrap();
-        assert!(
-            result.contains(msg),
-            format!("'{}' not found in '{}'", msg, result)
-        );
-        assert!(
-            result.contains(":odr:"),
-            format!(":odr: not found in '{}'", result)
-        );
+        assert!(result.contains(msg), "'{}' not found in '{}'", msg, result);
+        assert!(result.contains(":odr:"), ":odr: not found in '{}'", result);
     }
 
     #[tokio::test]