Uses of Class
org.jgroups.protocols.TP
-
Packages that use TP Package Description org.jgroups.blocks Provides building blocks that are layered on top of channels.org.jgroups.protocols Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.org.jgroups.stack Support for managing protocol stacks.org.jgroups.util Provides useful functionality which cannot be assigned to any particular other package. -
-
Uses of TP in org.jgroups.blocks
Methods in org.jgroups.blocks with parameters of type TP Modifier and Type Method Description void
RequestCorrelator. registerProbeHandler(TP transport)
void
RequestCorrelator. unregisterProbeHandler(TP transport)
-
Uses of TP in org.jgroups.protocols
Subclasses of TP in org.jgroups.protocols Modifier and Type Class Description class
BasicTCP
Shared base class for TCP protocolsclass
SHARED_LOOPBACK
Loopback transport shared by all channels within the same VM.class
SimpleTCP
Bare-bones thread-per-connection TCP-based transport.class
TCP
TCP based protocol.class
TCP_NIO2
Protocol using TCP/IP to send and receive messages.class
TUNNEL
Replacement for UDP.class
UDP
IP multicast transport based on UDP.Fields in org.jgroups.protocols declared as TP Modifier and Type Field Description protected TP
BARRIER. transport
protected TP
BaseBundler. transport
protected TP
DAISYCHAIN. transport
protected TP
Discovery. transport
protected TP
PerDestinationBundler. transport
Methods in org.jgroups.protocols with type parameters of type TP Modifier and Type Method Description <T extends TP>
TTP. bundler(java.lang.String type)
<T extends TP>
TTP. clearDifferentClusterCache()
<T extends TP>
TTP. clearDifferentVersionCache()
<T extends TP>
TTP. enableBlockingTimerTasks(boolean flag)
<T extends TP>
TTP. enableDiagnostics()
<T extends TP>
TTP. isTrace(boolean i)
<T extends TP>
TTP. logDiscardMsgs(boolean l)
<T extends TP>
TTP. logDiscardMsgsVersion(boolean l)
<T extends TP>
TTP. msgProcessingPolicy(MessageProcessingPolicy p)
<T extends TP>
TTP. receiveOnAllInterfaces(boolean r)
<T extends TP>
TTP. registerProbeHandler(DiagnosticsHandler.ProbeHandler handler)
<T extends TP>
TTP. setAsyncExecutor(AsyncExecutor<java.lang.Object> e)
<T extends TP>
TTP. setBindAddr(java.net.InetAddress b)
<T extends TP>
TTP. setBindAddress(java.net.InetAddress a)
<T extends TP>
TTP. setBindPort(int port)
<T extends TP>
TTP. setBindToAllInterfaces(boolean f)
<T extends TP>
TTP. setBundler(Bundler new_bundler)
Installs a bundler<T extends TP>
TTP. setBundlerType(java.lang.String b)
<T extends TP>
TTP. setDiagnosticsHandler(DiagnosticsHandler handler)
Sets aDiagnosticsHandler
.<T extends TP>
TTP. setExternalAddr(java.net.InetAddress e)
<T extends TP>
TTP. setExternalPort(int e)
<T extends TP>
TTP. setLocalTransport(java.lang.String tp_class)
<T extends TP>
TTP. setLocalTransport(LocalTransport l)
<T extends TP>
TTP. setLogDiscardMessages(boolean flag)
<T extends TP>
TTP. setLogDiscardMessagesVersion(boolean f)
<T extends TP>
TTP. setLogicalAddrCacheExpiration(long l)
<T extends TP>
TTP. setLogicalAddrCacheMaxSize(int l)
<T extends TP>
TTP. setLogicalAddrCacheReaperInterval(long l)
<T extends TP>
TTP. setMessageProcessingPolicy(java.lang.String policy)
<T extends TP>
TTP. setPortRange(int range)
<T extends TP>
TTP. setSuppressTimeDifferentClusterWarnings(long s)
<T extends TP>
TTP. setSuppressTimeDifferentVersionWarnings(long s)
<T extends TP>
TTP. setThreadFactory(ThreadFactory factory)
<T extends TP>
TTP. setThreadPool(java.util.concurrent.Executor thread_pool)
<T extends TP>
TTP. setTimer(TimeScheduler timer)
Sets a new timer.<T extends TP>
TTP. setTimeService(TimeService ts)
<T extends TP>
TTP. setTimeServiceInterval(long t)
<T extends TP>
TTP. setWhoHasCacheTimeout(long w)
<T extends TP>
TTP. unregisterProbeHandler(DiagnosticsHandler.ProbeHandler handler)
<T extends TP>
TTP. useVirtualThreads(boolean f)
Methods in org.jgroups.protocols with parameters of type TP Modifier and Type Method Description void
BaseBundler. init(TP transport)
default void
Bundler. init(TP transport)
Called after creation of the bundlerLocalTransport
LocalTransport. init(TP transport)
Calls after the local transport has been created.void
PerDestinationBundler. init(TP transport)
void
RemoveQueueBundler. init(TP transport)
void
RingBufferBundler. init(TP transport)
void
RingBufferBundlerLockless. init(TP transport)
void
RingBufferBundlerLockless2. init(TP transport)
void
TransferQueueBundler. init(TP tp)
-
Uses of TP in org.jgroups.stack
Methods in org.jgroups.stack that return TP Modifier and Type Method Description TP
Protocol. getTransport()
TP
ProtocolStack. getTransport()
Returns the bottom most protocolMethods in org.jgroups.stack with parameters of type TP Modifier and Type Method Description void
MessageProcessingPolicy. init(TP transport)
Called after creation. -
Uses of TP in org.jgroups.util
Subclasses of TP in org.jgroups.util Modifier and Type Class Description class
MockTransport
A dummy implementation ofTP
Fields in org.jgroups.util declared as TP Modifier and Type Field Description protected TP
SubmitToThreadPool. tp
protected TP
RTT. transport
Methods in org.jgroups.util that return TP Modifier and Type Method Description protected TP
SubmitToThreadPool. getTransport()
Methods in org.jgroups.util with parameters of type TP Modifier and Type Method Description void
MaxOneThreadPerSender. init(TP transport)
void
RTT. init(TP tp)
void
SubmitToThreadPool. init(TP transport)
-