- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 349 for Stopping (0.19 sec)
-
testing/internal-integ-testing/src/main/groovy/org/bbottema/javasocksproxyserver/TestRecordingSocksServer.java
} public synchronized void start(int listenPort, ServerSocketFactory serverSocketFactory) { this.stopping = false; new Thread(new ServerProcess(listenPort, serverSocketFactory)).start(); } public synchronized void stop() { stopping = true; } private class ServerProcess implements Runnable { protected final int port;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Service.java
* Called when the service transitions to the {@linkplain State#STOPPING STOPPING} state. The * only valid values for {@code from} are {@linkplain State#STARTING STARTING} or {@linkplain * State#RUNNING RUNNING}. This occurs when {@link Service#stopAsync} is called. * * @param from The previous state that is being transitioned from. */ public void stopping(State from) {} /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 12.1K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerDaemonClientsManager.java
if (candidate.getLogLevel() != currentLogLevel) { // TODO: Send a message to workers to change their log level rather than stopping LOGGER.info("Log level has changed, stopping idle worker daemon with out-of-date log level."); candidate.stop(); } else { return candidate;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 19:54:37 UTC 2024 - 10K bytes - Viewed (0) -
pkg/test/loadbalancersim/timer/queue.go
package timer import ( "container/heap" "sync" "time" ) type Queue struct { heap timerHeap mutex sync.Mutex stopCh chan struct{} resetTimerCh chan struct{} stopping bool timer *time.Timer currentDeadline time.Time } func NewQueue() *Queue { q := &Queue{ heap: make(timerHeap, 0), timer: time.NewTimer(1 * time.Minute),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 19:13:32 UTC 2023 - 3.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java
* blocks, it can prevent this service from changing state. If you need to performing a blocking * operation in order to trigger shutdown, consider instead registering a listener and * implementing {@code stopping}. Note, however, that {@code stopping} does not run at exactly the * same times as {@code triggerShutdown}. */ protected void triggerShutdown() {} /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 13 19:45:20 UTC 2023 - 7.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractIdleServiceTest.java
assertEquals(1, service.shutDownCalled); assertEquals(Service.State.TERMINATED, service.state()); assertThat(service.transitionStates) .containsExactly(Service.State.STARTING, Service.State.STOPPING) .inOrder(); } public void testStop_failed() { final Exception exception = new Exception("deliberate"); TestService service = new TestService() { @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* Called when the service transitions to the {@linkplain State#STOPPING STOPPING} state. The * only valid values for {@code from} are {@linkplain State#STARTING STARTING} or {@linkplain * State#RUNNING RUNNING}. This occurs when {@link Service#stopAsync} is called. * * @param from The previous state that is being transitioned from. */ public void stopping(State from) {} /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 10.7K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandlerTest.groovy
1 * lockRequestListener.stop() 1 * releaseLockActionExecutor.stop() } def "stopping is safe even if the handler was not initialized"() { when: handler.stop() then: noExceptionThrown() } def "stopping is safe even if the executor was not initialized"() { handler.reservePort() when: handler.stop()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/test/framework/components/echo/util/traffic/generator.go
Options echo.CallOptions // Interval between successive call operations. If not set, defaults to 1 second. Interval time.Duration // Maximum time to wait for traffic to complete after stopping. If not set, defaults to 15 seconds. StopTimeout time.Duration } // Generator of traffic between echo instances. Every time interval // (as defined by Config.Interval), a grpc request is sent to the source pod,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 12 22:50:35 UTC 2022 - 3.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
assertFalse(service.startUpCalled); service.startAsync().awaitRunning(); assertTrue(service.startUpCalled); assertEquals(Service.State.RUNNING, service.state()); enterRun.await(); // to avoid stopping the service until run() is invoked service.stopAsync().awaitTerminated(); assertTrue(service.shutDownCalled); assertEquals(Service.State.TERMINATED, service.state()); executionThread.join(); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 12.7K bytes - Viewed (0)