- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for heddle (0.2 sec)
-
okhttp/src/test/java/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
* * * [TCP handshake][connectSocket] * * Optional [CONNECT tunnels][connectTunnel]. When using an HTTP proxy to reach an HTTPS server * we must send a `CONNECT` request, and handle authorization challenges from the proxy. * * Optional [TLS handshake][connectTls]. * * Each step may fail. If a retry is possible, a new instance is created with the next plan, which * will be configured differently. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
.assertFailureMatches("(?s)Hostname localhost not verified.*") } /** * Anonymous cipher suites were disabled in OpenJDK because they're rarely used and permit * man-in-the-middle attacks. https://bugs.openjdk.java.net/browse/JDK-8212823 */ @Test fun anonCipherSuiteUnsupported() { platform.assumeNotConscrypt() platform.assumeNotBouncyCastle()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K 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()) { return null // Nothing to do. }
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/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
return true } /** * Figures out the HTTP request to make in response to receiving [userResponse]. This will * either add authentication headers, follow redirects or handle a client request timeout. If a * follow-up is either unnecessary or not applicable, this returns null. */ @Throws(IOException::class) private fun followUpRequest( userResponse: Response,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 12.1K bytes - Viewed (4) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
currentPushRequests.remove(streamId) } } } /** Listener of streams and settings initiated by the peer. */ abstract class Listener { /** * Handle a new stream from this connection's peer. Implementations should respond by either * [replying to the stream][Http2Stream.writeHeaders] or [closing it][Http2Stream.close]. This * response does not need to be synchronous.
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/main/kotlin/okhttp3/Cookie.kt
} else { Long.MAX_VALUE } expiresAt = currentTimeMillis + deltaMilliseconds if (expiresAt < currentTimeMillis || expiresAt > MAX_DATE) { expiresAt = MAX_DATE // Handle overflow & limit the date range. } } // If the domain is present, it must domain match. Otherwise we have a host-only cookie. val urlHost = url.host if (domain == null) {
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-android/src/main/kotlin/okhttp3/android/AndroidAsyncDns.kt
hostname, UnknownHostException(e.message).apply { initCause(e) }, ) } }, ) } catch (e: Exception) { // Handle any errors that might leak out // https://issuetracker.google.com/issues/319957694 callback.onFailure( hostname, UnknownHostException(e.message).apply { initCause(e) },
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 10:07:48 GMT 2024 - 2.8K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
} private fun serveConnection(raw: Socket) { taskRunner.newQueue().execute("MockWebServer ${raw.remoteSocketAddress}", cancelable = false) { try { SocketHandler(raw).handle() } catch (e: IOException) { logger.fine("$this connection from ${raw.inetAddress} failed: $e") } catch (e: Exception) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
******@****.***ck { finished = this.finished flowControlError = remainingByteCount + readBuffer.size > maxByteCount } // If the peer sends more data than we can handle, discard it and close the connection. if (flowControlError) { source.skip(remainingByteCount) closeLater(ErrorCode.FLOW_CONTROL_ERROR) return }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1)