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.tests
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 protocols
class	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
private TP	COUNTER.transport
protected TP	DAISYCHAIN.transport
protected TP	Discovery.transport
protected TP	NoBundler.transport
protected TP	PerDestinationBundler.transport
protected TP	TransferQueueBundler2.transport

Methods in org.jgroups.protocols with type parameters of type TP

Modifier and Type	Method	Description
<T extends TP> T	TP.bundler(String type)
<T extends TP> T	TP.clearDifferentClusterCache()
<T extends TP> T	TP.clearDifferentVersionCache()
<T extends TP> T	TP.enableBlockingTimerTasks(boolean flag)
<T extends TP> T	TP.enableDiagnostics()
<T extends TP> T	TP.isTrace(boolean i)
<T extends TP> T	TP.logDiscardMsgs(boolean l)
<T extends TP> T	TP.logDiscardMsgsVersion(boolean l)
<T extends TP> T	TP.loopbackCopy(boolean l)
<T extends TP> T	TP.loopbackSeparateThread(boolean l)
<T extends TP> T	TP.receiveOnAllInterfaces(boolean r)
<T extends TP> T	TP.registerProbeHandler(DiagnosticsHandler.ProbeHandler handler)
<T extends TP> T	TP.setAsyncExecutor(AsyncExecutor<Object> e)
<T extends TP> T	TP.setBindAddr(InetAddress b)
<T extends TP> T	TP.setBindAddress(InetAddress a)
<T extends TP> T	TP.setBindPort(int port)
<T extends TP> T	TP.setBindToAllInterfaces(boolean f)
<T extends TP> T	TP.setBundler(Bundler bundler)	Installs a bundler
<T extends TP> T	TP.setBundlerType(String b)
<T extends TP> T	TP.setDiagnosticsHandler(DiagnosticsHandler handler)	Sets a DiagnosticsHandler.
<T extends TP> T	TP.setExternalAddr(InetAddress e)
<T extends TP> T	TP.setExternalPort(int e)
<T extends TP> T	TP.setLocalTransport(String tp_class)
<T extends TP> T	TP.setLocalTransport(LocalTransport l)
<T extends TP> T	TP.setLogDiscardMessages(boolean flag)
<T extends TP> T	TP.setLogDiscardMessagesVersion(boolean f)
<T extends TP> T	TP.setLogicalAddrCacheExpiration(long l)
<T extends TP> T	TP.setLogicalAddrCacheMaxSize(int l)
<T extends TP> T	TP.setLogicalAddrCacheReaperInterval(long l)
<T extends TP> T	TP.setMessageFactory(MessageFactory m)
<T extends TP> T	TP.setMsgFactoryClass(String m)
<T extends TP> T	TP.setPortRange(int range)
<T extends TP> T	TP.setSuppressTimeDifferentClusterWarnings(long s)
<T extends TP> T	TP.setSuppressTimeDifferentVersionWarnings(long s)
<T extends TP> T	TP.setThreadFactory(ThreadFactory factory)
<T extends TP> T	TP.setThreadPool(Executor thread_pool)
<T extends TP> T	TP.setTimer(TimeScheduler timer)	Sets a new timer.
<T extends TP> T	TP.setTimeService(TimeService ts)
<T extends TP> T	TP.setTimeServiceInterval(long t)
<T extends TP> T	TP.setWhoHasCacheTimeout(long w)
<T extends TP> T	TP.unregisterProbeHandler(DiagnosticsHandler.ProbeHandler handler)
<T extends TP> T	TP.useVirtualThreads(boolean b)

Methods in org.jgroups.protocols with parameters of type TP

Modifier and Type	Method	Description
private TransferQueueBundler2.Buffer	TransferQueueBundler2.Buffer.addMessage(Message msg, TP transport)
void	BaseBundler.init(TP transport)
void	BatchBundler.init(TP transport)
default void	Bundler.init(TP transport)	Called after creation of the bundler
LocalTransport	LocalTransport.init(TP transport)	Calls after the local transport has been created.
void	NoBundler.init(TP transport)
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)
void	TransferQueueBundler2.init(TP transport)
private TransferQueueBundler2.Buffer	TransferQueueBundler2.Buffer.send(Address dest, TP transport)

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 protocol

Methods 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.tests

Fields in org.jgroups.tests with type parameters of type TP

Modifier and Type	Field	Description
private static final List<Supplier<TP>>	InfinispanStackMerge3Test.TRANSPORTS

Methods in org.jgroups.tests with parameters of type TP

Modifier and Type	Method	Description
protected static JChannel	InfinispanStackMerge3Test.createChannel(TP transport, String name)

Uses of TP in org.jgroups.util

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)