- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 56 for confirm (0.23 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
else -> { connectionUser.acquireConnectionNoEvents(connection) true } } } if (!acquired) continue // Confirm the connection is healthy and return it. if (connection.isHealthy(doExtensiveHealthChecks)) return connection // In the second synchronized block, release the unhealthy acquired connection. We're also on
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) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt
private val forbiddenLocks = mutableListOf<Any>() /** 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) } /**
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-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
taskRunner.lock.withLock { check(currentTask == TestThreadSerialTask) nanoTime = newTime yieldUntil(ResumePriority.AfterOtherTasks) } } /** Confirm all tasks have completed. Used by the test thread only. */ fun assertNoMoreTasks() { taskRunner.assertThreadDoesntHoldLock() taskRunner.lock.withLock { assertThat(activeThreads).isEqualTo(0) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RequestTest.kt
assertThat(request.tag(UUID::class.java)).isSameAs(uuidTag) assertThat(request.tag(String::class.java)).isSameAs(stringTag) assertThat(request.tag(Long::class.javaObjectType)).isSameAs(longTag) } /** Confirm that we don't accidentally share the backing map between objects. */ @Test fun tagsAreImmutable() { val builder = Request.Builder() .url("https://square.com")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Interceptor.kt
* return Response.Builder() * .request(chain.request()) * .protocol(Protocol.HTTP_1_1) * .code(400) * .message("client config invalid") * .body("client config invalid".toResponseBody(null)) * .build() * } * * return chain.proceed(chain.request()) * } * ``` */ fun interface Interceptor { @Throws(IOException::class)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
server.protocols = Arrays.asList(Protocol.HTTP_2, Protocol.HTTP_1_1) timeToFirstByte() } /** * Test to confirm that events are reported at the time they occur and no earlier and no later. * This inserts a bunch of synthetic 250 ms delays into both client and server and confirms that * the same delays make it back into the events. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 56.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cookie.kt
* value. */ @get:JvmName("sameSite") val sameSite: String?, ) { /** * Returns true if this cookie should be included on a request to [url]. In addition to this * check callers should also confirm that this cookie has not expired. */ fun matches(url: HttpUrl): Boolean { val domainMatch = if (hostOnly) { url.host == domain } else { domainMatch(url.host, domain)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:12:05 GMT 2024 - 23.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
var byteCount = byteCount while (byteCount > 0L) { var toWrite: Int this.withLock { try { while (writeBytesTotal >= writeBytesMaximum) { // Before blocking, confirm that the stream we're writing is still open. It's possible // that the stream has since been closed (such as if this write timed out.) if (!streams.containsKey(streamId)) {
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) -
okhttp/src/test/java/okhttp3/CacheTest.kt
ifNoneMatch.compareAndSet(null, chain.request().header("If-None-Match")) chain.proceed(chain.request()) }, ) .build() // Confirm the value is cached and intercepted. assertThat(get(url).body.string()).isEqualTo("A") assertThat(ifNoneMatch.get()).isEqualTo("v1") } @Test fun networkInterceptorNotInvokedForFullyCached() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
```java client.setConnectionSpecs(Arrays.asList( ConnectionSpec.MODERN_TLS, ConnectionSpec.COMPATIBLE_TLS)); ``` * **New cipher suites.** Please confirm that your webservers are reachable with this limited set of cipher suites. ``` Android Name Version
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 26.6K bytes - Viewed (0)