Class TCP

java.lang.Object
org.jgroups.stack.Protocol
org.jgroups.protocols.TPConfig
org.jgroups.protocols.TP
org.jgroups.protocols.BasicTCP
org.jgroups.protocols.TCP
All Implemented Interfaces:
ConnectionListener, Receiver, Lifecycle, DiagnosticsHandler.ProbeHandler
public class TCP extends BasicTCP
TCP based protocol. Creates a server socket, which gives us the local address of this group member. For each accept() on the server socket, a new thread is created that listens on the socket. For each outgoing message m, if m.dest is in the outgoing hash table, the associated socket will be reused to send message, otherwise a new socket is created and put in the hash table. When a socket connection breaks or a member is removed from the group, the corresponding items in the incoming and outgoing hash tables will be removed as well.

This functionality is in TcpServer, which is used by TCP. TCP sends messages using ct.send() and registers with the connection table to receive all incoming messages.

Author:
Bela Ban

  • Field Details

    • srv

      protected TcpServer srv

    • buffered_input_stream_size

      protected int buffered_input_stream_size

    • buffered_output_stream_size

      protected int buffered_output_stream_size

    • log_accept_error

      protected boolean log_accept_error

    • use_lock_to_send

      protected boolean use_lock_to_send

    • tls

      protected TLS tls

    • non_blocking_sends

      @Deprecated protected boolean non_blocking_sends
      Deprecated.

    • max_send_queue

      protected int max_send_queue

  • Constructor Details

    • TCP

      public TCP()

  • Method Details

    • getBufferedInputStreamSize

      public int getBufferedInputStreamSize()

    • setBufferedInputStreamSize

      public TCP setBufferedInputStreamSize(int buffered_input_stream_size)

    • getBufferedOutputStreamSize

      public int getBufferedOutputStreamSize()

    • setBufferedOutputStreamSize

      public TCP setBufferedOutputStreamSize(int buffered_output_stream_size)

    • tls

      public TLS tls()

    • tls

      public TCP tls(TLS t)

    • logAcceptError

      public boolean logAcceptError()

    • logAcceptError

      public TCP logAcceptError(boolean l)

    • nonBlockingSends

      public boolean nonBlockingSends()

    • nonBlockingSends

      public TCP nonBlockingSends(boolean b)

    • maxSendQueue

      public int maxSendQueue()

    • maxSendQueue

      public TCP maxSendQueue(int s)

    • useLockToSend

      public boolean useLockToSend()

    • useLockToSend

      public TCP useLockToSend(boolean u)

    • getOpenConnections

      public int getOpenConnections()

    • printConnections

      public String printConnections()
      Specified by:
      printConnections in class BasicTCP

    • clearConnections

      public TCP clearConnections(boolean graceful)
      Specified by:
      clearConnections in class BasicTCP

    • setSocketFactory

      public void setSocketFactory(SocketFactory factory)
      Description copied from class: Protocol
      Sets a SocketFactory. Socket factories are typically provided by the transport (TP)
      Overrides:
      setSocketFactory in class TPConfig
      Parameters:
      factory -

    • sendUnicast

      public void sendUnicast(PhysicalAddress dest, ByteBuffer data) throws Exception
      Description copied from class: TP
      Send a unicast message to a member. Note that the destination address is a *physical*, not a logical address
      Specified by:
      sendUnicast in class TP
      Parameters:
      dest - Must be a non-null physical unicast address (e.g. IpAddress)
      data - The data to be sent. This is not a copy, so don't modify it
      Throws:
      Exception

    • retainAll

      public void retainAll(Collection<Address> members)
      Specified by:
      retainAll in class BasicTCP

    • init

      public void init() throws Exception
      Description copied from class: Protocol
      Called after a protocol has been created and before the protocol is started. Attributes are already set. Other protocols are not yet connected and events cannot yet be sent.
      Specified by:
      init in interface Lifecycle
      Overrides:
      init in class BasicTCP
      Throws:
      Exception - Thrown if protocol cannot be initialized successfully. This will cause the ProtocolStack to fail, so the the channel constructor will throw an exception

    • start

      public void start() throws Exception
      Description copied from class: TP
      Creates the unicast and multicast sockets and starts the unicast and multicast receiver threads
      Specified by:
      start in interface Lifecycle
      Overrides:
      start in class TP
      Throws:
      Exception - Thrown if protocol cannot be started successfully. This will cause the ProtocolStack to fail, so JChannel.connect(String) will throw an exception

    • stop

      public void stop()
      Description copied from class: Protocol
      Called on a JChannel.disconnect(); stops work (e.g. by closing multicast socket). Will be called from top to bottom.
      Specified by:
      stop in interface Lifecycle
      Overrides:
      stop in class TP

    • handleConnect

      protected void handleConnect() throws Exception
      Overrides:
      handleConnect in class TP
      Throws:
      Exception

    • handleDisconnect

      protected void handleDisconnect()
      Overrides:
      handleDisconnect in class TP

    • getPhysicalAddress

      protected PhysicalAddress getPhysicalAddress()
      Description copied from class: TP
      Returns the physical address of this transport
      Specified by:
      getPhysicalAddress in class TP