com.fr.third.jgroups.protocols

类 PING

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.Discovery

com.fr.third.jgroups.protocols.PING

直接已知子类:

BPING, MPING

public class PING
extends Discovery

The PING protocol retrieves the initial membership by mcasting a discovery request (via the multicast capable transport) to all current cluster members

The responses should allow us to determine the coordinator which we have to contact, e.g. in case we want to join the group. When we are a server (after having received the BECOME_SERVER event), we'll respond to discovery requests with a discovery response.

作者:

Bela Ban

字段概要

从类继承的字段 com.fr.third.jgroups.protocols.Discovery

always_send_physical_addr_with_discovery_request, async_discovery, break_on_coord_rsp, cluster_name, current_coord, discovery_rsp_expiry_time, force_sending_discovery_rsps, is_coord, is_leaving, is_server, local_addr, max_members_in_discovery_request, members, num_discovery_requests, num_initial_members, num_initial_srv_members, ping_responses, return_entire_cache, stagger_timeout, timeout, timer, transport_supports_multicasting, use_disk_cache, view, WHITESPACE

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

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

构造器概要

构造器

构造器和说明
PING()

方法概要

方法

限定符和类型	方法和说明
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	isDynamic()
protected void	sendDiscoveryRequest(java.lang.String cluster_name, java.util.List<Address> members_to_find)
protected void	sendMcastDiscoveryRequest(Message msg)

从类继承的方法 com.fr.third.jgroups.protocols.Discovery

addDiscoveryResponseToCaches, addResponse, addressAsString, addToCache, breakOnCoordResponse, breakOnCoordResponse, deserialize, discoveryRequestReceived, down, dumpCache, findInitialMembersAsString, findMembers, forceDiscoveryResponses, forceDiscoveryResponses, getCurrentCoord, getNumberOfDiscoveryRequestsSent, getNumInitialMembers, getTimeout, getView, getViewId, handleConnect, handleDisconnect, handleDiscoveryResponse, init, isCoord, isMergeRunning, marshal, numInitialMembers, numInitialMembers, providedUpServices, read, readPingData, resetStats, returnEntireCache, returnEntireCache, sendDiscoveryResponse, serializeWithoutView, setForceSendingDiscoveryRsps, setNumInitialMembers, setTimeout, staggerTimeout, staggerTimeout, start, stop, timeout, timeout, up, useDiskCache, useDiskCache, write

从类继承的方法 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

构造器详细资料

PING

public PING()

方法详细资料

isDynamic

public boolean isDynamic()

指定者:

isDynamic 在类中 Discovery

findMembers

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

从类复制的说明: Discovery

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

指定者:

findMembers 在类中 Discovery

参数:

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

sendDiscoveryRequest

protected void sendDiscoveryRequest(java.lang.String cluster_name,
                        java.util.List<Address> members_to_find)
                             throws java.lang.Exception

抛出:

java.lang.Exception

sendMcastDiscoveryRequest

protected void sendMcastDiscoveryRequest(Message msg)