Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 283 for stopping (0.08 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/ServiceTest.java

        assertLessThan(NEW, TERMINATED);
    
        assertLessThan(STARTING, RUNNING);
        assertLessThan(STARTING, STOPPING);
        assertLessThan(STARTING, FAILED);
    
        assertLessThan(RUNNING, STOPPING);
        assertLessThan(RUNNING, FAILED);
    
        assertLessThan(STOPPING, FAILED);
        assertLessThan(STOPPING, TERMINATED);
      }
    
      private static <T extends Comparable<? super T>> void assertLessThan(T a, T b) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 1.9K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/ServiceTest.java

        assertLessThan(NEW, TERMINATED);
    
        assertLessThan(STARTING, RUNNING);
        assertLessThan(STARTING, STOPPING);
        assertLessThan(STARTING, FAILED);
    
        assertLessThan(RUNNING, STOPPING);
        assertLessThan(RUNNING, FAILED);
    
        assertLessThan(STOPPING, FAILED);
        assertLessThan(STOPPING, TERMINATED);
      }
    
      private static <T extends Comparable<? super T>> void assertLessThan(T a, T b) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 1.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractService.java

        return new ListenerCallQueue.Event<Listener>() {
          @Override
          public void call(Listener listener) {
            listener.stopping(from);
          }
    
          @Override
          public String toString() {
            return "stopping({from = " + from + "})";
          }
        };
      }
    
      private final Monitor monitor = new Monitor();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/AbstractService.java

        return new ListenerCallQueue.Event<Listener>() {
          @Override
          public void call(Listener listener) {
            listener.stopping(from);
          }
    
          @Override
          public String toString() {
            return "stopping({from = " + from + "})";
          }
        };
      }
    
      private final Monitor monitor = new Monitor();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  5. 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: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  6. 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: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 10.7K bytes
    - Viewed (0)
  7. android/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: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  8. android/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: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  9. cmd/signals.go

    			p.Stop()
    		}
    
    		if success {
    			os.Exit(0)
    		}
    
    		os.Exit(1)
    	}
    
    	stopProcess := func() bool {
    		shutdownHealMRFWithTimeout() // this can take time sometimes, it needs to be executed
    		// before stopping s3 operations
    
    		// send signal to various go-routines that they need to quit.
    		cancelGlobalContext()
    
    		if httpServer := newHTTPServerFn(); httpServer != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 04 17:02:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  10. 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: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
Back to top