Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for withLock (0.07 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

      override fun noNewExchanges() {
        this.withLock {
          noNewExchanges = true
        }
        connectionListener.noNewExchanges(this)
      }
    
      /** Prevent this connection from being used for hosts other than the one in [route]. */
      internal fun noCoalescedConnections() {
        this.withLock {
          noCoalescedConnections = true
        }
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

    import okhttp3.FakeRoutePlanner
    import okhttp3.OkHttpClient
    import okhttp3.Request
    import okhttp3.TestUtil.awaitGarbageCollection
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.Locks.withLock
    import okhttp3.internal.http2.Http2
    import okhttp3.internal.http2.Http2Connection
    import okhttp3.internal.http2.Http2ConnectionTest
    import okhttp3.internal.http2.MockHttp2Peer
    import okhttp3.internal.http2.Settings
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jun 22 16:06:35 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

    import okhttp3.Route
    import okhttp3.internal.USER_AGENT
    import okhttp3.internal.canReuseConnectionFor
    import okhttp3.internal.closeQuietly
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.Locks.withLock
    import okhttp3.internal.connection.RoutePlanner.Plan
    import okhttp3.internal.platform.Platform
    import okhttp3.internal.toHostHeader
    
    class RealRoutePlanner(
      private val taskRunner: TaskRunner,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 12K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.CallConnectionUser
    import okhttp3.internal.connection.FastFallbackExchangeFinder
    import okhttp3.internal.connection.Locks.withLock
    import okhttp3.internal.connection.RealCall
    import okhttp3.internal.connection.RealConnection
    import okhttp3.internal.connection.RealConnectionPool
    import okhttp3.internal.connection.RealRoutePlanner
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

    import javax.net.ssl.SSLSocket
    import kotlin.concurrent.withLock
    import okhttp3.CertificatePinner
    import okhttp3.ConnectionSpec
    import okhttp3.Handshake
    import okhttp3.Handshake.Companion.handshake
    import okhttp3.Protocol
    import okhttp3.Request
    import okhttp3.Route
    import okhttp3.internal.closeQuietly
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.Locks.withLock
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  6. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

    import java.util.logging.Handler
    import java.util.logging.Level
    import java.util.logging.LogManager
    import java.util.logging.LogRecord
    import java.util.logging.Logger
    import kotlin.concurrent.withLock
    import okhttp3.internal.buildConnectionPool
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.RealConnectionPool
    import okhttp3.internal.http2.Http2
    import okhttp3.internal.taskRunnerInternal
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

    import okhttp3.internal.EMPTY_BYTE_ARRAY
    import okhttp3.internal.EMPTY_HEADERS
    import okhttp3.internal.concurrent.TaskFaker
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.Locks.withLock
    import okhttp3.internal.notifyAll
    import okhttp3.internal.wait
    import okio.AsyncTimeout
    import okio.Buffer
    import okio.BufferedSource
    import okio.Source
    import okio.buffer
    import org.junit.jupiter.api.AfterEach
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  8. common/config/.golangci.yml

        - linters:
            - staticcheck
          text: 'SA1019: grpc.DialContext is deprecated: use NewClient instead'
        - linters:
            - staticcheck
          text: "SA1019: grpc.WithBlock is deprecated"
        - linters:
            - staticcheck
          text: "SA1019: grpc.FailOnNonTempDialError"
        - linters:
            - staticcheck
          text: "SA1019: grpc.WithReturnConnectionError"
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  9. test-site/activator-launch-1.3.2.jar

    void ResolveValues$$anonfun$resolve$1(Implicit); } xsbt/boot/Locks$GlobalLock.class package xsbt.boot; public final synchronized class Locks$GlobalLock { private final java.io.File file; private boolean fileLocked; public final synchronized Object withLock(java.util.concurrent.Callable); private Object ignoringDeadlockAvoi(java.util.concurrent.Callable); public final Object xsbt$boot$Locks$GlobalLock$$withChannelRetries$1(int, java.nio.channels.FileChannel, java.util.concurrent.Callable); private final...
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Mon Apr 20 08:41:37 UTC 2015
    - 1.2M bytes
    - Viewed (0)
Back to top