- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,023 for Socket (0.19 sec)
-
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
/** * A non-blocking interface to a web socket. Use the [factory][WebSocket.Factory] to create * instances; usually this is [OkHttpClient]. * * ## Web Socket Lifecycle * * Upon normal operation each web socket progresses through a sequence of states: * * * **Connecting:** the initial state of each web socket. Messages may be enqueued but they won't * be transmitted until the web socket is open. *
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSocketFactory.kt
} @Throws(IOException::class) override fun createSocket( host: String, port: Int, ): Socket { val socket = delegate.createSocket(host, port) return configureSocket(socket) } @Throws(IOException::class) override fun createSocket( host: String, port: Int, localAddress: InetAddress, localPort: Int, ): Socket {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
} val source = socket.source().buffer() val sink = socket.sink().buffer() while (processOneRequest(socket, source, sink)) { } if (sequenceNumber == 0) { logger.warning( "${this@MockWebServer} connection from ${raw.inetAddress} didn't make a request", ) } socket.close() openClientSockets.remove(socket) } /**
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
@Throws(IOException::class) override fun configureSocket(socket: Socket): Socket { socket.sendBufferSize = SOCKET_BUFFER_SIZE socket.receiveBufferSize = SOCKET_BUFFER_SIZE return socket } }, ) .sslSocketFactory( handshakeCertificates.sslSocketFactory(),
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.9K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainSocketFactory.java
} @Override public Socket createSocket(String host, int port) throws IOException { Socket result = createSocket(); try { result.connect(new InetSocketAddress(host, port)); } catch (IOException e) { result.close(); throw e; } return result; } @Override public Socket createSocket(
Java - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Dec 03 21:33:52 GMT 2023 - 2.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt
serverSocket.setReceiveBufferSize(SOCKET_BUFFER_SIZE) return serverSocket } } client = clientTestRule.newClientBuilder() .socketFactory( object : DelegatingSocketFactory(getDefault()) { @Throws(IOException::class) override fun configureSocket(socket: Socket): Socket { socket.setSendBufferSize(SOCKET_BUFFER_SIZE)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K 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 Apr 28 00:10:09 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 31.2K 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 Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K 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 Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Jul 12 02:25:59 GMT 2022 - 66K 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 Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.1K bytes - Viewed (0)