hx conf, fmt

Signed-off-by: Onur Satici <[email protected]>

Author: onursatici

.helix/languages.toml

@@ -0,0 +1,3 @@
+[language-server.rust-analyzer.config]
+cargo = { target = "x86_64-unknown-linux-gnu", features = "all" }
+checkOnSave = { extraArgs = ["--target", "x86_64-unknown-linux-gnu"] }

bench-vortex/src/lib.rs

@@ -76,7 +76,11 @@ pub fn configure_runtime(choice: Option<RuntimeChoice>) {
 }
 
 fn make_session() -> VortexSession {
-    match RUNTIME_OVERRIDE.get().copied().unwrap_or(RuntimeChoice::Tokio) {
+    match RUNTIME_OVERRIDE
+        .get()
+        .copied()
+        .unwrap_or(RuntimeChoice::Tokio)
+    {
         RuntimeChoice::Tokio => VortexSession::default().with_tokio(),
         #[cfg(all(feature = "uring", target_os = "linux"))]
         RuntimeChoice::Uring => {

vortex-io/src/file/std_file.rs

@@ -27,9 +27,9 @@ use crate::file::IntoReadSource;
 use crate::file::IoRequest;
 use crate::file::ReadSource;
 use crate::file::ReadSourceRef;
-use crate::runtime::Handle;
 #[cfg(all(target_os = "linux", feature = "uring"))]
 use crate::file::uring_file::open_uring_read_source;
+use crate::runtime::Handle;
 
 /// Read exactly `buffer.len()` bytes from `file` starting at `offset`.
 /// This is a platform-specific helper that uses the most efficient method available.

vortex-io/src/file/uring_file.rs

@@ -72,8 +72,13 @@ impl ReadSource for UringFileIoSource {
 
     fn size(&self) -> BoxFuture<'static, VortexResult<u64>> {
         let std_file = self.std_file.clone();
-        futures::future::ready(std_file.metadata().map(|m| m.len()).map_err(VortexError::from))
-            .boxed()
+        futures::future::ready(
+            std_file
+                .metadata()
+                .map(|m| m.len())
+                .map_err(VortexError::from),
+        )
+        .boxed()
     }
 
     fn drive_send(

vortex-io/src/runtime/uring.rs

@@ -15,8 +15,8 @@ use std::thread;
 use futures::future::BoxFuture;
 use kanal::Receiver;
 use kanal::Sender;
-use monoio::RuntimeBuilder;
 use monoio::IoUringDriver;
+use monoio::RuntimeBuilder;
 use vortex_error::vortex_panic;
 
 use crate::runtime::AbortHandle;
@@ -78,7 +78,9 @@ impl LocalExecutor for HandleSetExecutor {
     fn spawn_local(&self, f: LocalSpawn) -> AbortHandleRef {
         match self.pick().as_local_executor() {
             Some(exec) => exec.spawn_local(f),
-            None => vortex_panic!("LocalExecutor requested but not supported by any underlying executor"),
+            None => vortex_panic!(
+                "LocalExecutor requested but not supported by any underlying executor"
+            ),
         }
     }
 }
@@ -93,9 +95,7 @@ pub(crate) struct HandleSet {
 impl HandleSet {
     pub(crate) fn new(executors: Vec<Arc<dyn Executor>>) -> Self {
         let executors: Arc<[Arc<dyn Executor>]> = executors.into();
-        let dispatcher = Arc::new(HandleSetExecutor::new(
-            executors.iter().cloned().collect(),
-        ));
+        let dispatcher = Arc::new(HandleSetExecutor::new(executors.iter().cloned().collect()));
         Self {
             executors,
             dispatcher,
@@ -116,10 +116,7 @@ impl HandleSet {
 
 /// Create a [`Handle`] that dispatches work round-robin across the provided handles.
 pub fn dispatching_handle(handles: &[Handle]) -> Handle {
-    let executors = handles
-        .iter()
-        .map(|h| h.runtime())
-        .collect::<Vec<_>>();
+    let executors = handles.iter().map(|h| h.runtime()).collect::<Vec<_>>();
     let set = HandleSet::new(executors);
     set.dispatching_handle()
 }