Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 283 for stripping (0.39 seconds)

  1. 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) {}
    
        /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 10.8K bytes
    - Click Count (0)
  2. 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() {
        Exception exception = new Exception("deliberate");
        TestService service =
            new TestService() {
              @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 7.7K bytes
    - Click Count (0)
  3. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Sep 04 17:02:39 GMT 2024
    - 3.2K bytes
    - Click Count (0)
  4. 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() {}
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 7.2K bytes
    - Click Count (0)
  5. scripts/tests/test_translation_fixer/test_code_blocks/test_code_blocks_mermaid.py

        expected_content = Path(
            f"{data_path}/translated_doc_mermaid_translated.md"
        ).read_text("utf-8")
    
        assert fixed_content == expected_content  # Translated doc remains unchanged
        assert (
            "Skipping mermaid code block replacement (lines 41-44). This should be checked manually."
        ) in result.output
    
    
    @pytest.mark.parametrize(
        "copy_test_files",
        [
            (
                f"{data_path}/en_doc.md",
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sat Jan 10 22:43:44 GMT 2026
    - 1.8K bytes
    - Click Count (0)
  6. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackRoundTripTest.kt

    import okio.Buffer
    import org.junit.jupiter.api.Assumptions.assumeFalse
    import org.junit.jupiter.params.ParameterizedTest
    import org.junit.jupiter.params.provider.ArgumentsSource
    
    /**
     * Tests for round-tripping headers through hpack.
     *
     * TODO: update hpack-test-case with the output of our encoder.
     * This test will hide complementary bugs in the encoder and decoder,
     * We should test that the encoder is producing responses that are
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2K bytes
    - Click Count (0)
  7. src/main/webapp/WEB-INF/web.xml

      <jsp-config>
        <jsp-property-group>
          <url-pattern>*.jsp</url-pattern>
          <el-ignored>false</el-ignored>
          <page-encoding>UTF-8</page-encoding>
          <scripting-invalid>false</scripting-invalid>
          <include-prelude>/WEB-INF/view/common/common.jsp</include-prelude>
        </jsp-property-group>
      </jsp-config>
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 21 09:08:35 GMT 2026
    - 8.5K bytes
    - Click Count (0)
  8. 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();
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 12.8K bytes
    - Click Count (0)
  9. 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() {
        Exception exception = new Exception("deliberate");
        TestService service =
            new TestService() {
              @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 7.7K bytes
    - Click Count (0)
  10. 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();
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 12.8K bytes
    - Click Count (0)
Back to Top