Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 387 for sockets (0.07 sec)

  1. 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 {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt

              object : DelegatingSocketFactory(getDefault()) {
                @Throws(IOException::class)
                override fun configureSocket(socket: Socket): Socket {
                  socket.setSendBufferSize(SOCKET_BUFFER_SIZE)
                  socket.setReceiveBufferSize(SOCKET_BUFFER_SIZE)
                  return socket
                }
              },
            ).build()
      }
    
      @AfterEach
      fun tearDown() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocketFactory.kt

      override fun getSupportedCipherSuites(): Array<String> = 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)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/FallbackTestClientSocketFactory.kt

      override fun configureSocket(sslSocket: SSLSocket): SSLSocket = TlsFallbackScsvDisabledSSLSocket(sslSocket)
    
      private class TlsFallbackScsvDisabledSSLSocket(
        socket: SSLSocket,
      ) : DelegatingSSLSocket(socket) {
        override fun setEnabledCipherSuites(suites: Array<String>) {
          val enabledCipherSuites = mutableListOf<String>()
          for (suite in suites) {
            if (suite != TLS_FALLBACK_SCSV) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2K bytes
    - Viewed (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingServerSocketFactory.kt

     */
    package okhttp3
    
    import java.io.IOException
    import java.net.InetAddress
    import java.net.ServerSocket
    import javax.net.ServerSocketFactory
    
    /**
     * A [ServerSocketFactory] that delegates calls. Sockets can be configured after creation by
     * overriding [.configureServerSocket].
     */
    open class DelegatingServerSocketFactory(
      private val delegate: ServerSocketFactory,
    ) : ServerSocketFactory() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2K bytes
    - Viewed (0)
  6. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainSocketFactory.java

    import java.net.InetSocketAddress;
    import java.net.Socket;
    import javax.net.SocketFactory;
    import jnr.unixsocket.UnixSocketChannel;
    
    /** Impersonate TCP-style SocketFactory over UNIX domain sockets. */
    public final class UnixDomainSocketFactory extends SocketFactory {
      private final File path;
    
      public UnixDomainSocketFactory(File path) {
        this.path = path;
      }
    
      @Override public Socket createSocket() throws IOException {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Dec 03 21:33:52 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

      // from the perspective of a single peer.
      private val random = Random(0)
      private val taskFaker = TaskFaker()
      private val sockets = inMemorySocketPair(8192L)
      private val client = TestStreams(taskFaker, sockets[0], client = true)
      private val server = TestStreams(taskFaker, sockets[1], client = false)
    
      @BeforeEach
      fun setUp() {
        client.initWebSocket(random)
        server.initWebSocket(random)
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.7K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/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(),
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Protocol.kt

     *
     * [ietf_alpn]: http://tools.ietf.org/html/draft-ietf-tls-applayerprotoneg
     */
    enum class Protocol(
      private val protocol: String,
    ) {
      /**
       * An obsolete plaintext framing that does not use persistent sockets by default.
       */
      HTTP_1_0("http/1.0"),
    
      /**
       * A plaintext framing that includes persistent connections.
       *
       * This version of OkHttp implements [RFC 7230][rfc_7230], and tracks revisions to that spec.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jun 23 18:58:57 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

            .build(),
        )
        val webSocket: WebSocket = newWebSocket()
        clientListener.assertOpen()
        val server = serverListener.assertOpen()
        webSocket.send("Web Sockets and Events?!")
        serverListener.assertTextMessage("Web Sockets and Events?!")
        webSocket.close(1000, "")
        serverListener.assertClosing(1000, "")
        server.close(1000, "")
        clientListener.assertClosing(1000, "")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 35.5K bytes
    - Viewed (0)
Back to top