Fixed the shutdown warning

src/engine/io/file_manager.rs

@@ -116,7 +116,7 @@ impl FileManager {
 
 impl Drop for FileManager {
     fn drop(&mut self) {
-        if !self.request_queue.is_closed() {
+        if self.request_queue.is_closed() {
             return;
         }
         error!("File Manager wasn't shutdown cleanly! This is a bug, please report!");

src/engine/io/file_manager/file_executor.rs

@@ -6,6 +6,7 @@ use crate::constants::PAGE_SIZE;
 use crate::engine::io::file_manager::ResourceFormatter;
 use crate::engine::io::page_formats::{PageId, PageOffset};
 use bytes::{Bytes, BytesMut};
+use futures::SinkExt;
 use lru::LruCache;
 use std::collections::{HashMap, VecDeque};
 use std::convert::TryFrom;
@@ -112,7 +113,7 @@ impl FileExecutor {
                     if let Some(sender) = shut_sender {
                         shutdown_sender = Some(sender);
                         self.receive_queue.close();
-                        info!("Got shutdown request");
+                        debug!("File Executor: Got shutdown request");
                     } else {}
                 }
                 recv_completed = receive_completed.recv() => {
@@ -125,9 +126,7 @@ impl FileExecutor {
                                 file_handles_open = file_handles_open.saturating_sub(1);
                             }
                         }
-                    } else {
-                        break;
-                    }
+                    } else {}
                 }
                 maybe_recv = self.receive_queue.recv(), if request_queue.len() < MAX_FILE_HANDLE_COUNT => {
                     if let Some((page_id, req_type)) = maybe_recv {

src/feophant.rs

@@ -106,7 +106,7 @@ impl FeOphant {
 
         //Clean up
         match self.file_manager.shutdown().await {
-            Ok(_) => {}
+            Ok(_) => info!("File Manager shutdown!"),
             Err(e) => error!("Had an error shutting down I/O {0}", e),
         }