rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2025-12-25 23:49:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: reduce execution time of test test_suspend_frontend (#7444)

Browse Source 
Signed-off-by: luofucong <luofc@foxmail.com>
This commit is contained in:
LFC
2025-12-19 15:25:36 +08:00
committed by GitHub
parent 4d66bd96b8
commit 6332d91884
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/frontend/src/frontend.rs
View File

@@ -142,6 +142,7 @@ impl Frontend {
#[cfg(test)] #[cfg(test)]
mod tests { mod tests {
use std::sync::atomic::{AtomicBool, Ordering}; use std::sync::atomic::{AtomicBool, Ordering};
use std::time::Duration;
use api::v1::meta::heartbeat_server::HeartbeatServer; use api::v1::meta::heartbeat_server::HeartbeatServer;
use api::v1::meta::mailbox_message::Payload; use api::v1::meta::mailbox_message::Payload;
@@ -156,7 +157,6 @@ mod tests {
use common_error::from_header_to_err_code_msg; use common_error::from_header_to_err_code_msg;
use common_error::status_code::StatusCode; use common_error::status_code::StatusCode;
use common_grpc::channel_manager::ChannelManager; use common_grpc::channel_manager::ChannelManager;
use common_meta::distributed_time_constants::default_distributed_time_constants;
use common_meta::heartbeat::handler::HandlerGroupExecutor; use common_meta::heartbeat::handler::HandlerGroupExecutor;
use common_meta::heartbeat::handler::parse_mailbox_message::ParseMailboxMessageHandler; use common_meta::heartbeat::handler::parse_mailbox_message::ParseMailboxMessageHandler;
use common_meta::heartbeat::handler::suspend::SuspendHandler; use common_meta::heartbeat::handler::suspend::SuspendHandler;
@@ -399,6 +399,10 @@ mod tests {
..Default::default() ..Default::default()
}, },
meta_client: Some(meta_client_options.clone()), meta_client: Some(meta_client_options.clone()),
heartbeat: HeartbeatOptions {
interval: Duration::from_secs(1),
..Default::default()
},
..Default::default() ..Default::default()
}; };
@@ -408,8 +412,7 @@ mod tests {
let meta_client = create_meta_client(&meta_client_options, server.clone()).await; let meta_client = create_meta_client(&meta_client_options, server.clone()).await;
let frontend = create_frontend(&options, meta_client).await?; let frontend = create_frontend(&options, meta_client).await?;
let frontend_heartbeat_interval = let frontend_heartbeat_interval = options.heartbeat.interval;
default_distributed_time_constants().frontend_heartbeat_interval;
tokio::time::sleep(frontend_heartbeat_interval).await; tokio::time::sleep(frontend_heartbeat_interval).await;
// initial state: not suspend: // initial state: not suspend:
assert!(!frontend.instance.is_suspended()); assert!(!frontend.instance.is_suspended());