Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for lose (0.02 sec)

  1. docs/changelogs/changelog_3x.md

        `Cache.urls()` would prevent in-flight entries from being written.
    
    
    ## Version 3.14.3
    
    _2019-09-10_
    
     *  Fix: Don't lose HTTP/2 flow control bytes when incoming data races with a stream close. If this
        happened enough then eventually the connection would stall.
    
     *  Fix: Acknowledge and apply inbound HTTP/2 settings atomically. Previously we had a race where we
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java

            .testEquals();
      }
    
      private interface Loser<E extends Throwable> {
        void lose() throws E;
      }
    
      public <T extends Loser<AssertionError>> void testMethod_exceptionTypes()
          throws NoSuchMethodException {
        Method failMethod = Loser.class.getMethod("lose");
        Invokable<T, ?> invokable = new TypeToken<T>(getClass()) {}.method(failMethod);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:44:53 UTC 2025
    - 89K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

     *
     * ```java
     * client.connectionPool().evictAll();
     * ```
     *
     * If your client has a cache, call [close()][Cache.close]. Note that it is an error to create calls
     * against a cache that is closed, and doing so will cause the call to crash.
     *
     * ```java
     * client.cache().close();
     * ```
     *
     * OkHttp also uses daemon threads for HTTP/2 connections. These will exit automatically if they
     * remain idle.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 21:55:03 UTC 2025
    - 51.4K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

              .url(server.url("/"))
              .build(),
          ).execute()
          .close()
        eventRecorder.removeUpToEvent<CallEnd>()
        val call =
          client.newCallWithListener(
            Request
              .Builder()
              .url(server.url("/"))
              .build(),
          )
        val response = call.execute()
        response.close()
        assertThat(eventRecorder.recordedEventTypes()).containsExactly(
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 70.5K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt

        createNewCache()
      }
    
      @AfterEach fun tearDown() {
        while (!toClose.isEmpty()) {
          toClose.pop().close()
        }
        taskFaker.close()
    
        (filesystem.delegate as? FakeFileSystem)?.checkNoOpenFiles()
      }
    
      @Test
      fun emptyCache() {
        cache.close()
        assertJournalEquals()
      }
    
      @Test
      fun recoverFromInitializationFailure() {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 59.4K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbSessionImpl.java

            } finally {
                super.finalize();
            }
        }
    
        /**
         * {@inheritDoc}
         *
         * @see java.lang.AutoCloseable#close()
         */
        @Override
        public void close() {
            release();
        }
    
        /**
         *
         */
        public void release() {
            long usage = this.usageCount.decrementAndGet();
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 68.9K bytes
    - Viewed (0)
  7. src/test/java/jcifs/smb/SmbFileIntegrationTest.java

            SmbFile targetFile = new SmbFile(baseUrl + "shared/" + targetFileName, renameContext);
    
            // Copy content to new file
            srcForCopy.copyTo(targetFile);
            srcForCopy.close();
            targetFile.close();
    
            // Wait before delete
            Thread.sleep(500);
            System.gc();
            Thread.sleep(200);
    
            // Delete original using fresh context
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 56K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

        logger.get().log(FINER, "cancelling {0}", this);
        boolean cancelled = future.cancel(mayInterruptIfRunning);
        if (cancelled) {
          close();
        }
        return cancelled;
      }
    
      private void close() {
        logger.get().log(FINER, "closing {0}", this);
        closeables.close();
      }
    
      private <U extends @Nullable Object> ClosingFuture<U> derive(FluentFuture<U> future) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 13:51:27 UTC 2025
    - 96.9K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        assertThat(c0e0.exchangeIndex).isEqualTo(0)
        val c0e1 = server.takeRequest()
        assertThat(c0e1.connectionIndex).isEqualTo(0)
        assertThat(c0e1.exchangeIndex).isEqualTo(1)
        response1.close()
        response2.close()
      }
    
      @Test
      fun connectionWindowUpdateAfterCanceling() {
        server.enqueue(
          MockResponse
            .Builder()
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 67.4K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

    @Timeout(5)
    @Tag("Slow")
    class Http2ConnectionTest {
      private val peer = MockHttp2Peer()
      private val taskFaker = TaskFaker()
    
      @AfterEach fun tearDown() {
        peer.close()
        taskFaker.close()
      }
    
      @Test fun serverPingsClientHttp2() {
        // Write the mocking script.
        peer.sendFrame().settings(Settings())
        peer.acceptFrame() // ACK
        peer.sendFrame().ping(false, 2, 3)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
Back to top