Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 43 for Lock (0.14 sec)

  1. docs/changelogs/changelog_4x.md

        impacts VM-wide behavior.
    
     *  New: Reduce contention for applications that make a very high number of concurrent requests.
        Previously OkHttp used its connection pool as a lock when making changes to connections and
        calls. With this change each connection is locked independently.
    
     *  Upgrade: [Okio 2.7.0][okio_2_7_0].
    
        ```kotlin
        implementation("com.squareup.okio:okio:2.7.0")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

      outFinished: Boolean,
      inFinished: Boolean,
      headers: Headers?,
    ) {
      internal val lock: ReentrantLock = ReentrantLock()
      val condition: Condition = lock.newCondition()
    
      // Internal state is guarded by [lock]. No long-running or potentially blocking operations are
      // performed while the lock is held.
    
      /** The bytes consumed and acknowledged by the stream. */
      val readBytes: WindowCounter = WindowCounter(id)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 23.2K bytes
    - Viewed (1)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt

      /** The timestamp of the last taken event, used to measure elapsed time between events. */
      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
       * Removes recorded events up to (and including) an event is found whose class equals [eventClass]
       * and returns it.
       */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 9K bytes
    - Viewed (1)
  4. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

        throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
      }
    }
    
    @Suppress("NOTHING_TO_INLINE")
    internal inline fun Any.assertThreadHoldsLock() {
      if (assertionsEnabled && !Thread.holdsLock(this)) {
        throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this")
      }
    }
    
    @Suppress("NOTHING_TO_INLINE")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 09 12:33:05 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        queue.schedule(
          object : Task("$okHttpName ConnectionPool connection opener") {
            override fun runOnce(): Long = openConnections(this@scheduleOpener)
          },
        )
      }
    
      /**
       * Holding the lock of the connection being added or removed when mutating this, and check its
       * [RealConnection.noNewExchanges] property. This defends against races where a connection is
       * simultaneously adopted and removed.
       */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 16.2K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/HttpUrlTest.kt

        //
        // HttpUrl is quite lenient with what characters it accepts. In particular, characters like '{'
        // and '"' are permitted but unlikely to occur in real-world URLs. Unfortunately we can't just
        // lock it down due to URL templating: "http://{env}.{dc}.example.com".
        UrlComponentEncodingTester.newInstance()
          .nonPrintableAscii(Encoding.FORBIDDEN)
          .nonAscii(Encoding.PUNYCODE)
          .override(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 67.9K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

    @Suppress("NAME_SHADOWING")
    class Http2Connection internal constructor(builder: Builder) : Closeable {
      internal val lock: ReentrantLock = ReentrantLock()
      internal val condition: Condition = lock.newCondition()
    
      // Internal state of this connection is guarded by 'lock'. No blocking operations may be
      // performed while holding this lock!
      //
      // Socket writes are guarded by frameWriter.
      //
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 32.6K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

     * executor, it should be able to run [the configured maximum][maxRequests] number of calls
     * concurrently.
     */
    class Dispatcher() {
      internal val lock: ReentrantLock = ReentrantLock()
    
      /**
       * The maximum number of requests to execute concurrently. Above this requests queue in memory,
       * waiting for the running calls to complete.
       *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 9K bytes
    - Viewed (0)
  9. mockwebserver/README.md

      server.shutdown();
    }
    ```
    
    Your unit tests might move the `server` into a field so you can shut it down
    from your test's `tearDown()`.
    
    ### API
    
    #### MockResponse
    
    Mock responses default to an empty response body and a `200` status code.
    You can set a custom body with a string, input stream or byte array. Also
    add headers with a fluent builder API.
    
    ```java
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Dec 17 15:34:10 GMT 2023
    - 5K bytes
    - Viewed (1)
  10. gradle/libs.versions.toml

    mockserver = { module = "org.testcontainers:mockserver", version.ref = "testcontainers" }
    mockserver-client = { module = "org.mock-server:mockserver-client-java-no-dependencies", version.ref = "mockserverClient" }
    nativeImageSvm = { module = "org.graalvm.nativeimage:svm", version.ref = "graalvm" }
    openjsse = "org.openjsse:openjsse:1.1.14"
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 22 19:34:32 GMT 2024
    - 7.2K bytes
    - Viewed (0)
Back to top