- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 195 for transitionTo (0.24 sec)
-
src/main/java/jcifs/util/SmbCircuitBreaker.java
log.info("[{}] Manually resetting circuit breaker to CLOSED", name); transitionTo(State.CLOSED); } /** * Manually trip the circuit breaker to open state */ public void trip() { log.info("[{}] Manually tripping circuit breaker to OPEN", name); transitionTo(State.OPEN); } /** * Get current failure threshold (may be dynamically adjusted)
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 33.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* Called when the service transitions to the {@linkplain State#TERMINATED TERMINATED} state. * The {@linkplain State#TERMINATED TERMINATED} state is a terminal state in the transition * diagram. Therefore, if this method is called, no other methods will be called on the {@link * Listener}. * * @param from The previous state that is being transitioned from. Failure can occur in any
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 10.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Service.java
* Called when the service transitions to the {@linkplain State#TERMINATED TERMINATED} state. * The {@linkplain State#TERMINATED TERMINATED} state is a terminal state in the transition * diagram. Therefore, if this method is called, no other methods will be called on the {@link * Listener}. * * @param from The previous state that is being transitioned from. Failure can occur in any
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 12.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 33.2K bytes - Viewed (0) -
src/test/java/jcifs/util/SmbCircuitBreakerTest.java
// Test max attempts in half-open with failure scenario circuitBreaker.trip(); // Open again Thread.sleep(1100); // Wait for reset // First attempt transitions to HALF_OPEN try { circuitBreaker.executeWithCircuitBreaker(() -> { // Verify we're in HALF_OPEN assertEquals(State.HALF_OPEN, circuitBreaker.getState());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 23.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
} /** Transition to the COMPLETED state and set the value. */ boolean set(@Nullable V v) { return complete(v, null, COMPLETED); } /** Transition to the COMPLETED state and set the exception. */ boolean setException(Throwable t) { return complete(null, t, COMPLETED); } /** Transition to the CANCELLED or INTERRUPTED state. */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jan 30 16:59:10 UTC 2025 - 13.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
// This means that the state has changed since we were scheduled. This implies // that an execution of runOneIteration has thrown an exception and we have // transitioned to a failed state, also this means that shutDown has already // been called, so we do not want to call it again. return; } shutDown();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.7K bytes - Viewed (0) -
guava/src/com/google/common/net/InetAddresses.java
* * @param hextets {@code int[]} array of eight 16-bit hextets, or -1s */ private static String hextetsToIPv6String(int[] hextets) { // While scanning the array, handle these state transitions: // start->num => "num" start->gap => "::" // num->num => ":num" num->gap => "::" // gap->num => "num" gap->gap => "" StringBuilder buf = new StringBuilder(39);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 47.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractService.java
} @Override public boolean isSatisfied() { return state().compareTo(TERMINATED) >= 0; } } /** The listeners to notify during a state transition. */ private final ListenerCallQueue<Listener> listeners = new ListenerCallQueue<>(); /** * The current state of the service. This should be written with the lock held but can be read
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
// This means that the state has changed since we were scheduled. This implies // that an execution of runOneIteration has thrown an exception and we have // transitioned to a failed state, also this means that shutDown has already // been called, so we do not want to call it again. return; } shutDown();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0)