public class TCPPING extends Discovery
Discovery.DiscoveryCacheDisseminationTask
Modifier and Type | Field and Description |
---|---|
protected BoundedList<PhysicalAddress> |
dynamic_hosts
https://jira.jboss.org/jira/browse/JGRP-989
|
protected List<PhysicalAddress> |
initial_hosts |
protected int |
max_dynamic_hosts |
protected int |
port_range |
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 |
---|
TCPPING() |
Modifier and Type | Method and Description |
---|---|
void |
clearDynamicHostList() |
void |
discoveryRequestReceived(Address sender,
String logical_name,
PhysicalAddress physical_addr) |
Object |
down(Event evt)
An event is to be sent down the stack.
|
void |
findMembers(List<Address> members,
boolean initial_discovery,
Responses responses)
Fetches information (e.g.
|
String |
getDynamicHostList() |
List<PhysicalAddress> |
getInitialHosts()
Returns the list of initial hosts as configured by the user via XML.
|
int |
getPortRange() |
void |
init()
Called after instance has been created (null constructor) and before protocol is started.
|
boolean |
isDynamic() |
protected void |
sendDiscoveryRequest(Message req) |
void |
setInitialHosts(Collection<InetSocketAddress> hosts) |
void |
setInitialHosts(List<PhysicalAddress> initial_hosts)
Deprecated.
Use
setInitialHosts(Collection) instead (will later get renamed to setInitialHosts()) |
void |
setPortRange(int port_range) |
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, 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, setProperties, setProtocolStack, setSocketFactory, setUpProtocol, setValue, statsEnabled, up
protected int port_range
protected List<PhysicalAddress> initial_hosts
protected int max_dynamic_hosts
protected BoundedList<PhysicalAddress> dynamic_hosts
public List<PhysicalAddress> getInitialHosts()
@Deprecated public void setInitialHosts(List<PhysicalAddress> initial_hosts)
setInitialHosts(Collection)
instead (will later get renamed to setInitialHosts())public void setInitialHosts(Collection<InetSocketAddress> hosts)
public int getPortRange()
public void setPortRange(int port_range)
public String getDynamicHostList()
public void clearDynamicHostList()
public void init() throws Exception
Protocol
public Object down(Event evt)
Protocol
down_prot.down()
.public void discoveryRequestReceived(Address sender, String logical_name, PhysicalAddress physical_addr)
discoveryRequestReceived
in class Discovery
public void findMembers(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 © 2018 JBoss, a division of Red Hat. All rights reserved.