- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 41 for Gill (0.12 sec)
-
okhttp-tls/src/test/java/okhttp3/tls/HandshakeCertificatesTest.kt
val acceptedIssuers = handshakeCertificates.trustManager.acceptedIssuers val names = acceptedIssuers .map { it.subjectDN.name } .toSet() // It's safe to assume all platforms will have a major Internet certificate issuer. assertThat(names).matchesPredicate { strings -> strings.any { it.matches(Regex("[A-Z]+=Entrust.*")) } } } private fun startTlsServer(): InetSocketAddress {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 7.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/RouteSelectorTest.kt
val address = factory.newAddress() proxySelector.proxies.add(Proxy.NO_PROXY) val routeSelector = newRouteSelector(address) proxySelector.assertRequests(address.url.toUri()) // Only the origin server will be attempted. assertThat(routeSelector.hasNext()).isTrue() dns[uriHost] = dns.allocate(1) val selection = routeSelector.next()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 20.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/CacheControl.kt
/** * Sets the minimum number of seconds that a response will continue to be fresh for. If the * response will be stale when [minFresh] have elapsed, the cached response will not be used and * a network request will be made. * * @param minFresh a non-negative integer. This is stored and transmitted with * [TimeUnit.SECONDS] precision; finer precision will be lost. */ fun minFresh( minFresh: Int,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 10K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
* seconds. If our implementation is acting correctly, it will not throw, as it is progressing. */ @ParameterizedTest @ArgumentsSource(ProtocolParamProvider::class) fun readTimeoutMoreGranularThanBodySize( protocol: Protocol, mockWebServer: MockWebServer, ) { setUp(protocol, mockWebServer) val body = CharArray(4096) // 4KiB to read. Arrays.fill(body, 'y') server.enqueue(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
* until one is ready. If there are no ready queues, or if other threads have everything under * control this will return null. If there is more than a single task ready to execute immediately * this will start another thread to handle that work. */ fun awaitTaskToRun(): Task? { lock.assertHeld() while (true) { if (readyQueues.isEmpty()) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
taskFaker.runTasks() server.webSocket!!.tearDown() client.webSocket!!.tearDown() taskFaker.close() } @Test fun close() { client.webSocket!!.close(1000, "Hello!") // This will trigger a close response. assertThat(server.processNextFrame()).isFalse() server.listener.assertClosing(1000, "Hello!") server.webSocket!!.finishReader() server.webSocket!!.close(1000, "Goodbye!")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RouteSelector.kt
// Postponed routes are always tried last. For example, if we have 2 proxies and all the // routes for proxy1 should be postponed, we'll move to proxy2. Only after we've exhausted // all the good routes will we attempt the postponed routes. val proxy = nextProxy() for (inetSocketAddress in inetSocketAddresses) { val route = Route(address, proxy, inetSocketAddress) if (routeDatabase.shouldPostpone(route)) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
val cacheRequest = cache.put(response.newBuilder().request(cacheNetworkRequest).build()) return cacheWritingResponse(cacheRequest, response).also { if (cacheResponse != null) { // This will log a conditional cache miss only. listener.cacheMiss(call) } } } if (HttpMethod.invalidatesCache(networkRequest.method)) { try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 10.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
/** The task that's currently executing. Guarded by [TaskRunner.lock]. */ private var currentTask: SerialTask = TestThreadSerialTask /** The coordinator task if it's waiting, and how it will resume. Guarded by [TaskRunner.lock]. */ private var waitingCoordinatorTask: SerialTask? = null private var waitingCoordinatorInterrupted = false private var waitingCoordinatorNotified = false
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/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
} } /** * HTTP/2 only. Send a push promise header block. * * A push promise contains all the headers that pertain to a server-initiated request, and a * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as * a part of the response to `streamId`. The `promisedStreamId` has a priority of one greater than * `streamId`. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0)