public class DNS_PING extends Discovery
Discovery.DiscoveryCacheDisseminationTask
Modifier and Type | Field and Description |
---|---|
protected BoundedList<Address> |
discovered_hosts |
protected java.lang.String |
dns_address |
protected java.lang.String |
dns_context_factory |
protected java.lang.String |
dns_query |
protected java.lang.String |
dns_record_type |
protected DNSResolver |
dns_resolver |
async_discovery, async_discovery_use_separate_thread_per_request, break_on_coord_rsp, cluster_name, current_coord, discovery_rsp_expiry_time, is_coord, is_leaving, is_server, local_addr, max_members_in_discovery_request, max_rank_to_reply, num_discovery_requests, ping_responses, return_entire_cache, send_cache_on_join, sends_can_block, stagger_timeout, timer, transport_supports_multicasting, use_disk_cache, use_ip_addrs, view, WHITESPACE
after_creation_hook, down_prot, ergonomics, id, log, stack, stats, up_prot
Constructor and Description |
---|
DNS_PING() |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
This method is called on a
JChannel.close() . |
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 |
findMembers(java.util.List<Address> members,
boolean initial_discovery,
Responses responses)
Fetches information (e.g.
|
void |
init()
Called after instance has been created (null constructor) and before protocol is started.
|
boolean |
isDynamic() |
protected void |
sendDiscoveryRequest(Message req) |
protected void |
validateProperties() |
addDiscoveryResponseToCaches, addResponse, addResponse, addressAsString, addToCache, breakOnCoordResponse, breakOnCoordResponse, deserialize, discoveryRspExpiryTime, disseminateDiscoveryInformation, dumpCache, findInitialMembersAsString, findMembers, getCurrentCoord, getNumberOfDiscoveryRequestsSent, getView, getViewId, handleConnect, handleDisconnect, handleDiscoveryResponse, isCoord, isMergeRunning, marshal, providedUpServices, read, readPingData, resetStats, returnEntireCache, returnEntireCache, sendCacheInformation, sendDiscoveryResponse, serializeWithoutView, staggerTimeout, staggerTimeout, start, startCacheDissemination, stop, up, up, useDiskCache, useDiskCache, weedOutCompletedDiscoveryResponses, write
accept, afterCreationHook, 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, setProperties, setProtocolStack, setSocketFactory, setUpProtocol, setValue, statsEnabled, up
protected java.lang.String dns_context_factory
protected java.lang.String dns_address
protected java.lang.String dns_record_type
protected java.lang.String dns_query
protected volatile DNSResolver dns_resolver
protected BoundedList<Address> discovered_hosts
public void init() throws java.lang.Exception
Protocol
protected void validateProperties()
public void destroy()
Protocol
JChannel.close()
.
Does some cleanup; after the call the VM will terminatepublic java.lang.Object down(Event evt)
Protocol
down_prot.down()
.public void discoveryRequestReceived(Address sender, java.lang.String logical_name, PhysicalAddress physical_addr)
discoveryRequestReceived
in class Discovery
public void findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses)
Discovery
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
in class Discovery
members
- A list of logical addresses (typically UUID
s). If null, then information
for all members is fetchedinitial_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 addedprotected void sendDiscoveryRequest(Message req)
Copyright © 1998-2020 Red Hat. All Rights Reserved.