remove SHUTDOWN global

sqld/src/lib.rs

@@ -52,8 +52,6 @@ type Result<T> = std::result::Result<T, Error>;
 ///
 /// /!\ use with caution.
 pub(crate) static HARD_RESET: Lazy<Arc<Notify>> = Lazy::new(|| Arc::new(Notify::new()));
-/// Clean shutdown of the server.
-pub(crate) static SHUTDOWN: Lazy<Arc<Notify>> = Lazy::new(|| Arc::new(Notify::new()));
 
 #[cfg(feature = "mwal_backend")]
 pub(crate) static VWAL_METHODS: OnceCell<
@@ -239,9 +237,10 @@ pub async fn run_server(config: Config) -> anyhow::Result<()> {
         }
         let mut join_set = JoinSet::new();
 
+        let shutdown_notify: Arc<Notify> = Arc::new(Notify::new());
         let idle_shutdown_layer = config
             .idle_shutdown_timeout
-            .map(|d| IdleShutdownLayer::new(d, SHUTDOWN.clone()));
+            .map(|d| IdleShutdownLayer::new(d, shutdown_notify.clone()));
 
         match config.writer_rpc_addr {
             Some(ref addr) => {
@@ -251,14 +250,13 @@ pub async fn run_server(config: Config) -> anyhow::Result<()> {
         }
 
         let reset = HARD_RESET.clone();
-        let shutdown = SHUTDOWN.clone();
         loop {
             tokio::select! {
                 _ = reset.notified() => {
                     hard_reset(&config, join_set).await?;
                     break;
                 },
-                _ = shutdown.notified() => {
+                _ = shutdown_notify.notified() => {
                     return Ok(())
                 }
                 Some(res) = join_set.join_next() => {

sqld/src/rpc/mod.rs

@@ -15,6 +15,7 @@ use crate::utils::services::idle_shutdown::IdleShutdownLayer;
 pub mod proxy;
 pub mod replication_log;
 
+#[allow(clippy::too_many_arguments)]
 pub async fn run_rpc_server(
     addr: SocketAddr,
     tls: bool,