minke.yu/sglang
1
0
Fork 0
Code Issues Pull Requests Actions 12 Packages Projects Releases Wiki Activity

Super tiny rename failure_count for consistency (#15186)

Browse Source
This commit is contained in:
fzyzcjy
2025-12-17 21:21:07 +08:00
committed by GitHub
parent 9d04b570bc
commit c4aed389da
1 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sgl-model-gateway/src/core/circuit_breaker.rs
+14 -14
View File
@@ -239,12 +239,12 @@ impl CircuitBreaker {
} }
/// Get the number of consecutive failures /// Get the number of consecutive failures
pub fn failure_count(&self) -> u32 { pub fn consecutive_failures(&self) -> u32 {
self.consecutive_failures.load(Ordering::Acquire) self.consecutive_failures.load(Ordering::Acquire)
} }
/// Get the number of consecutive successes /// Get the number of consecutive successes
pub fn success_count(&self) -> u32 { pub fn consecutive_successes(&self) -> u32 {
self.consecutive_successes.load(Ordering::Acquire) self.consecutive_successes.load(Ordering::Acquire)
} }
@@ -304,8 +304,8 @@ impl CircuitBreaker {
pub fn stats(&self) -> CircuitBreakerStats { pub fn stats(&self) -> CircuitBreakerStats {
CircuitBreakerStats { CircuitBreakerStats {
state: self.state(), state: self.state(),
consecutive_failures: self.failure_count(), consecutive_failures: self.consecutive_failures(),
consecutive_successes: self.success_count(), consecutive_successes: self.consecutive_successes(),
total_failures: self.total_failures(), total_failures: self.total_failures(),
total_successes: self.total_successes(), total_successes: self.total_successes(),
time_since_last_failure: self.time_since_last_failure(), time_since_last_failure: self.time_since_last_failure(),
@@ -364,8 +364,8 @@ mod tests {
let cb = CircuitBreaker::new(); let cb = CircuitBreaker::new();
assert_eq!(cb.state(), CircuitState::Closed); assert_eq!(cb.state(), CircuitState::Closed);
assert!(cb.can_execute()); assert!(cb.can_execute());
assert_eq!(cb.failure_count(), 0); assert_eq!(cb.consecutive_failures(), 0);
assert_eq!(cb.success_count(), 0); assert_eq!(cb.consecutive_successes(), 0);
} }
#[test] #[test]
@@ -385,7 +385,7 @@ mod tests {
assert_eq!(cb.state(), CircuitState::Open); assert_eq!(cb.state(), CircuitState::Open);
assert!(!cb.can_execute()); assert!(!cb.can_execute());
assert_eq!(cb.failure_count(), 3); assert_eq!(cb.consecutive_failures(), 3);
} }
#[test] #[test]
@@ -461,11 +461,11 @@ mod tests {
cb.record_failure(); cb.record_failure();
cb.record_failure(); cb.record_failure();
assert_eq!(cb.failure_count(), 2); assert_eq!(cb.consecutive_failures(), 2);
cb.record_success(); cb.record_success();
assert_eq!(cb.failure_count(), 0); assert_eq!(cb.consecutive_failures(), 0);
assert_eq!(cb.success_count(), 1); assert_eq!(cb.consecutive_successes(), 1);
cb.record_failure(); cb.record_failure();
cb.record_failure(); cb.record_failure();
@@ -485,8 +485,8 @@ mod tests {
cb.reset(); cb.reset();
assert_eq!(cb.state(), CircuitState::Closed); assert_eq!(cb.state(), CircuitState::Closed);
assert_eq!(cb.failure_count(), 0); assert_eq!(cb.consecutive_failures(), 0);
assert_eq!(cb.success_count(), 0); assert_eq!(cb.consecutive_successes(), 0);
} }
#[test] #[test]
@@ -525,10 +525,10 @@ mod tests {
cb1.record_failure(); cb1.record_failure();
let cb2 = cb1.clone(); let cb2 = cb1.clone();
assert_eq!(cb2.failure_count(), 1); assert_eq!(cb2.consecutive_failures(), 1);
cb1.record_failure(); cb1.record_failure();
assert_eq!(cb2.failure_count(), 2); assert_eq!(cb2.consecutive_failures(), 2);
} }
#[test] #[test]