Format

Author: rkuris

benchmark/src/create.rs

@@ -5,7 +5,7 @@ use std::error::Error;
 use std::time::Instant;
 
 use fastrace::prelude::SpanContext;
-use fastrace::{func_path, Span};
+use fastrace::{Span, func_path};
 use firewood::db::Db;
 use firewood::v2::api::{Db as _, Proposal as _};
 use log::info;

benchmark/src/main.rs

@@ -31,8 +31,8 @@ use firewood::manager::{CacheReadStrategy, RevisionManagerConfig};
 
 use fastrace::collector::Config;
 
-use opentelemetry::trace::SpanKind;
 use opentelemetry::InstrumentationScope;
+use opentelemetry::trace::SpanKind;
 use opentelemetry_otlp::{SpanExporter, WithExportConfig};
 use opentelemetry_sdk::Resource;
 

ffi/src/metrics.rs

@@ -3,12 +3,12 @@ use std::{
     io::Write,
     net::Ipv6Addr,
     ops::Deref,
-    sync::{atomic::Ordering, Arc, Once},
+    sync::{Arc, Once, atomic::Ordering},
     time::SystemTime,
 };
 
-use oxhttp::model::{Body, Response, StatusCode};
 use oxhttp::Server;
+use oxhttp::model::{Body, Response, StatusCode};
 use std::net::Ipv4Addr;
 use std::time::Duration;
 

firewood/benches/hashops.rs

@@ -4,7 +4,7 @@
 // hash benchmarks; run with 'cargo bench'
 
 use criterion::profiler::Profiler;
-use criterion::{criterion_group, criterion_main, BatchSize, Criterion};
+use criterion::{BatchSize, Criterion, criterion_group, criterion_main};
 use firewood::db::{BatchOp, DbConfig};
 use firewood::merkle::Merkle;
 use firewood::v2::api::{Db as _, Proposal as _};

firewood/src/merkle.rs

@@ -1036,7 +1036,7 @@ impl<'a, T: PartialEq> PrefixOverlap<'a, T> {
 mod tests {
     use super::*;
     use rand::rngs::StdRng;
-    use rand::{rng, Rng, SeedableRng};
+    use rand::{Rng, SeedableRng, rng};
     use storage::{MemStore, MutableProposal, NodeStore, RootReader};
     use test_case::test_case;
 
@@ -1338,9 +1338,11 @@ mod tests {
 
             {
                 // Test that the proof is invalid when the hash is different
-                assert!(proof
-                    .verify(key, Some(value), &TrieHash::default())
-                    .is_err());
+                assert!(
+                    proof
+                        .verify(key, Some(value), &TrieHash::default())
+                        .is_err()
+                );
             }
         }
     }

fwdctl/src/create.rs

@@ -1,7 +1,7 @@
 // Copyright (C) 2023, Ava Labs, Inc. All rights reserved.
 // See the file LICENSE.md for licensing terms.
 
-use clap::{value_parser, Args};
+use clap::{Args, value_parser};
 use firewood::db::{Db, DbConfig};
 use firewood::v2::api;
 

fwdctl/tests/cli.rs

@@ -1,7 +1,7 @@
 // Copyright (C) 2023, Ava Labs, Inc. All rights reserved.
 // See the file LICENSE.md for licensing terms.
 
-use anyhow::{anyhow, Result};
+use anyhow::{Result, anyhow};
 use assert_cmd::Command;
 use predicates::prelude::*;
 use serial_test::serial;

grpc-testtool/benches/insert.rs

@@ -1,7 +1,7 @@
 // Copyright (C) 2023, Ava Labs, Inc. All rights reserved.
 // See the file LICENSE.md for licensing terms.
 
-use criterion::{criterion_group, criterion_main, BatchSize, BenchmarkId, Criterion};
+use criterion::{BatchSize, BenchmarkId, Criterion, criterion_group, criterion_main};
 use rand::distributions::Alphanumeric;
 use rand::{Rng, SeedableRng};
 use std::borrow::BorrowMut as _;

grpc-testtool/src/bin/process-server.rs

@@ -4,11 +4,11 @@
 use chrono::Local;
 use clap::Parser;
 use env_logger::Builder;
-use log::{info, LevelFilter};
+use log::{LevelFilter, info};
+use rpc::DatabaseService;
 use rpc::process_server::process_server_service_server::ProcessServerServiceServer;
 use rpc::rpcdb::database_server::DatabaseServer as RpcServer;
 use rpc::sync::db_server::DbServer as SyncServer;
-use rpc::DatabaseService;
 use serde::Deserialize;
 use std::error::Error;
 use std::io::Write;

grpc-testtool/src/service.rs

@@ -7,8 +7,8 @@ use firewood::v2::api::{Db as _, Error};
 use std::collections::HashMap;
 use std::ops::Deref;
 use std::path::Path;
-use std::sync::atomic::{AtomicU64, Ordering};
 use std::sync::Arc;
+use std::sync::atomic::{AtomicU64, Ordering};
 use tokio::sync::Mutex;
 use tonic::Status;