Package org.jgroups.protocols
Class MULTI_PING
- java.lang.Object
- 
- org.jgroups.stack.Protocol
- 
- org.jgroups.protocols.Discovery
- 
- org.jgroups.protocols.MULTI_PING
 
 
 
- 
 public class MULTI_PING extends Discovery Protocol to invoke multiple discovery protocols in the same stack. All discovery protocols needs to be _below_ this one, e.g.<TCP.../> <TCPPING initial_hosts="127.0.0.1[7800]"/> <PING /> <MPING/> <FILE_PING/> <MULTI_PING async_discovery="true"/> <MERGE3 .../> ...- Since:
- 4.0.8
- Author:
- Bela Ban
 
- 
- 
Nested Class Summary- 
Nested classes/interfaces inherited from class org.jgroups.protocols.DiscoveryDiscovery.DiscoveryCacheDisseminationTask
 
- 
 - 
Field SummaryFields Modifier and Type Field Description protected java.util.List<Discovery>discovery_protocols- 
Fields inherited from class org.jgroups.protocols.Discoveryasync_discovery, async_discovery_use_separate_thread_per_request, break_on_coord_rsp, cluster_name, current_coord, discovery_req_futures, discovery_rsp_callback, discovery_rsp_expiry_time, is_coord, is_leaving, is_server, local_addr, max_members_in_discovery_request, max_rank_to_reply, num_discovery_requests, num_discovery_runs, ping_responses, return_entire_cache, send_cache_on_join, sends_can_block, stagger_timeout, timer, transport, transport_supports_multicasting, use_disk_cache, use_ip_addrs, view, WHITESPACE
 - 
Fields inherited from class org.jgroups.stack.Protocolafter_creation_hook, down_prot, ergonomics, id, log, stack, stats, up_prot
 
- 
 - 
Constructor SummaryConstructors Constructor Description MULTI_PING()
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidfindMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)Fetches information (e.g.protected voidfindMembers(java.util.List<Address> members, boolean initial_discovery, Responses rsps, boolean async)java.lang.StringgetDiscoveryProtocols()voidinit()Called after instance has been created (null constructor) and before protocol is started.protected voidinvokeFindMembers(java.util.List<Address> members, boolean initial_discovery, Responses rsps, boolean async)booleanisDynamic()voidweedOutCompletedDiscoveryResponses()Removes responses which are done or whose timeout has expired (in the latter case, an expired response is marked as done)- 
Methods inherited from class org.jgroups.protocols.DiscoveryaddDiscoveryResponseToCaches, addResponse, addResponse, addressAsString, addToCache, breakOnCoordResponse, breakOnCoordResponse, clearRequestFutures, deserialize, discoveryRequestReceived, discoveryRspExpiryTime, disseminateDiscoveryInformation, down, dumpCache, findInitialMembersAsString, findMembers, getClusterName, getCurrentCoord, getNumberOfDiscoveryRequestsSent, getView, getViewId, handleConnect, handleDisconnect, handleDiscoveryResponse, isCoord, isMergeRunning, marshal, providedUpServices, read, readPingData, resetStats, returnEntireCache, returnEntireCache, sendCacheInformation, sendDiscoveryResponse, serializeWithoutView, setClusterName, staggerTimeout, staggerTimeout, start, startCacheDissemination, stop, up, up, useDiskCache, useDiskCache, write
 - 
Methods inherited from class org.jgroups.stack.Protocolaccept, afterCreationHook, destroy, down, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, providedDownServices, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, statsEnabled, up
 
- 
 
- 
- 
- 
Field Detail- 
discovery_protocolsprotected final java.util.List<Discovery> discovery_protocols 
 
- 
 - 
Method Detail- 
getDiscoveryProtocolspublic java.lang.String getDiscoveryProtocols() 
 - 
initpublic void init() throws java.lang.ExceptionDescription copied from class:ProtocolCalled 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.
 - 
weedOutCompletedDiscoveryResponsespublic void weedOutCompletedDiscoveryResponses() Description copied from class:DiscoveryRemoves responses which are done or whose timeout has expired (in the latter case, an expired response is marked as done)- Overrides:
- weedOutCompletedDiscoveryResponsesin class- Discovery
 
 - 
findMembersprotected void findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses) Description copied from class:DiscoveryFetches information (e.g. physical address, logical name) for the given member addresses. Needs to add responses to theResponsesobject. IfDiscovery.async_discoveryis true, this method will be called in a separate thread, otherwise the caller's thread will be used.- Specified by:
- findMembersin class- Discovery
- Parameters:
- 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
 
 - 
invokeFindMembersprotected void invokeFindMembers(java.util.List<Address> members, boolean initial_discovery, Responses rsps, boolean async) Description copied from class:Discovery- Overrides:
- invokeFindMembersin class- Discovery
 
 
- 
 
-