com.fr.third.jgroups.protocols

类 Discovery

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.Discovery

直接已知子类:

FILE_PING, JDBC_PING, PING, SHARED_LOOPBACK_PING, TCPGOSSIP, TCPPING

public abstract class Discovery
extends Protocol

The Discovery protocol retrieves the initial membership (used by GMS and MERGE3) by sending discovery requests. We do this in subclasses of Discovery, e.g. by mcasting a discovery request (PING) or, if gossiping is enabled, by contacting the GossipRouter (TCPGOSSIP).

The responses should allow us to determine the coordinator which we have to contact, e.g. in case we want to join the group, or to see if we have diverging views in case of MERGE2.

When we are a server (after having received the BECOME_SERVER event), we'll respond to discovery requests with a discovery response.

作者:

Bela Ban

字段概要

字段

限定符和类型	字段和说明
protected boolean	always_send_physical_addr_with_discovery_request 已过时。
protected boolean	async_discovery
protected boolean	break_on_coord_rsp
protected java.lang.String	cluster_name
protected Address	current_coord
protected long	discovery_rsp_expiry_time
protected boolean	force_sending_discovery_rsps
protected boolean	is_coord
protected boolean	is_leaving
protected boolean	is_server
protected Address	local_addr
protected int	max_members_in_discovery_request
protected java.util.List<Address>	members
protected int	num_discovery_requests
protected int	num_initial_members 已过时。
protected int	num_initial_srv_members 已过时。
protected java.util.Map<java.lang.Long,Responses>	ping_responses
protected boolean	return_entire_cache
protected long	stagger_timeout
protected long	timeout 已过时。
protected TimeScheduler	timer
protected boolean	transport_supports_multicasting
protected boolean	use_disk_cache
protected View	view
protected static byte[]	WHITESPACE

从类继承的字段 com.fr.third.jgroups.stack.Protocol

down_prot, ergonomics, id, log, name, stack, stats, up_prot

构造器概要

构造器

构造器和说明
Discovery()

方法概要

方法

限定符和类型	方法和说明
protected boolean	addDiscoveryResponseToCaches(Address mbr, java.lang.String logical_name, PhysicalAddress physical_addr)
protected void	addResponse(PingData rsp, boolean overwrite)
protected static java.lang.String	addressAsString(Address address)
void	addToCache(java.lang.String filename)
boolean	breakOnCoordResponse()
Discovery	breakOnCoordResponse(boolean flag)
protected static PingData	deserialize(byte[] data)
void	discoveryRequestReceived(Address sender, java.lang.String logical_name, PhysicalAddress physical_addr)
java.lang.Object	down(Event evt) An event is to be sent down the stack.
void	dumpCache(java.lang.String output_filename)
java.lang.String	findInitialMembersAsString()
Responses	findMembers(java.util.List<Address> members, boolean initial_discovery, boolean async)
protected abstract void	findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses) Fetches information (e.g. physical address, logical name) for the given member addresses.
boolean	forceDiscoveryResponses()
Discovery	forceDiscoveryResponses(boolean f)
java.lang.String	getCurrentCoord()
int	getNumberOfDiscoveryRequestsSent()
int	getNumInitialMembers() 已过时。
long	getTimeout()
java.lang.String	getView()
ViewId	getViewId()
void	handleConnect()
void	handleDisconnect()
protected void	handleDiscoveryResponse(PingData data, Address sender)
void	init() Called after instance has been created (null constructor) and before protocol is started.
protected boolean	isCoord(Address member)
abstract boolean	isDynamic()
protected boolean	isMergeRunning()
static Buffer	marshal(PingData data)
long	numInitialMembers() 已过时。
Discovery	numInitialMembers(int num) 已过时。
java.util.List<java.lang.Integer>	providedUpServices() List of events that are provided to layers above (they will be handled when sent down from above)
protected java.util.List<PingData>	read(java.io.InputStream in)
protected PingData	readPingData(byte[] buffer, int offset, int length)
void	resetStats()
boolean	returnEntireCache()
Discovery	returnEntireCache(boolean flag)
protected void	sendDiscoveryResponse(Address logical_addr, PhysicalAddress physical_addr, java.lang.String logical_name, Address sender, boolean coord)
protected byte[]	serializeWithoutView(PingData data) Creates a byte[] representation of the PingData, but DISCARDING the view it contains.
void	setForceSendingDiscoveryRsps(boolean flag)
void	setNumInitialMembers(int num) 已过时。
void	setTimeout(long timeout)
long	staggerTimeout()
Discovery	staggerTimeout(long timeout)
void	start() This method is called on a Channel.connect(String).
void	stop() This method is called on a Channel.disconnect().
long	timeout()
Discovery	timeout(long timeout)
java.lang.Object	up(Event evt) An event was received from the layer below.
boolean	useDiskCache()
Discovery	useDiskCache(boolean flag)
protected void	write(java.util.List<PingData> list, java.io.OutputStream out)

