- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for Lock (0.15 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
} private fun logEvent(e: ConnectionEvent) { if (e.connection != null) { assertThat(Thread.holdsLock(e.connection), "Called with lock $${e.connection}") .isFalse() } for (lock in forbiddenLocks) { assertThat(Thread.holdsLock(lock), "Called with lock $lock") .isFalse() } if (enforceOrder) { checkForStartEvent(e) } eventSequence.offer(e) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
docs/contribute/concurrency.md
### Locks We have 3 different things that we synchronize on. #### Http2Connection This lock guards internal state of each connection. This lock is never held for blocking operations. That means that we acquire the lock, read or write a few fields and release the lock. No I/O and no application-layer callbacks. #### Http2Stream
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
* be removed from the execution schedule. */ fun cancelAll() { lock.assertNotHeld() taskRunner.lock.withLock { if (cancelAllAndDecide()) { taskRunner.kickCoordinator(this) } } } fun shutdown() { lock.assertNotHeld() taskRunner.lock.withLock { shutdown = true if (cancelAllAndDecide()) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Locks.kt
return lock.withLock(action) } inline fun <T> RealConnection.withLock(action: () -> T): T { contract { callsInPlace(action, InvocationKind.EXACTLY_ONCE) } return lock.withLock(action) } inline fun <T> RealCall.withLock(action: () -> T): T { contract { callsInPlace(action, InvocationKind.EXACTLY_ONCE) } return lock.withLock(action) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 2.1K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/ClientAndServer.java
* cannot do TLS over domain sockets. */ public class ClientAndServer { public void run() throws Exception { File socketFile = new File("/tmp/ClientAndServer.sock"); socketFile.delete(); // Clean up from previous runs. MockWebServer server = new MockWebServer(); server.setServerSocketFactory(new UnixDomainServerSocketFactory(socketFile));
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Dec 24 03:46:30 GMT 2018 - 2.1K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt
import okhttp3.Headers import okhttp3.HttpUrl import okhttp3.HttpUrl.Companion.toHttpUrlOrNull import okhttp3.internal.platform.Platform import okio.Buffer /** An HTTP request that came into the mock web server. */ @ExperimentalOkHttpApi class RecordedRequest( val requestLine: String, /** All headers. */ val headers: Headers, /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 3.8K bytes - Viewed (1)