- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for withLock (0.07 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)