Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 473 for sockets (0.1 sec)

  1. okhttp/src/test/java/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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. 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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  3. 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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Dec 03 21:33:52 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  4. okhttp/src/test/java/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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  5. 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(),
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  6. cni/pkg/config/config.go

    	// KUBERNETES_SERVICE_HOST
    	K8sServiceHost string
    	// KUBERNETES_SERVICE_PORT
    	K8sServicePort string
    	// KUBERNETES_NODE_NAME
    	K8sNodeName string
    	// Path where service account secrets live, e.g. "/var/run/secrets/kubernetes.io/serviceaccount"
    	// Tests may override.
    	K8sServiceAccountPath string
    
    	// Directory from where the CNI binaries should be copied
    	CNIBinSourceDir string
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 15:33:47 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  7. okhttp/src/main/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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:17:33 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. 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)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  9. 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() {
      @Throws(IOException::class)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  10. internal/http/dial_linux.go

    			// with dead end because tcp-keepalive is not fired when there is data in the socket buffer.
    			//    https://blog.cloudflare.com/when-tcp-sockets-refuse-to-die/
    			// This is a sensitive configuration, it is better to set it to high values, > 60 secs since it can
    			// affect clients reading data with a very slow pace  (disappropriate with socket buffer sizes)
    			if opts.UserTimeout > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
Back to top