Class TcpBaseServer

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, ConnectionListener
    Direct Known Subclasses:
    TcpClient, TcpServer

    public abstract class TcpBaseServer
    extends BaseServer
    Common base class for TCP based clients and servers
    Since:
    3.6.5
    Author:
    Bela Ban
    • Field Detail

      • peer_addr_read_timeout

        protected int peer_addr_read_timeout
      • buffered_inputstream_size

        protected int buffered_inputstream_size
      • buffered_outputstream_size

        protected int buffered_outputstream_size
      • non_blocking_sends

        protected boolean non_blocking_sends
      • max_send_queue

        protected int max_send_queue
    • Method Detail

      • createConnection

        protected TcpConnection createConnection​(Address dest)
                                          throws java.lang.Exception
        Description copied from class: BaseServer
        Creates a new connection object to target dest, but doesn't yet connect it
        Specified by:
        createConnection in class BaseServer
        Throws:
        java.lang.Exception
      • peerAddressReadTimeout

        public int peerAddressReadTimeout()
      • peerAddressReadTimeout

        public TcpBaseServer peerAddressReadTimeout​(int t)
      • getBufferedInputStreamSize

        public int getBufferedInputStreamSize()
      • setBufferedInputStreamSize

        public TcpBaseServer setBufferedInputStreamSize​(int s)
      • getBufferedOutputStreamSize

        public int getBufferedOutputStreamSize()
      • setBufferedOutputStreamSize

        public TcpBaseServer setBufferedOutputStreamSize​(int s)
      • nonBlockingSends

        public boolean nonBlockingSends()
      • nonBlockingSends

        public TcpBaseServer nonBlockingSends​(boolean b)
      • maxSendQueue

        public int maxSendQueue()