mirror of
https://github.com/pjh456/OxideJS.git
synced 2026-10-27 04:01:11 +08:00
style: 自动格式化
This commit is contained in:
@@ -1388,7 +1388,8 @@ mod tests {
|
|||||||
|
|
||||||
let config = ServerConfig {
|
let config = ServerConfig {
|
||||||
endpoint: Endpoint::Tcp(addr),
|
endpoint: Endpoint::Tcp(addr),
|
||||||
sidecar_path: std::env::temp_dir().join(format!("oxide_server_tcp_yield_{}_sidecar.json", std::process::id())),
|
sidecar_path: std::env::temp_dir()
|
||||||
|
.join(format!("oxide_server_tcp_yield_{}_sidecar.json", std::process::id())),
|
||||||
worker_count: 2,
|
worker_count: 2,
|
||||||
version: env!("CARGO_PKG_VERSION").to_string(),
|
version: env!("CARGO_PKG_VERSION").to_string(),
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -189,7 +189,10 @@ fn server_start_e2e() {
|
|||||||
let sidecar_path = sidecar::well_known_sidecar_path();
|
let sidecar_path = sidecar::well_known_sidecar_path();
|
||||||
|
|
||||||
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
||||||
assert!(!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())), "存活 server 占用 well-known 路径,测试不抢占");
|
assert!(
|
||||||
|
!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())),
|
||||||
|
"存活 server 占用 well-known 路径,测试不抢占"
|
||||||
|
);
|
||||||
|
|
||||||
// start 为守护形态:CLI 即刻返回,server 是脱离的孙进程;worker 数压到 2
|
// start 为守护形态:CLI 即刻返回,server 是脱离的孙进程;worker 数压到 2
|
||||||
// 避免按宿主核数预热的成本。
|
// 避免按宿主核数预热的成本。
|
||||||
@@ -238,7 +241,10 @@ fn server_start_when_running() {
|
|||||||
let sidecar_path = sidecar::well_known_sidecar_path();
|
let sidecar_path = sidecar::well_known_sidecar_path();
|
||||||
|
|
||||||
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
||||||
assert!(!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())), "存活 server 占用 well-known 路径,测试不抢占");
|
assert!(
|
||||||
|
!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())),
|
||||||
|
"存活 server 占用 well-known 路径,测试不抢占"
|
||||||
|
);
|
||||||
|
|
||||||
// 首次 start:CLI 即刻返回,server 是脱离的孙进程。
|
// 首次 start:CLI 即刻返回,server 是脱离的孙进程。
|
||||||
let output = oxide(&["server", "start", "--workers", "2"]);
|
let output = oxide(&["server", "start", "--workers", "2"]);
|
||||||
@@ -276,7 +282,10 @@ fn server_restart_e2e() {
|
|||||||
let sidecar_path = sidecar::well_known_sidecar_path();
|
let sidecar_path = sidecar::well_known_sidecar_path();
|
||||||
|
|
||||||
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
||||||
assert!(!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())), "存活 server 占用 well-known 路径,测试不抢占");
|
assert!(
|
||||||
|
!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())),
|
||||||
|
"存活 server 占用 well-known 路径,测试不抢占"
|
||||||
|
);
|
||||||
|
|
||||||
// 起子进程 A:worker 数压到 2,轮询 socket 文件出现(10 秒截止)判就绪。
|
// 起子进程 A:worker 数压到 2,轮询 socket 文件出现(10 秒截止)判就绪。
|
||||||
let mut child = Command::new(env!("CARGO_BIN_EXE_oxide"))
|
let mut child = Command::new(env!("CARGO_BIN_EXE_oxide"))
|
||||||
@@ -357,7 +366,10 @@ fn server_log_e2e() {
|
|||||||
let log_path = sidecar::well_known_log_path();
|
let log_path = sidecar::well_known_log_path();
|
||||||
|
|
||||||
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
||||||
assert!(!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())), "存活 server 占用 well-known 路径,测试不抢占");
|
assert!(
|
||||||
|
!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())),
|
||||||
|
"存活 server 占用 well-known 路径,测试不抢占"
|
||||||
|
);
|
||||||
|
|
||||||
// 删旧日志文件:server 即将全新启动,内容断言不受历史污染。
|
// 删旧日志文件:server 即将全新启动,内容断言不受历史污染。
|
||||||
let _ = std::fs::remove_file(&log_path);
|
let _ = std::fs::remove_file(&log_path);
|
||||||
@@ -437,7 +449,10 @@ fn server_forge_e2e() {
|
|||||||
let sidecar_path = sidecar::well_known_sidecar_path();
|
let sidecar_path = sidecar::well_known_sidecar_path();
|
||||||
|
|
||||||
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
||||||
assert!(!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())), "存活 server 占用 well-known 路径,测试不抢占");
|
assert!(
|
||||||
|
!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())),
|
||||||
|
"存活 server 占用 well-known 路径,测试不抢占"
|
||||||
|
);
|
||||||
|
|
||||||
// start 为守护形态:CLI 即刻返回,server 是脱离的孙进程;轮询 socket 文件
|
// start 为守护形态:CLI 即刻返回,server 是脱离的孙进程;轮询 socket 文件
|
||||||
// 出现判就绪(worker 数压到 2 避免按宿主核数预热的成本)。
|
// 出现判就绪(worker 数压到 2 避免按宿主核数预热的成本)。
|
||||||
@@ -496,7 +511,10 @@ fn server_watchdog_e2e() {
|
|||||||
let sidecar_path = sidecar::well_known_sidecar_path();
|
let sidecar_path = sidecar::well_known_sidecar_path();
|
||||||
|
|
||||||
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
||||||
assert!(!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())), "存活 server 占用 well-known 路径,测试不抢占");
|
assert!(
|
||||||
|
!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())),
|
||||||
|
"存活 server 占用 well-known 路径,测试不抢占"
|
||||||
|
);
|
||||||
|
|
||||||
// 拉起 watchdog 前台进程(stdout 管道捕获崩溃诊断输出)。
|
// 拉起 watchdog 前台进程(stdout 管道捕获崩溃诊断输出)。
|
||||||
let mut child = Command::new(env!("CARGO_BIN_EXE_oxide"))
|
let mut child = Command::new(env!("CARGO_BIN_EXE_oxide"))
|
||||||
@@ -599,7 +617,10 @@ fn server_watchdog_sigint_stops_server() {
|
|||||||
let sidecar_path = sidecar::well_known_sidecar_path();
|
let sidecar_path = sidecar::well_known_sidecar_path();
|
||||||
|
|
||||||
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
// 探活先行:存活 server 占用全局路径时 panic,不抢占。
|
||||||
assert!(!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())), "存活 server 占用 well-known 路径,测试不抢占");
|
assert!(
|
||||||
|
!sidecar::is_server_alive(&Endpoint::Unix(socket.clone())),
|
||||||
|
"存活 server 占用 well-known 路径,测试不抢占"
|
||||||
|
);
|
||||||
|
|
||||||
// 拉起 watchdog 前台进程。
|
// 拉起 watchdog 前台进程。
|
||||||
let mut child = Command::new(env!("CARGO_BIN_EXE_oxide"))
|
let mut child = Command::new(env!("CARGO_BIN_EXE_oxide"))
|
||||||
|
|||||||
Reference in New Issue
Block a user