chore: refine start log (#12567)

Signed-off-by: MrCroxx <[email protected]>
risingwavelabs · Sep 27, 2023 · 491273d · 491273d
1 parent 6f9c5c2
commit 491273d
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 4 deletions.
diff --git a/src/compute/src/lib.rs b/src/compute/src/lib.rs
@@ -200,7 +200,6 @@ pub fn start(opts: ComputeNodeOpts) -> Pin<Box<dyn Future<Output = ()> + Send>>
         validate_opts(&opts);
 
         let listen_addr = opts.listen_addr.parse().unwrap();
-        tracing::info!("Server Listening at {}", listen_addr);
 
         let advertise_addr = opts
             .advertise_addr
@@ -216,6 +215,8 @@ pub fn start(opts: ComputeNodeOpts) -> Pin<Box<dyn Future<Output = ()> + Send>>
         let (join_handle_vec, _shutdown_send) =
             compute_node_serve(listen_addr, advertise_addr, opts).await;
 
+        tracing::info!("Server listening at {}", listen_addr);
+
         for join_handle in join_handle_vec {
             join_handle.await.unwrap();
         }

diff --git a/src/meta/src/lib.rs b/src/meta/src/lib.rs
@@ -246,7 +246,6 @@ pub fn start(opts: MetaNodeOpts) -> Pin<Box<dyn Future<Output = ()> + Send>> {
                     .collect()
             });
 
-        info!("Meta server listening at {}", listen_addr);
         let add_info = AddressInfo {
             advertise_addr: opts.advertise_addr,
             listen_addr,
@@ -319,6 +318,8 @@ pub fn start(opts: MetaNodeOpts) -> Pin<Box<dyn Future<Output = ()> + Send>> {
         .await
         .unwrap();
 
+        tracing::info!("Meta server listening at {}", listen_addr);
+
         match leader_lost_handle {
             None => {
                 tokio::select! {

diff --git a/src/storage/compactor/src/lib.rs b/src/storage/compactor/src/lib.rs
@@ -109,18 +109,18 @@ pub fn start(opts: CompactorOpts) -> Pin<Box<dyn Future<Output = ()> + Send>> {
             tracing::info!("Proxy rpc endpoint: {}", opts.proxy_rpc_endpoint.clone());
 
             let listen_addr = opts.listen_addr.parse().unwrap();
-            tracing::info!("Server Listening at {}", listen_addr);
 
             let (join_handle, _shutdown_sender) = shared_compactor_serve(listen_addr, opts).await;
 
+            tracing::info!("Server listening at {}", listen_addr);
+
             join_handle.await.unwrap();
         }),
         None | Some(CompactorMode::Dedicated) => Box::pin(async move {
             tracing::info!("Compactor node options: {:?}", opts);
             tracing::info!("meta address: {}", opts.meta_address.clone());
 
             let listen_addr = opts.listen_addr.parse().unwrap();
-            tracing::info!("Server Listening at {}", listen_addr);
 
             let advertise_addr = opts
                 .advertise_addr
@@ -135,6 +135,8 @@ pub fn start(opts: CompactorOpts) -> Pin<Box<dyn Future<Output = ()> + Send>> {
             let (join_handle, observer_join_handle, _shutdown_sender) =
                 compactor_serve(listen_addr, advertise_addr, opts).await;
 
+            tracing::info!("Server listening at {}", listen_addr);
+
             join_handle.await.unwrap();
             observer_join_handle.abort();
         }),