Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 4 of 4 for setKeepAlive (0.34 seconds)

  2. github.com/square/okhttp

    okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt 

      override fun getSoTimeout(): Int = delegate!!.soTimeout

  @Throws(SocketException::class)
  override fun getTcpNoDelay(): Boolean = delegate!!.tcpNoDelay

  @Throws(SocketException::class)
  override fun setKeepAlive(keepAlive: Boolean) {
    delegate!!.keepAlive = keepAlive
  }

  @Throws(SocketException::class)
  override fun setSendBufferSize(size: Int) {
    delegate!!.sendBufferSize = size
  }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  3. github.com/minio/minio

    internal/event/target/mqtt.go 

    	options := mqtt.NewClientOptions().
		SetClientID(clientID).
		SetCleanSession(true).
		SetUsername(args.User).
		SetPassword(args.Password).
		SetMaxReconnectInterval(args.MaxReconnectInterval).
		SetKeepAlive(args.KeepAlive).
		SetTLSConfig(&tls.Config{RootCAs: args.RootCAs}).
		AddBroker(args.Broker.String())

	target.client = mqtt.NewClient(options)

	token := target.client.Connect()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 8.2K bytes
    - Click Count (0)
  4. github.com/codelibs/jcifs

    src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaConnection.java 

                    socketChannel.bind(localAddress);
            }

            socketChannel.connect(remoteAddress);
            socket = socketChannel.socket();
            socket.setTcpNoDelay(true);
            socket.setKeepAlive(true);

            state = RdmaConnectionState.CONNECTED;
            log.debug("TCP RDMA connection established to {}", remoteAddress);

        } catch (IOException e) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  5. github.com/golang/go

    api/go1.txt 

    pkg net, method (*TCPConn) ReadFrom(io.Reader) (int64, error)
pkg net, method (*TCPConn) RemoteAddr() Addr
pkg net, method (*TCPConn) SetDeadline(time.Time) error
pkg net, method (*TCPConn) SetKeepAlive(bool) error
pkg net, method (*TCPConn) SetLinger(int) error
pkg net, method (*TCPConn) SetNoDelay(bool) error
pkg net, method (*TCPConn) SetReadBuffer(int) error
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Wed Aug 14 18:58:28 GMT 2013
    - 1.7M bytes
    - Click Count (0)
Back to Top