- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 76 for secret (0.2 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
/** * What should be done with the incoming socket. * * Be careful when using values like [DisconnectAtEnd], [ShutdownInputAtEnd] * and [ShutdownOutputAtEnd] that close a socket after a response, and where there are * follow-up requests. The client is unblocked and free to continue as soon as it has received the * entire response body. If and when the client makes a subsequent request using a pooled socket the
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 4.6K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/RecordedRequestTest.kt
import java.net.InetAddress import java.net.Socket import okhttp3.Headers import okhttp3.Headers.Companion.headersOf import okhttp3.internal.EMPTY_HEADERS import okio.Buffer import org.junit.jupiter.api.Test import org.junit.jupiter.api.Timeout @Timeout(30) class RecordedRequestTest { private val headers: Headers = EMPTY_HEADERS @Test fun testIPv4() { val socket = FakeSocket(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ChannelSocketFactory.kt
*/ package okhttp3 import java.net.InetAddress import java.net.Socket import java.nio.channels.SocketChannel import javax.net.SocketFactory class ChannelSocketFactory : SocketFactory() { override fun createSocket(): Socket { return SocketChannel.open().socket() } override fun createSocket( host: String, port: Int, ): Socket = TODO("Not yet implemented") override fun createSocket(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt
*/ val handshakeServerNames: List<String> init { if (socket is SSLSocket) { try { this.handshake = socket.session.handshake() this.handshakeServerNames = Platform.get().getHandshakeServerNames(socket) } catch (e: IOException) { throw IllegalArgumentException(e) } } else { this.handshake = null
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) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
// These properties are initialized by connect() and never reassigned. /** The low-level TCP socket. */ private var rawSocket: Socket? = null /** * The application layer socket. Either an [SSLSocket] layered over [rawSocket], or [rawSocket] * itself if this connection does not use SSL. */ internal var socket: Socket? = null private var handshake: Handshake? = null private var protocol: Protocol? = null
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) -
docs/contribute/concurrency.md
We can't rely on application threads to read data from the socket. Application threads are transient: sometimes they're reading and writing and sometimes they're off doing application-layer things. But the socket is permanent, and it needs constant attention: we dispatch all incoming frames so the connection is good-to-go when the application layer needs it. So we have a dedicated thread for every socket that just reads frames and dispatches them.
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-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocketFactory.kt
return delegate.supportedCipherSuites } @Throws(IOException::class) override fun createSocket( socket: Socket, host: String, port: Int, autoClose: Boolean, ): SSLSocket { val sslSocket = delegate.createSocket(socket, host, port, autoClose) as SSLSocket return configureSocket(sslSocket) } @Throws(IOException::class)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.8K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java
serverSocketChannel.configureBlocking(true); serverSocketChannel.socket().bind(address); } @Override public int getLocalPort() { return 1; // A white lie. There is no local port. } @Override public SocketAddress getLocalSocketAddress() { return endpoint; } @Override public Socket accept() throws IOException { try {
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Feb 12 16:33:52 GMT 2019 - 3.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketExtensions.kt
* ``` * * If any other extension or parameter is specified, then [unknownValues] will be true. Such * responses should be refused as their web socket extensions will not be understood. * * Note that [java.util.zip.Deflater] is hardcoded to use 15 bits (32 KiB) for * `client_max_window_bits` and [java.util.zip.Inflater] is hardcoded to use 15 bits (32 KiB) for
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
): RealConnection { val result = RealConnection.newTestConnection( taskRunner = taskRunner, connectionPool = pool, route = route, socket = Socket(), idleAtNs = idleAtNanos, ) result.withLock { pool.put(result) } return result } fun newConnectionPool( taskRunner: TaskRunner = this.taskRunner,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 7.7K bytes - Viewed (0)