- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for forbidLock (0.04 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
.eventListenerFactory { ClientRuleEventListener(logger = ::addEvent) } .build() connectionListener.forbidLock(RealConnectionPool.get(client.connectionPool)) connectionListener.forbidLock(client.dispatcher) testClient = client } return client } private fun initialClientBuilder(): OkHttpClient.Builder = if (isLoom()) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 10.5K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt
.fastFallback(fastFallback) .build() @BeforeEach fun setUp() { platform.assumeNotOpenJSSE() platform.assumeNotBouncyCastle() listener.forbidLock(get(client.connectionPool)) listener.forbidLock(client.dispatcher) } @ParameterizedTest @ValueSource(booleans = [true, false]) fun successfulCallEventSequence() { server!!.enqueue(MockResponse(body = "abc")) val call =
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 9.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.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. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 5.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt
.build() private var socksProxy: SocksProxy? = null private var cache: Cache? = null @BeforeEach fun setUp() { platform.assumeNotOpenJSSE() listener.forbidLock(get(client.connectionPool)) listener.forbidLock(client.dispatcher) } @AfterEach fun tearDown() { if (socksProxy != null) { socksProxy!!.shutdown() } if (cache != null) { cache!!.delete()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 60.4K 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. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 9.5K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt
.eventListenerFactory(clientTestRule.wrap(listener)) .build() @BeforeEach fun setUp() { dispatcher.maxRequests = 20 dispatcher.maxRequestsPerHost = 10 listener.forbidLock(dispatcher) } @Test fun maxRequestsZero() { assertFailsWith<IllegalArgumentException> { dispatcher.maxRequests = 0 } } @Test fun maxPerHostZero() {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 12.7K bytes - Viewed (0)