Uses of Class
org.jgroups.stack.Protocol
-
Packages that use Protocol Package Description org.jgroups Provides top-level public JGroups classes such as Channel, Message, etc.org.jgroups.blocks Provides building blocks that are layered on top of channels.org.jgroups.conf Provides ways to configure a protocol stack.org.jgroups.fork org.jgroups.jmx org.jgroups.protocols Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.org.jgroups.protocols.dns org.jgroups.protocols.pbcast org.jgroups.protocols.relay org.jgroups.protocols.relay.config 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 Protocol in org.jgroups
Methods in org.jgroups with parameters of type Protocol Modifier and Type Method Description protected java.lang.reflect.Method
JChannelProbeHandler. findMethod(Protocol prot, java.lang.String method_name, java.lang.String[] args)
Constructors in org.jgroups with parameters of type Protocol Constructor Description JChannel(Protocol... protocols)
Creates a channel from an array of protocols.Constructor parameters in org.jgroups with type arguments of type Protocol Constructor Description JChannel(java.util.List<Protocol> protocols)
Creates a channel from a list of protocols. -
Uses of Protocol in org.jgroups.blocks
Subclasses of Protocol in org.jgroups.blocks Modifier and Type Class Description protected class
MessageDispatcher.ProtocolAdapter
Fields in org.jgroups.blocks declared as Protocol Modifier and Type Field Description protected Protocol
RequestCorrelator. down_prot
The protocol layer to use to pass up/down messages.Methods in org.jgroups.blocks with type parameters of type Protocol Modifier and Type Method Description <T extends Protocol>
TMessageDispatcher.ProtocolAdapter. setAddress(Address addr)
<T extends Protocol>
TMessageDispatcher.ProtocolAdapter. setDownProt(Protocol d)
Methods in org.jgroups.blocks with parameters of type Protocol Modifier and Type Method Description protected static RequestCorrelator
MessageDispatcher. createRequestCorrelator(Protocol transport, RequestHandler handler, Address local_addr)
<T extends Protocol>
TMessageDispatcher.ProtocolAdapter. setDownProt(Protocol d)
Constructors in org.jgroups.blocks with parameters of type Protocol Constructor Description RequestCorrelator(Protocol down_prot, RequestHandler handler, Address local_addr)
Constructor. -
Uses of Protocol in org.jgroups.conf
Methods in org.jgroups.conf that return types with arguments of type Protocol Modifier and Type Method Description java.lang.Class<? extends Protocol>
ProtocolConfiguration. loadProtocolClass(java.lang.Class<?> loadingClass)
Load the class of theProtocol
configured by this instance.Methods in org.jgroups.conf with parameters of type Protocol Modifier and Type Method Description default void
ProtocolStackConfigurator. afterCreation(Protocol prot)
Method parameters in org.jgroups.conf with type arguments of type Protocol Modifier and Type Method Description boolean
ProtocolConfiguration. isAssignableProtocol(java.lang.Class<? extends Protocol> other, java.lang.Class<?> loadingClass)
Determines if the classother
is the same or superclass (or superinterface) as theProtocol
configured by this instance. -
Uses of Protocol in org.jgroups.fork
Subclasses of Protocol in org.jgroups.fork Modifier and Type Class Description class
ForkProtocol
Acts as bottom protocol of a fork-stack.class
ForkProtocolStack
Protocol stack which maintains the mapping between fork-channel IDs and ForkChannelsFields in org.jgroups.fork with type parameters of type Protocol Modifier and Type Field Description protected java.util.List<Protocol>
ForkProtocolStack. protocols
Methods in org.jgroups.fork that return types with arguments of type Protocol Modifier and Type Method Description java.util.List<Protocol>
ForkProtocolStack. getProtocols()
Method parameters in org.jgroups.fork with type arguments of type Protocol Modifier and Type Method Description protected static FORK
ForkChannel. getFORK(JChannel ch, ProtocolStack.Position position, java.lang.Class<? extends Protocol> neighbor, boolean create_fork_if_absent)
Creates a new FORK protocol, or returns the existing one, or throws an exception.Constructors in org.jgroups.fork with parameters of type Protocol Constructor Description ForkChannel(JChannel main_channel, java.lang.String fork_stack_id, java.lang.String fork_channel_id, boolean create_fork_if_absent, ProtocolStack.Position position, java.lang.Class<? extends Protocol> neighbor, Protocol... protocols)
Creates a new fork-channel from a main-channel.ForkChannel(JChannel main_channel, java.lang.String fork_stack_id, java.lang.String fork_channel_id, Protocol... protocols)
Creates a new fork-channel from a main-channel.Constructor parameters in org.jgroups.fork with type arguments of type Protocol Constructor Description ForkChannel(JChannel main_channel, java.lang.String fork_stack_id, java.lang.String fork_channel_id, boolean create_fork_if_absent, ProtocolStack.Position position, java.lang.Class<? extends Protocol> neighbor, Protocol... protocols)
Creates a new fork-channel from a main-channel.ForkProtocolStack(UnknownForkHandler unknownForkHandler, java.util.List<Protocol> protocols, java.lang.String fork_stack_id)
-
Uses of Protocol in org.jgroups.jmx
Methods in org.jgroups.jmx with parameters of type Protocol Modifier and Type Method Description static javax.management.DynamicMBean
JmxConfigurator. wrap(Protocol p)
Wrap Protocol with DynamicMBean interface. -
Uses of Protocol in org.jgroups.protocols
Subclasses of Protocol in org.jgroups.protocols Modifier and Type Class Description class
ASYM_ENCRYPT
Encrypts and decrypts communication in JGroups by using a secret key distributed to all cluster members by the key server (coordinator) using asymmetric (public/private key) encryption.
The secret key is identical for all cluster members and is used to encrypt messages when sending and decrypt them when receiving messages.class
AUTH
The AUTH protocol adds a layer of authentication to JGroups.class
BARRIER
All messages up the stack have to go through a barrier (read lock, RL).class
BasicTCP
Shared base class for TCP protocolsclass
BATCH
Batches messages near the top of the stack.class
BATCH2
Batches messages near the top of the stack.class
BPING
Broadcast PING.class
CLEAR_FLAGS
Protocol which clears a set of flags in the down or up direction for all messagesclass
COMPRESS
Compresses the payload of a message.class
COUNTER
Protocol which is used byCounterService
to provide a distributed atomic counterclass
DAISYCHAIN
Implementation of daisy chaining.class
DELAY
Delays incoming/outgoing messages by a random number of milliseconds (range between 0 and n where n is determined by the user) and nanoseconds (constant amount).class
DETECT_LOOPBACKS
Detects unicast loopbacks: messages where dest == local addressclass
DH_KEY_EXCHANGE
Key exchange based on Diffie-Hellman-Merkle (https://en.wikipedia.org/wiki/Diffie%E2%80%93Hellman_key_exchange).
Diffie-Hellman is used between a member and a key server (the coordinator) to obtain a session key (only known to the key server and the joiner) which is used by the key server to encrypt the shared secret symmetric (group) key and by the requester to decrypt the group key it gets in the response of the key server.class
DISCARD
Discards up or down messages based on a percentage; e.g., setting property 'up' to 0.1 causes 10% of all up messages to be discarded.class
DISCARD_PAYLOAD
Discards a message whose sequence number (in the payload, as a Long) matches seqno 2 times, before passing it down.class
Discovery
The Discovery protocol retrieves the initial membership (used by GMS and MERGE3) by sending discovery requests.class
DROP
Protocol which drops up or down messages according to user-defined filtersclass
DUPL
Duplicates outgoing or incoming messages by copying themclass
Encrypt<E extends java.security.KeyStore.Entry>
Super class of symmetric (SYM_ENCRYPT
) and asymmetric (ASYM_ENCRYPT
) encryption protocols.class
EXAMPLE
Example of a protocol layer.class
FailureDetection
class
FD_ALL
Failure detection based on simple heartbeat protocol.class
FD_ALL2
Failure detection based on simple heartbeat protocol.class
FD_ALL3
Failure detection based on simple heartbeat protocol.class
FD_HOST
Failure detection protocol which detects the crash or hanging of entire hosts and suspects all cluster members on those hosts.class
FD_SOCK
Failure detection protocol based on sockets.class
FD_SOCK2
Failure detection protocol based on TCP connections, successor toFD_SOCK
.class
FILE_PING
Simple discovery protocol which uses a file on shared storage such as an SMB share, NFS mount or S3.class
FlowControl
Simple flow control protocol based on a credit system.class
FORK
The FORK protocol; multiplexes messages to different forks in a stack (https://issues.redhat.com/browse/JGRP-1613).class
FRAG
Fragmentation layer.class
FRAG2
Fragmentation layer.class
FRAG3
Fragmentation protocol which uses less memory to store fragments thanFRAG2
.
When a message is fragmented, all fragments carry the size of the original message, their offset and length with respect to the original message and a fragment ID (to identify the fragment).
When the first fragment is received, the full message is created and each fragment copies its data into the full message at its offset and length.class
FRAG4
Fragmentation layer.class
Fragmentation
Base class for all fragmentation protocols.class
HDRS
Prints the headers of all sent or received messagesclass
INJECT_VIEW
Simple protocol to inject an arbitrary view on one or more cluster nodes.class
JDBC_PING
Discovery protocol using a JDBC connection to a shared database.class
JDBC_PING2
New version ofJDBC_PING
.class
KeyExchange
Base class for protocols implementing key exchange: a secret key to be used for encryption is exchanged between 2 parties (usually the key server and a new cluster member) securely; ie.class
LOCAL_PING
Discovery protocol for finding members in the local process only.class
MAKE_BATCH
Intercepts individual up messages and creates batches from them, passing the batches up.class
MERGE3
Protocol to discover subgroups; e.g., existing due to a network partition (that healed).class
MFC
Simple flow control protocol based on a credit system.class
MFC_NB
Non-blocking alternative toMFC
.
JIRA: JIRA: https://issues.redhat.com/browse/JGRP-2172class
MPING
Uses its own IP multicast socket to send and receive discovery requests/responses.class
NAKACK3
Negative AcKnowledgement layer (NAKs).class
NAKACK4
New multicast protocols based on fixed-size xmit windows and message ACKsDetails: https://issues.redhat.com/browse/JGRP-2780 class
NON_BLOCKING_SENDS
Detects sends during processing of incoming messages and sets flagMessage.TransientFlag.DONT_BLOCK
to prevent blocking the incoming thread on a send.
JIRA: https://issues.redhat.com/browse/JGRP-2772class
PDC
Persistent Discovery Cache.class
PERF
Protocol measuring latency between stacks.class
PING
The PING protocol retrieves the initial membership by mcasting a discovery request (via the multicast capable transport) to all current cluster membersclass
RACKSPACE_PING
Discovery protocol based on Rackspace Cloud Files storage solutionclass
RATE
Measures incoming and outgoing rates: messages/sec, bytes/sec.class
RATE_LIMITER
Protocol which sends at most max_bytes in time_period milliseconds.class
RATE_LIMITER2
Rate limiter based credits (max_bytes).class
RED
Implementation of Random Early Drop: messages are discarded when the bundler's queue in the transport nears exhaustion.class
ReliableMulticast
Base class for reliable multicast protocolsclass
REVERSE
Reverses the next N messages that are received.class
RSVP
Protocol which implements synchronous messages (https://issues.redhat.com/browse/JGRP-1389).class
SEQUENCER
Implementation of total order protocol using a sequencer.class
SEQUENCER2
Implementation of total order protocol using a sequencer_uum.class
SERIALIZE
Serializes the entire message (including payload, headers, flags and destination and src) into the payload of another message that's then sent.class
SHARED_LOOPBACK
Loopback transport shared by all channels within the same VM.class
SHARED_LOOPBACK_PING
Discovery protocol running overSHARED_LOOPBACK
only.class
SHUFFLE
Reorders messages by buffering them and shuffling the result after TIMEOUT ms.class
SimpleTCP
Bare-bones thread-per-connection TCP-based transport.class
SIZE
Protocol which prints out the real size of a message.class
SNIFF
Protocol trying to print message payloads as stringsclass
SOS
Periodically fetches some attributes and writes them to a file (https://issues.redhat.com/browse/JGRP-2402)class
SSL_KEY_EXCHANGE
Key exchange based on SSL sockets.class
STATS
Provides various statsclass
STOMP
Protocol which provides STOMP (https://stomp.github.io/) support.class
SWIFT_PING
Discovery protocol based on Openstack Swift (object storage).class
SYM_ENCRYPT
Encrypts and decrypts communication in JGroups by using a secret key shared by all cluster members.class
TCP
TCP based protocol.class
TCP_NIO2
Protocol using TCP/IP to send and receive messages.class
TCPGOSSIP
The TCPGOSSIP protocol layer retrieves the initial membership (used by GMS when started by sending event FIND_INITIAL_MBRS down the stack).class
TCPPING
The TCPPING protocol defines a static cluster membership.class
THREAD_COUNT
Maintains averages of up- and down-threadsclass
TIME
Protocol measuring delivery times.class
TP
Generic transport - specific implementations should extend this abstract class.class
TRACE
class
TUNNEL
Replacement for UDP.class
UDP
IP multicast transport based on UDP.class
UFC
Simple flow control protocol based on a credit system.class
UFC_NB
Non-blocking alternative toUFC
.
JIRA: https://issues.redhat.com/browse/JGRP-2172class
UNBATCH
Interceptsup(MessageBatch)
and passes up each message of a message batch as a single message.class
UNICAST3
Reliable unicast protocol using a combination of positive and negative acks.class
VERIFY_SUSPECT
Catches SUSPECT events traveling up the stack.class
VERIFY_SUSPECT2
Double-checks that a suspected member is really dead.
Details: https://issues.redhat.com/browse/JGRP-2558
Design: https://github.com/belaban/JGroups/blob/master/doc/design/VERIFY_SUSPECT2.txtFields in org.jgroups.protocols with type parameters of type Protocol Modifier and Type Field Description protected java.util.concurrent.ConcurrentMap<java.lang.String,Protocol>
FORK. fork_stacks
Methods in org.jgroups.protocols with type parameters of type Protocol Modifier and Type Method Description protected <T extends Protocol>
TRSVP. findDownProtocol(java.lang.Class<? extends Protocol> cl)
protected <T extends Protocol>
TKeyExchange. findProtocolAbove(java.lang.Class<? extends Protocol> clazz)
<T extends Protocol>
TFORK. setAddress(Address addr)
<T extends Protocol>
TTP. setAddress(Address addr)
<T extends Protocol>
TReliableMulticast. setLevel(java.lang.String level)
<T extends Protocol>
TTP. setLevel(java.lang.String level)
<T extends Protocol>
TUNICAST3. setLevel(java.lang.String level)
Methods in org.jgroups.protocols that return Protocol Modifier and Type Method Description Protocol
FORK. get(java.lang.String fork_stack_id)
Protocol
FORK. putIfAbsent(java.lang.String fork_stack_id, Protocol p)
Methods in org.jgroups.protocols with parameters of type Protocol Modifier and Type Method Description static ForkProtocolStack
FORK. getForkStack(Protocol prot)
protected void
FORK. getStateFrom(JChannel channel, Protocol prot, java.lang.String stack, java.lang.String ch, java.io.DataOutputStream out)
Protocol
FORK. putIfAbsent(java.lang.String fork_stack_id, Protocol p)
Method parameters in org.jgroups.protocols with type arguments of type Protocol Modifier and Type Method Description ProtocolStack
FORK. createForkStack(java.lang.String fork_stack_id, java.util.List<Protocol> protocols, boolean initialize)
Returns the fork stack for fork_stack_id (if exitstent), or creates a new fork-stack from protocols and adds it into the hashmap of fork-stack (key is fork_stack_id).protected <T extends Protocol>
TRSVP. findDownProtocol(java.lang.Class<? extends Protocol> cl)
protected <T extends Protocol>
TKeyExchange. findProtocolAbove(java.lang.Class<? extends Protocol> clazz)
-
Uses of Protocol in org.jgroups.protocols.dns
Subclasses of Protocol in org.jgroups.protocols.dns Modifier and Type Class Description class
DNS_PING
-
Uses of Protocol in org.jgroups.protocols.pbcast
Subclasses of Protocol in org.jgroups.protocols.pbcast Modifier and Type Class Description class
GMS
Group membership protocol.class
NAKACK2
Negative AcKnowledgement layer (NAKs).class
STABLE
Computes the broadcast messages that are stable; i.e., have been delivered by all members.class
STATE
STATE streams the state (written to an OutputStream) to the state requester in chunks (defined by chunk_size).class
STATE_SOCK
STATE_SOCK
has the state provider create a server socket to which the state requester connects and from which the latter reads the state.class
STATE_TRANSFER
STATE_TRANSFER protocol based on byte array transfer.class
StreamingStateTransfer
Base class for state transfer protocols which use streaming (or chunking) to transfer state between two members.Methods in org.jgroups.protocols.pbcast with type parameters of type Protocol Modifier and Type Method Description <T extends Protocol>
TNAKACK2. setLevel(java.lang.String level)
-
Uses of Protocol in org.jgroups.protocols.relay
Subclasses of Protocol in org.jgroups.protocols.relay Modifier and Type Class Description class
RELAY
class
RELAY2
Design: ./doc/design/RELAY2.txt and at https://github.com/belaban/JGroups/blob/master/doc/design/RELAY2.txt.class
RELAY3
Provides relaying of messages between autonomous sites.
Design: ./doc/design/RELAY2.txt and at https://github.com/belaban/JGroups/blob/master/doc/design/RELAY2.txt.
JIRA: https://issues.redhat.com/browse/JGRP-1433 -
Uses of Protocol in org.jgroups.protocols.relay.config
Fields in org.jgroups.protocols.relay.config declared as Protocol Modifier and Type Field Description protected Protocol[]
RelayConfig.ProgrammaticBridgeConfig. protocols
Methods in org.jgroups.protocols.relay.config with parameters of type Protocol Modifier and Type Method Description protected static java.lang.String
RelayConfig.ProgrammaticBridgeConfig. printProtocols(Protocol[] protocols)
Constructors in org.jgroups.protocols.relay.config with parameters of type Protocol Constructor Description ProgrammaticBridgeConfig(java.lang.String cluster_name, Protocol[] prots)
-
Uses of Protocol in org.jgroups.stack
Subclasses of Protocol in org.jgroups.stack Modifier and Type Class Description class
ProtocolStack
A ProtocolStack manages a number of protocols layered above each other.Fields in org.jgroups.stack declared as Protocol Modifier and Type Field Description protected Protocol
ProtocolStack. bottom_prot
protected Protocol
Protocol. down_prot
protected Protocol
ProtocolStack. top_prot
protected Protocol
Protocol. up_prot
Fields in org.jgroups.stack with type parameters of type Protocol Modifier and Type Field Description protected static java.lang.Class<? extends Protocol>
CheckCallerRunsPolicy. NAKACK2
protected static java.lang.Class<? extends Protocol>
CheckForAbsenceOfRED. NAKACK2
protected static java.lang.Class<? extends Protocol>
CheckForAbsenceOfRED. RED
protected static java.lang.Class<? extends Protocol>
CheckCallerRunsPolicy. UNICAST3
protected static java.lang.Class<? extends Protocol>
CheckForAbsenceOfRED. UNICAST3
Methods in org.jgroups.stack with type parameters of type Protocol Modifier and Type Method Description <T extends Protocol>
TProtocol. addPolicy(Policy p)
<T extends Protocol>
TProtocol. addr(Address addr)
<T extends Protocol>
TProtocolStack. findProtocol(java.lang.Class<? extends Protocol> clazz)
<T extends Protocol>
TProtocolStack. findProtocol(java.lang.Class<? extends Protocol>... classes)
Finds the first protocol of a list and returns it.<T extends Protocol>
TProtocolStack. findProtocol(java.lang.String name)
Returns a given protocol or null if not foundstatic <T extends Protocol>
TProtocolStack. findProtocol(Protocol start, boolean down, java.lang.Class<? extends Protocol> clazz)
<T extends Protocol>
java.util.List<T>ProtocolStack. findProtocols(java.lang.String regexp)
<T extends Protocol>
TProtocolStack. getBottomProtocol()
<T extends Protocol>
TProtocol. getDownProtocol()
<T extends Protocol>
TProtocol. getUpProtocol()
<T extends Protocol>
TProtocol. level(java.lang.String level)
<T extends Protocol>
TProtocol. removePolicy(Policy p)
<T extends Protocol>
TProtocolStack. removeProtocol(java.lang.Class<? extends Protocol> prot)
<T extends Protocol>
TProtocolStack. removeProtocol(java.lang.Class<? extends Protocol>... protocols)
<T extends Protocol>
TProtocolStack. removeProtocol(java.lang.String prot_name)
Removes a protocol from the stack.<T extends Protocol>
TProtocolStack. removeProtocol(T prot)
<T extends Protocol>
TProtocol. setAddress(Address addr)
<T extends Protocol>
TProtocol. setDownProtocol(Protocol prot)
<T extends Protocol>
TProtocol. setErgonomics(boolean ergonomics)
<T extends Protocol>
TProtocol. setId(short id)
<T extends Protocol>
TProtocol. setLevel(java.lang.String level)
Sets the level of a logger.<T extends Protocol>
TProtocol. setPolicies(java.util.List<Policy> l)
<T extends Protocol>
TProtocol. setProtocolStack(ProtocolStack s)
<T extends Protocol>
TProtocol. setUpProtocol(Protocol prot)
<T extends Protocol>
TProtocol. setValue(java.lang.String name, java.lang.Object value)
Methods in org.jgroups.stack that return Protocol Modifier and Type Method Description static Protocol
Configurator. connectProtocols(java.util.List<Protocol> protocol_list)
Creates a protocol stack by iterating through the protocol list and connecting adjacent layers.protected static Protocol
Configurator. createLayer(ProtocolStack stack, ProtocolConfiguration config)
static Protocol
Configurator. createProtocol(java.lang.String prot_spec, ProtocolStack stack)
static Protocol
Configurator. createProtocol(java.lang.String prot_spec, ProtocolStack stack, boolean init_attrs)
Creates a new protocol given the protocol specification.protected Protocol
ProtocolStack. createProtocol(java.lang.String classname)
Protocol
ProtocolStack. getTopProtocol()
Protocol
Configurator. setupProtocolStack(java.util.List<ProtocolConfiguration> config)
static Protocol
Configurator. setupProtocolStack(java.util.List<ProtocolConfiguration> protocol_configs, ProtocolStack st)
Sets up the protocol stack.Methods in org.jgroups.stack that return types with arguments of type Protocol Modifier and Type Method Description static java.util.List<Protocol>
Configurator. createProtocols(java.util.List<ProtocolConfiguration> protocol_configs, ProtocolStack stack)
Takes a list of configurations, creates a protocol for each and returns all protocols in a list.static java.util.List<Protocol>
Configurator. createProtocolsAndInitializeAttrs(java.util.List<ProtocolConfiguration> cfgs, ProtocolStack st)
java.util.List<Protocol>
ProtocolStack. getProtocols()
Returns all protocols in a list, from top to bottom.Methods in org.jgroups.stack with parameters of type Protocol Modifier and Type Method Description ProtocolStack
ProtocolStack. addProtocol(Protocol prot)
Adds a protocol at the tail of the protocol listProtocolStack
ProtocolStack. addProtocols(Protocol... prots)
Adds a list of protocolsvoid
ProtocolHook. afterCreation(Protocol prot)
Called after all protocols have been created, connected and its attributes set, but beforeinit()
is called.ProtocolStack
ProtocolStack. bottomProtocol(Protocol bottom)
protected static void
ProtocolStack. callAfterCreationHook(Protocol prot, java.lang.String classname)
void
CheckCallerRunsPolicy. check(Protocol prot)
void
CheckForAbsenceOfRED. check(Protocol prot)
void
Policy. check(Protocol prot)
Checks that a condition is met in a given protocolprotected java.lang.reflect.Method
NonReflectiveProbeHandler. findMethod(Protocol prot, java.lang.String method_name, java.lang.String[] args)
static <T extends Protocol>
TProtocolStack. findProtocol(Protocol start, boolean down, java.lang.Class<? extends Protocol> clazz)
static void
ProtocolStack. initComponents(Protocol p, ProtocolConfiguration cfg)
NonReflectiveProbeHandler
NonReflectiveProbeHandler. initialize(Protocol[] protocols)
static void
Configurator. initializeAttrs(Protocol prot, ProtocolConfiguration config, StackType ip_version)
Sets the attributes in a given protocol from propertiesvoid
ProtocolStack. insertProtocol(Protocol prot, ProtocolStack.Position position, java.lang.Class<? extends Protocol> neighbor_prot)
void
ProtocolStack. insertProtocol(Protocol prot, ProtocolStack.Position position, java.lang.Class<? extends Protocol>... neighbor_prots)
void
ProtocolStack. insertProtocol(Protocol prot, ProtocolStack.Position position, java.lang.String neighbor_prot)
Inserts an already created (and initialized) protocol into the protocol list.void
ProtocolStack. insertProtocolAtTop(Protocol prot)
void
ProtocolStack. insertProtocolInStack(Protocol prot, Protocol neighbor, ProtocolStack.Position position)
protected static void
Configurator. removeProvidedDownServices(Protocol protocol, java.util.List<java.lang.Integer> events)
Removes all events provided by the protocol above protocol from eventsprotected static void
Configurator. removeProvidedUpServices(Protocol protocol, java.util.List<java.lang.Integer> events)
Removes all events provided by the protocol below protocol from eventsvoid
ProtocolStack. replaceProtocol(Protocol existing_prot, Protocol new_prot)
Replaces one protocol instance with another.<T extends Protocol>
TProtocol. setDownProtocol(Protocol prot)
<T extends Protocol>
TProtocol. setUpProtocol(Protocol prot)
ProtocolStack
ProtocolStack. topProtocol(Protocol top)
Method parameters in org.jgroups.stack with type arguments of type Protocol Modifier and Type Method Description ProtocolStack
ProtocolStack. addProtocols(java.util.List<Protocol> prots)
Adds a list of protocolsstatic Protocol
Configurator. connectProtocols(java.util.List<Protocol> protocol_list)
Creates a protocol stack by iterating through the protocol list and connecting adjacent layers.static void
Configurator. ensureValidBindAddresses(java.util.List<Protocol> protocols)
Makes sure that all fields annotated with @LocalAddress is (1) an InetAddress and (2) a valid address on any local network interface<T extends Protocol>
TProtocolStack. findProtocol(java.lang.Class<? extends Protocol> clazz)
static <T extends Protocol>
TProtocolStack. findProtocol(Protocol start, boolean down, java.lang.Class<? extends Protocol> clazz)
static java.util.List<java.net.InetAddress>
Configurator. getInetAddresses(java.util.List<Protocol> protocols)
static java.util.Map<java.lang.String,java.net.InetAddress>
Configurator. getInetAddresses2(java.util.List<Protocol> protocols)
Returns a map of protocol.attr/InetAddress tuplesNonReflectiveProbeHandler
NonReflectiveProbeHandler. initialize(java.util.Collection<Protocol> prots)
void
ProtocolStack. insertProtocol(Protocol prot, ProtocolStack.Position position, java.lang.Class<? extends Protocol> neighbor_prot)
<T extends Protocol>
TProtocolStack. removeProtocol(java.lang.Class<? extends Protocol> prot)
static void
Configurator. sanityCheck(java.util.List<Protocol> protocols)
Throws an exception if sanity check fails.static void
Configurator. setDefaultAddressValues(java.util.List<Protocol> protocols, StackType ip_version)
Processes fields and methods which are inet address related, and assigns them default values defined by (Property.defaultValueIPv4()
andProperty.defaultValueIPv6()
). -
Uses of Protocol in org.jgroups.util
Methods in org.jgroups.util that return Protocol Modifier and Type Method Description static Protocol[]
Util. getTestStack(Protocol... additional_protocols)
Returns a default stack for testing with transport = SHARED_LOOPBACKMethods in org.jgroups.util that return types with arguments of type Protocol Modifier and Type Method Description static java.lang.Class<? extends Protocol>[]
Util. getUnicastProtocols()
static java.lang.Class<? extends Protocol>
Util. loadProtocolClass(java.lang.String protocol_name, java.lang.Class<?> cl)
Methods in org.jgroups.util with parameters of type Protocol Modifier and Type Method Description static java.util.Map<java.lang.String,Metrics.Entry<java.lang.Object>>
Metrics. extract(Protocol p)
static java.util.Map<java.lang.String,Metrics.Entry<java.lang.Object>>
Metrics. extract(Protocol p, java.util.function.Predicate<java.lang.reflect.AccessibleObject> filter)
static Protocol[]
Util. getTestStack(Protocol... additional_protocols)
Returns a default stack for testing with transport = SHARED_LOOPBACK
-