从类继承的方法 com.fr.third.jgroups.stack.Protocol

accept, destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, printStats, providedDownServices, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, statsEnabled, up

从类继承的方法 java.lang.Object

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

字段详细资料

timeout

@Deprecated
protected long timeout

已过时。

num_initial_members

@Deprecated
protected int num_initial_members

已过时。

num_initial_srv_members

@Deprecated
protected int num_initial_srv_members

已过时。

break_on_coord_rsp

protected boolean break_on_coord_rsp

return_entire_cache

protected boolean return_entire_cache

stagger_timeout

protected long stagger_timeout

force_sending_discovery_rsps

protected boolean force_sending_discovery_rsps

use_disk_cache

protected boolean use_disk_cache

always_send_physical_addr_with_discovery_request

@Deprecated
protected boolean always_send_physical_addr_with_discovery_request

已过时。

max_members_in_discovery_request

protected int max_members_in_discovery_request

discovery_rsp_expiry_time

protected long discovery_rsp_expiry_time

async_discovery

protected boolean async_discovery

num_discovery_requests

protected int num_discovery_requests

is_server

protected volatile boolean is_server

is_leaving

protected volatile boolean is_leaving

timer

protected TimeScheduler timer

view

protected View view

members

protected final java.util.List<Address> members

is_coord

protected boolean is_coord

local_addr

protected Address local_addr

current_coord

protected Address current_coord

cluster_name

protected java.lang.String cluster_name

ping_responses

protected final java.util.Map<java.lang.Long,Responses> ping_responses

transport_supports_multicasting

protected boolean transport_supports_multicasting

WHITESPACE

protected static final byte[] WHITESPACE

构造器详细资料

Discovery

public Discovery()

方法详细资料

setForceSendingDiscoveryRsps

public void setForceSendingDiscoveryRsps(boolean flag)

init

public void init()
          throws java.lang.Exception

从类复制的说明: Protocol

Called after instance has been created (null constructor) and before protocol is started. Properties are already set. Other protocols are not yet connected and events cannot yet be sent.

覆盖:

init 在类中 Protocol

抛出:

java.lang.Exception - Thrown if protocol cannot be initialized successfully. This will cause the ProtocolStack to fail, so the channel constructor will throw an exception

isDynamic

public abstract boolean isDynamic()

handleDisconnect

public void handleDisconnect()

handleConnect

public void handleConnect()

discoveryRequestReceived

public void discoveryRequestReceived(Address sender,
                            java.lang.String logical_name,
                            PhysicalAddress physical_addr)

getTimeout

public long getTimeout()

setTimeout

public void setTimeout(long timeout)

getNumInitialMembers

@Deprecated
public int getNumInitialMembers()

已过时。

setNumInitialMembers

@Deprecated
public void setNumInitialMembers(int num)

已过时。

getNumberOfDiscoveryRequestsSent

public int getNumberOfDiscoveryRequestsSent()

timeout

public long timeout()

timeout

public Discovery timeout(long timeout)

numInitialMembers

@Deprecated
public long numInitialMembers()

已过时。

numInitialMembers

@Deprecated
public Discovery numInitialMembers(int num)

已过时。

breakOnCoordResponse

public boolean breakOnCoordResponse()

breakOnCoordResponse

public Discovery breakOnCoordResponse(boolean flag)

returnEntireCache

public boolean returnEntireCache()

returnEntireCache

public Discovery returnEntireCache(boolean flag)

staggerTimeout

public long staggerTimeout()

staggerTimeout

public Discovery staggerTimeout(long timeout)

forceDiscoveryResponses

public boolean forceDiscoveryResponses()

forceDiscoveryResponses

public Discovery forceDiscoveryResponses(boolean f)

useDiskCache

public boolean useDiskCache()

useDiskCache

public Discovery useDiskCache(boolean flag)

getView

public java.lang.String getView()

getViewId

public ViewId getViewId()

getCurrentCoord

public java.lang.String getCurrentCoord()

isMergeRunning

protected boolean isMergeRunning()

providedUpServices

public java.util.List<java.lang.Integer> providedUpServices()

