org.jgroups.stack

Class Configurator

java.lang.Object

org.jgroups.stack.Configurator

public class Configurator
extends Object

The task if this class is to setup and configure the protocol stack. A string describing the desired setup, which is both the layering and the configuration of each layer, is given to the configurator which creates and configures the protocol stack and returns a reference to the top layer (Protocol).

Future functionality will include the capability to dynamically modify the layering of the protocol stack and the properties of each layer.

Author:

Bela Ban, Richard Achmatowicz

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Configurator.InetAddressInfo

Field Summary

Fields

Modifier and Type	Field and Description
protected static Log	log

Constructor Summary

Constructors

Constructor and Description
Configurator()
Configurator(ProtocolStack protocolStack)

Method Summary

Methods

Modifier and Type	Method and Description
static Protocol	connectProtocols(List<Protocol> protocol_list) Creates a protocol stack by iterating through the protocol list and connecting adjacent layers.
static Map<String,Map<String,Configurator.InetAddressInfo>>	createInetAddressMap(List<ProtocolConfiguration> protocol_configs, List<Protocol> protocols)
protected static Protocol	createLayer(ProtocolStack stack, ProtocolConfiguration config)
static Protocol	createProtocol(String prot_spec, ProtocolStack stack) Creates a new protocol given the protocol specification.
static StackType	determineIpVersionFromAddresses(Collection<InetAddress> addrs) This method takes a set of InetAddresses, represented by an inetAddressmap, and: - if the resulting set is non-empty, goes through to see if all InetAddress-related user settings have a consistent IP version: v4 or v6, and throws an exception if not - if the resulting set is empty, sets the default IP version based on available stacks and if a dual stack, stack preferences - sets the IP version to be used in the JGroups session
static void	ensureValidBindAddresses(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
static Collection<InetAddress>	getAddresses(Map<String,Map<String,Configurator.InetAddressInfo>> inetAddressMap) Returns all inet addresses found
static Object	getField(Field field, Object target)
static List<InetAddress>	getInetAddresses(List<Protocol> protocols)
static Object	getValueFromProtocol(Protocol protocol, Field field)
static Object	getValueFromProtocol(Protocol protocol, String field_name)
static boolean	isSetPropertyMethod(Method method)
static List<ProtocolConfiguration>	parseConfigurations(String configuration) Return a number of ProtocolConfigurations in a vector
static String	printConfigurations(Collection<ProtocolConfiguration> configs)
protected static String	printEvents(List<Integer> events)
static void	removeDeprecatedProperties(Object obj, Map<String,String> props)
protected static void	removeProvidedDownServices(Protocol protocol, List<Integer> events) Removes all events provided by the protocol above protocol from events
protected static void	removeProvidedUpServices(Protocol protocol, List<Integer> events) Removes all events provided by the protocol below protocol from events
static void	resolveAndAssignField(Object obj, Field field, Map<String,String> props)
static void	resolveAndAssignFields(Object obj, Map<String,String> props)
static void	resolveAndInvokePropertyMethod(Object obj, Method method, Map<String,String> props)
static void	resolveAndInvokePropertyMethods(Object obj, Map<String,String> props)
static void	sanityCheck(List<Protocol> protocols) Throws an exception if sanity check fails.
static void	setDefaultValues(List<Protocol> protocols)
static void	setDefaultValues(List<Protocol> protocols, StackType ip_version)
static void	setDefaultValues(List<ProtocolConfiguration> protocol_configs, List<Protocol> protocols, StackType ip_version)
static void	setField(Field field, Object target, Object value)
Protocol	setupProtocolStack(List<ProtocolConfiguration> config)
Protocol	setupProtocolStack(ProtocolStack copySource)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected static final Log log

Constructor Detail

Configurator

public Configurator()

Configurator

public Configurator(ProtocolStack protocolStack)

Method Detail

setupProtocolStack

public Protocol setupProtocolStack(List<ProtocolConfiguration> config)
                            throws Exception

Throws:

Exception

setupProtocolStack

public Protocol setupProtocolStack(ProtocolStack copySource)
                            throws Exception

Throws:

Exception

setDefaultValues

public static void setDefaultValues(List<Protocol> protocols)
                             throws Exception

Throws:

Exception

createProtocol

public static Protocol createProtocol(String prot_spec,
                      ProtocolStack stack)
                               throws Exception

Creates a new protocol given the protocol specification. Initializes the properties and starts the up and down handler threads.

Parameters:

prot_spec - The specification of the protocol. Same convention as for specifying a protocol stack. An exception will be thrown if the class cannot be created. Example:

"VERIFY_SUSPECT(timeout=1500)"

Note that no colons (:) have to be specified

stack - The protocol stack

Returns:

Protocol The newly created protocol

Throws:

Exception - Will be thrown when the new protocol cannot be created

connectProtocols

public static Protocol connectProtocols(List<Protocol> protocol_list)
                                 throws Exception

Creates a protocol stack by iterating through the protocol list and connecting adjacent layers. The list starts with the topmost layer and has the bottommost layer at the tail.

Parameters:

protocol_list - List of Protocol elements (from top to bottom)

Returns:

Protocol stack

Throws:

Exception

parseConfigurations

public static List<ProtocolConfiguration> parseConfigurations(String configuration)
                                                       throws Exception

Return a number of ProtocolConfigurations in a vector

Parameters:

configuration - protocol-stack configuration string

Returns:

List of ProtocolConfigurations

Throws:

Exception

printConfigurations

public static String printConfigurations(Collection<ProtocolConfiguration> configs)

createLayer

protected static Protocol createLayer(ProtocolStack stack,
                   ProtocolConfiguration config)
                               throws Exception

Throws:

Exception

sanityCheck

public static void sanityCheck(List<Protocol> protocols)
                        throws Exception

Throws an exception if sanity check fails. Possible sanity check is uniqueness of all protocol names

Throws:

Exception

printEvents

protected static String printEvents(List<Integer> events)

removeProvidedUpServices

protected static void removeProvidedUpServices(Protocol protocol,
                            List<Integer> events)

Removes all events provided by the protocol below protocol from events

Parameters:

protocol -

events -

removeProvidedDownServices

protected static void removeProvidedDownServices(Protocol protocol,
                              List<Integer> events)

Removes all events provided by the protocol above protocol from events

Parameters:

protocol -

events -

getAddresses

public static Collection<InetAddress> getAddresses(Map<String,Map<String,Configurator.InetAddressInfo>> inetAddressMap)
                                            throws Exception

Returns all inet addresses found

Throws:

Exception

determineIpVersionFromAddresses

public static StackType determineIpVersionFromAddresses(Collection<InetAddress> addrs)
                                                 throws Exception

This method takes a set of InetAddresses, represented by an inetAddressmap, and: - if the resulting set is non-empty, goes through to see if all InetAddress-related user settings have a consistent IP version: v4 or v6, and throws an exception if not - if the resulting set is empty, sets the default IP version based on available stacks and if a dual stack, stack preferences - sets the IP version to be used in the JGroups session

Returns:

StackType.IPv4 for IPv4, StackType.IPv6 for IPv6, StackType.Unknown if the version cannot be determined

Throws:

Exception

createInetAddressMap

public static Map<String,Map<String,Configurator.InetAddressInfo>> createInetAddressMap(List<ProtocolConfiguration> protocol_configs,
                                                                        List<Protocol> protocols)
                                                                                 throws Exception

Throws:

Exception

getInetAddresses

public static List<InetAddress> getInetAddresses(List<Protocol> protocols)
                                          throws Exception

Throws:

Exception

setDefaultValues

public static void setDefaultValues(List<ProtocolConfiguration> protocol_configs,
                    List<Protocol> protocols,
                    StackType ip_version)
                             throws Exception

Throws:

Exception

setDefaultValues

public static void setDefaultValues(List<Protocol> protocols,
                    StackType ip_version)
                             throws Exception

Throws:

Exception

ensureValidBindAddresses

public static void ensureValidBindAddresses(List<Protocol> protocols)
                                     throws Exception

Makes sure that all fields annotated with @LocalAddress is (1) an InetAddress and (2) a valid address on any local network interface

Parameters:

protocols -

Throws:

Exception

getValueFromProtocol

public static Object getValueFromProtocol(Protocol protocol,
                          Field field)
                                   throws IllegalAccessException

Throws:

IllegalAccessException

getValueFromProtocol

public static Object getValueFromProtocol(Protocol protocol,
                          String field_name)
                                   throws IllegalAccessException

Throws:

IllegalAccessException

resolveAndInvokePropertyMethods

public static void resolveAndInvokePropertyMethods(Object obj,
                                   Map<String,String> props)
                                            throws Exception

Throws:

Exception

resolveAndInvokePropertyMethod

public static void resolveAndInvokePropertyMethod(Object obj,
                                  Method method,
                                  Map<String,String> props)
                                           throws Exception

Throws:

Exception

resolveAndAssignFields

public static void resolveAndAssignFields(Object obj,
                          Map<String,String> props)
                                   throws Exception

Throws:

Exception

resolveAndAssignField

public static void resolveAndAssignField(Object obj,
                         Field field,
                         Map<String,String> props)
                                  throws Exception

Throws:

Exception

removeDeprecatedProperties

public static void removeDeprecatedProperties(Object obj,
                              Map<String,String> props)
                                       throws Exception

Throws:

Exception

isSetPropertyMethod

public static boolean isSetPropertyMethod(Method method)

setField

public static void setField(Field field,
            Object target,
            Object value)

getField

public static Object getField(Field field,
              Object target)