- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 230 for socketio (0.38 sec)
-
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/test/java/okhttp3/URLConnectionTest.kt
.socketFactory( object : DelegatingSocketFactory(getDefault()) { override fun configureSocket(socket: Socket): Socket { socket.receiveBufferSize = socketBufferSize socket.sendBufferSize = socketBufferSize return socket } }, ) .writeTimeout(Duration.ofMillis(500)) .build() server.start()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
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) -
istioctl/pkg/writer/envoy/configdump/testdata/endpoint/configdump.json
"address": { "pipe": { "path": "./var/run/secrets/workload-spiffe-uds/socket" } }, "health_check_config": {} },
Json - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jul 12 02:25:59 GMT 2022 - 66K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
val connectionPool: RealConnectionPool, override val route: Route, /** The low-level TCP socket. */ private var rawSocket: Socket?, /** * The application layer socket. Either an [SSLSocket] layered over [rawSocket], or [rawSocket] * itself if this connection does not use SSL. */ private var socket: Socket?, private var handshake: Handshake?, private var protocol: Protocol?,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt
val sslSocket = sslSocketFactory.createSocket( socket, socket.inetAddress.hostAddress, socket.port, true, ) as SSLSocket sslSocket.useClientMode = false Platform.get().configureTlsExtensions(sslSocket, null, listOf(Protocol.HTTP_2)) sslSocket.startHandshake() return sslSocket } override fun onStream(stream: Http2Stream) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
private fun readAndWriteFrames() { check(socket == null) val socket = serverSocket!!.accept()!! this.socket = socket // Bail out now if this instance was closed while waiting for the socket to accept. synchronized(this) { if (executor.isShutdown) { socket.close() return } } val outputStream = socket.getOutputStream()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbTransport.java
do { /* These Socket constructors attempt to connect before SO_TIMEOUT can be applied if (localAddr == null) { socket = new Socket( address.getHostAddress(), 139 ); } else { socket = new Socket( address.getHostAddress(), 139, localAddr, localPort ); } socket.setSoTimeout( SO_TIMEOUT ); */
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 31.2K bytes - Viewed (0)