fmt

lolraft/src/generated/lolraft.rs

@@ -1,3 +1,4 @@
+// This file is @generated by prost-build.
 /// Update request to the `RaftApp`.
 /// This type of request is serialized in the log and processed sequentially.
 /// `request_id` is unique identifier of the request to avoid executing duplicating requests.

lolraft/src/process/mod.rs

@@ -17,8 +17,8 @@ mod command_log;
 use command_log::CommandLog;
 mod voter;
 use voter::Voter;
-mod query_queue;
 mod app;
+mod query_queue;
 use app::App;
 
 mod command;

lolraft/src/process/query_queue.rs

@@ -27,7 +27,10 @@ impl Processor {
     /// Register a query to be executed when the read index reaches `read_index`.
     /// `read_index` is the index of the commit pointer of when the query is submitted.
     pub fn process(&self, index: Index) -> usize {
-        let qs = self.inner.try_iter().take_while(|(read_index, _)| *read_index <= index);
+        let qs = self
+            .inner
+            .try_iter()
+            .take_while(|(read_index, _)| *read_index <= index);
 
         let mut n = 0;
         for (_, q) in qs {
@@ -38,7 +41,7 @@ impl Processor {
                 // which just results in failing on the client side.
                 if let Ok(resp) = app.process_read(&q.message).await {
                     q.user_completion.complete_with(resp).ok();
-                } 
+                }
             };
             tokio::spawn(fut);
         }
@@ -49,10 +52,7 @@ impl Processor {
 
 pub fn new(app: Ref<App>) -> (Producer, Processor) {
     let (tx, rx) = flume::unbounded();
-    let processor = Processor {
-        inner: rx,
-        app,
-    };
+    let processor = Processor { inner: rx, app };
     let producer = Producer { inner: tx };
     (producer, processor)
-}
+}

lolraft/src/process/thread/advance_user.rs

@@ -30,7 +30,12 @@ impl Thread {
     }
 }
 
-pub fn new(command_log: CommandLog, app: App, consumer: EventConsumer<KernEvent>, producer: EventProducer<ApplicationEvent>) -> ThreadHandle {
+pub fn new(
+    command_log: CommandLog,
+    app: App,
+    consumer: EventConsumer<KernEvent>,
+    producer: EventProducer<ApplicationEvent>,
+) -> ThreadHandle {
     Thread {
         command_log,
         app,

lolraft/src/process/thread/mod.rs

@@ -78,4 +78,4 @@ pub struct CommitEvent;
 pub struct KernEvent;
 
 #[derive(Clone)]
-pub struct ApplicationEvent;
+pub struct ApplicationEvent;

lolraft/src/process/thread/query_execution.rs

@@ -16,7 +16,9 @@ impl Thread {
     fn do_loop(self) -> ThreadHandle {
         let fut = async move {
             loop {
-                self.consumer.consume_events(Duration::from_millis(100)).await;
+                self.consumer
+                    .consume_events(Duration::from_millis(100))
+                    .await;
                 while self.advance_once().await {
                     tokio::task::yield_now().await;
                 }
@@ -27,7 +29,11 @@ impl Thread {
     }
 }
 
-pub fn new(query_queue: query_queue::Processor, command_log: Ref<CommandLog>, consumer: EventConsumer<ApplicationEvent>) -> ThreadHandle {
+pub fn new(
+    query_queue: query_queue::Processor,
+    command_log: Ref<CommandLog>,
+    consumer: EventConsumer<ApplicationEvent>,
+) -> ThreadHandle {
     Thread {
         query_queue,
         command_log,

tests/lol-tests/benches/query.rs

@@ -31,7 +31,7 @@ fn do_bench(m: u16, b: &mut test::Bencher) {
 
     rt.block_on(async {
         drop(cluster);
-   });
+    });
 }
 
 #[bench]
@@ -49,4 +49,4 @@ fn query_100(b: &mut test::Bencher) {
 #[bench]
 fn query_1000(b: &mut test::Bencher) {
     do_bench(1000, b);
-}
+}