cargo fmt

Author: nbdd0121

src/cgroup.rs

@@ -1,4 +1,4 @@
-use anyhow::{ensure, Context, Result};
+use anyhow::{Context, Result, ensure};
 use aya::maps::{HashMap, MapData};
 use aya::programs::{CgroupAttachMode, CgroupDevice, Link};
 use std::ffi::OsStr;

src/cli/device.rs

@@ -2,7 +2,7 @@ use std::fmt::Display;
 use std::path::PathBuf;
 use std::str::FromStr;
 
-use anyhow::{bail, ensure, Context, Error, Result};
+use anyhow::{Context, Error, Result, bail, ensure};
 use udev::Enumerator;
 
 use crate::dev::Device;

src/cli/symlink.rs

@@ -1,7 +1,7 @@
 use std::path::PathBuf;
 use std::str::FromStr;
 
-use anyhow::{bail, ensure, Error, Result};
+use anyhow::{Error, Result, bail, ensure};
 
 use crate::dev::Device;
 
@@ -50,7 +50,10 @@ impl FromStr for Symlink {
         match kind {
             "usb" => {
                 let parts: Vec<_> = dev.split(':').collect();
-                ensure!(parts.len() == 3, "Symlink DEVICE format for usb should be `<VID>:<PID>:<INTERFACE>`, found `{dev}`.");
+                ensure!(
+                    parts.len() == 3,
+                    "Symlink DEVICE format for usb should be `<VID>:<PID>:<INTERFACE>`, found `{dev}`."
+                );
 
                 let vid = parts[0];
                 let pid = parts[1];

src/dev/monitor.rs

@@ -2,12 +2,12 @@
 //!
 //! Provides async support and convience methods to monitor devices and retrieve device properties.
 
-use std::collections::hash_map::Entry;
 use std::collections::HashMap;
 use std::collections::VecDeque;
+use std::collections::hash_map::Entry;
 use std::path::PathBuf;
 use std::rc::Rc;
-use std::task::{ready, Poll};
+use std::task::{Poll, ready};
 
 use anyhow::Result;
 use tokio::io::unix::AsyncFd;

src/main.rs

@@ -16,11 +16,11 @@ use std::pin::pin;
 use std::process::ExitCode;
 use std::sync::Arc;
 
-use anyhow::{bail, Context, Result};
+use anyhow::{Context, Result, bail};
 use clap::Parser;
 use log::info;
-use runc::cli::{CreateOptions, GlobalOptions};
 use runc::Container;
+use runc::cli::{CreateOptions, GlobalOptions};
 use rustix::fd::OwnedFd;
 use rustix::pipe::PipeFlags;
 use rustix::process::Signal;
@@ -118,9 +118,11 @@ async fn create(global: GlobalOptions, create: CreateOptions, notifier: OwnedFd)
         }
     };
 
-    let mut stream = pin!(tokio_stream::empty()
-        .merge(hotplug_stream)
-        .merge(container_stream));
+    let mut stream = pin!(
+        tokio_stream::empty()
+            .merge(hotplug_stream)
+            .merge(container_stream)
+    );
 
     loop {
         let event = stream.try_next().await?.context("No more events")?;

src/runc/container.rs

@@ -4,12 +4,12 @@ use std::os::fd::AsFd;
 use std::os::unix::fs::{FileTypeExt, MetadataExt, PermissionsExt};
 use std::path::Path;
 
-use anyhow::{bail, Context, Result};
+use anyhow::{Context, Result, bail};
 use rustix::fs::{FileType, Mode};
 use rustix::mount::{FsMountFlags, FsOpenFlags, MountAttrFlags, MoveMountFlags, UnmountFlags};
 use rustix::process::{Pid, Signal};
-use tokio::io::unix::AsyncFd;
 use tokio::io::Interest;
+use tokio::io::unix::AsyncFd;
 use tokio::sync::Mutex;
 
 use crate::cgroup::{