Delete dead code

src/rpu.rs

@@ -31,7 +31,7 @@ impl Rpu {
         }
     }
 
-    pub fn write_service<W: Write + Send + 'static>(
+    fn write_service<W: Write + Send + 'static>(
         accounting_stage: Arc<AccountingStage>,
         request_processor: Arc<RequestProcessor>,
         exit: Arc<AtomicBool>,
@@ -49,23 +49,6 @@ impl Rpu {
         })
     }
 
-    pub fn drain_service(
-        accounting_stage: Arc<AccountingStage>,
-        request_processor: Arc<RequestProcessor>,
-        exit: Arc<AtomicBool>,
-    ) -> JoinHandle<()> {
-        spawn(move || {
-            let entry_writer = EntryWriter::new(&accounting_stage, &request_processor);
-            loop {
-                let _ = entry_writer.drain_entries();
-                if exit.load(Ordering::Relaxed) {
-                    info!("drain_service exiting");
-                    break;
-                }
-            }
-        })
-    }
-
     /// Create a UDP microservice that forwards messages the given Rpu.
     /// This service is the network leader
     /// Set `exit` to shutdown its threads.

src/tvu.rs

@@ -32,7 +32,7 @@ impl Tvu {
         }
     }
 
-    pub fn drain_service(
+    fn drain_service(
         accounting_stage: Arc<AccountingStage>,
         request_processor: Arc<RequestProcessor>,
         exit: Arc<AtomicBool>,