从类复制的说明: Protocol

List of events that are provided to layers above (they will be handled when sent down from above)

覆盖:

providedUpServices 在类中 Protocol

resetStats

public void resetStats()

覆盖:

resetStats 在类中 Protocol

start

public void start()
           throws java.lang.Exception

从类复制的说明: Protocol

This method is called on a Channel.connect(String). Starts work. Protocols are connected and queues are ready to receive events. Will be called from bottom to top. This call will replace the START and START_OK events.

覆盖:

start 在类中 Protocol

抛出:

java.lang.Exception - Thrown if protocol cannot be started successfully. This will cause the ProtocolStack to fail, so Channel.connect(String) will throw an exception

stop

public void stop()

从类复制的说明: Protocol

This method is called on a Channel.disconnect(). Stops work (e.g. by closing multicast socket). Will be called from top to bottom. This means that at the time of the method invocation the neighbor protocol below is still working. This method will replace the STOP, STOP_OK, CLEANUP and CLEANUP_OK events. The ProtocolStack guarantees that when this method is called all messages in the down queue will have been flushed

覆盖:

stop 在类中 Protocol

findMembers

protected abstract void findMembers(java.util.List<Address> members,
               boolean initial_discovery,
               Responses responses)

Fetches information (e.g. physical address, logical name) for the given member addresses. Needs to add responses to the Responses object. If async_discovery is true, this method will be called in a separate thread, otherwise the caller's thread will be used.

参数:

members - A list of logical addresses (typically UUIDs). If null, then information for all members is fetched

initial_discovery - Set to true if this is for the initial membership discovery. Some protocols (e.g. file based ones) may return only the information for the coordinator(s).

responses - The list to which responses should be added

findMembers

public Responses findMembers(java.util.List<Address> members,
                    boolean initial_discovery,
                    boolean async)

findInitialMembersAsString

public java.lang.String findInitialMembersAsString()

addToCache

public void addToCache(java.lang.String filename)
                throws java.lang.Exception

抛出:

java.lang.Exception

dumpCache

public void dumpCache(java.lang.String output_filename)
               throws java.lang.Exception

抛出:

java.lang.Exception

up

public java.lang.Object up(Event evt)

从类复制的说明: Protocol

An event was received from the layer below. Usually the current layer will want to examine the event type and - depending on its type - perform some computation (e.g. removing headers from a MSG event type, or updating the internal membership list when receiving a VIEW_CHANGE event). Finally the event is either a) discarded, or b) an event is sent down the stack using down_prot.down() or c) the event (or another event) is sent up the stack using up_prot.up().

覆盖:

up 在类中 Protocol

handleDiscoveryResponse

protected void handleDiscoveryResponse(PingData data,
                           Address sender)

down

public java.lang.Object down(Event evt)

从类复制的说明: Protocol

An event is to be sent down the stack. The layer may want to examine its type and perform some action on it, depending on the event's type. If the event is a message MSG, then the layer may need to add a header to it (or do nothing at all) before sending it down the stack using down_prot.down(). In case of a GET_ADDRESS event (which tries to retrieve the stack's address from one of the bottom layers), the layer may need to send a new response event back up the stack using up_prot.up().

覆盖:

down 在类中 Protocol

read

protected java.util.List<PingData> read(java.io.InputStream in)

write

protected void write(java.util.List<PingData> list,
         java.io.OutputStream out)
              throws java.lang.Exception

抛出:

java.lang.Exception

addResponse

protected void addResponse(PingData rsp,
               boolean overwrite)

addDiscoveryResponseToCaches

protected boolean addDiscoveryResponseToCaches(Address mbr,
                                   java.lang.String logical_name,
                                   PhysicalAddress physical_addr)

serializeWithoutView

protected byte[] serializeWithoutView(PingData data)

Creates a byte[] representation of the PingData, but DISCARDING the view it contains.

参数:

data - the PingData instance to serialize.

返回:

deserialize

protected static PingData deserialize(byte[] data)
                               throws java.lang.Exception

抛出:

java.lang.Exception

marshal

public static Buffer marshal(PingData data)

readPingData

protected PingData readPingData(byte[] buffer,
                    int offset,
                    int length)

sendDiscoveryResponse

protected void sendDiscoveryResponse(Address logical_addr,
                         PhysicalAddress physical_addr,
                         java.lang.String logical_name,
                         Address sender,
                         boolean coord)

addressAsString

protected static java.lang.String addressAsString(Address address)

isCoord

protected boolean isCoord(Address member)