public class TCPPING extends Discovery
Discovery.Responses
Modifier and Type | Field and Description |
---|---|
protected BoundedList<PhysicalAddress> |
dynamic_hosts
https://jira.jboss.org/jira/browse/JGRP-989
|
protected int |
max_dynamic_hosts |
always_send_physical_addr_with_discovery_request, break_on_coord_rsp, current_coord, force_sending_discovery_rsps, group_addr, is_coord, is_leaving, is_server, local_addr, members, num_discovery_requests, num_initial_members, num_initial_srv_members, ping_responses, return_entire_cache, stagger_timeout, timeout, timer, use_disk_cache, view
Constructor and Description |
---|
TCPPING() |
Modifier and Type | Method and Description |
---|---|
void |
clearDynamicHostList() |
void |
discoveryRequestReceived(Address sender,
String logical_name,
Collection<PhysicalAddress> physical_addrs) |
Object |
down(Event evt)
An event is to be sent down the stack.
|
Collection<PhysicalAddress> |
fetchClusterMembers(String cluster_name)
Grab all current cluster members
|
String |
getDynamicHostList() |
List<IpAddress> |
getInitialHosts()
Returns the list of initial hosts as configured by the user via XML.
|
String |
getInitialHostsList() |
int |
getPortRange() |
void |
init()
Called after instance has been created (null constructor) and before protocol is started.
|
boolean |
isDynamic() |
boolean |
sendDiscoveryRequestsInParallel()
Whether or not to send each discovery request on a separate (timer) thread.
|
void |
setInitialHosts(List<IpAddress> initial_hosts) |
void |
setPortRange(int port_range) |
breakOnCoordResponse, breakOnCoordResponse, deserialize, findAllViews, findAllViewsAsString, findInitialMembers, findInitialMembersAsString, findMembers, forceDiscoveryResponses, forceDiscoveryResponses, getCurrentCoord, getNumberOfDiscoveryRequestsSent, getNumInitialMembers, getTimeout, getView, getViewId, handleConnect, handleDisconnect, isMergeRunning, marshal, numInitialMembers, numInitialMembers, providedUpServices, readPingData, resetStats, returnEntireCache, returnEntireCache, sendDiscoveryRequest, sendDiscoveryResponse, sendMcastDiscoveryRequest, serializeWithoutView, setForceSendingDiscoveryRsps, setNumInitialMembers, setTimeout, staggerTimeout, staggerTimeout, start, stop, timeout, timeout, up, useDiskCache, useDiskCache
accept, destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, printStats, providedDownServices, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, statsEnabled, up
protected int max_dynamic_hosts
protected BoundedList<PhysicalAddress> dynamic_hosts
public List<IpAddress> getInitialHosts()
public int getPortRange()
public void setPortRange(int port_range)
public String getDynamicHostList()
public void clearDynamicHostList()
public String getInitialHostsList()
public void init() throws Exception
Protocol
public Collection<PhysicalAddress> fetchClusterMembers(String cluster_name)
Discovery
fetchClusterMembers
in class Discovery
public boolean sendDiscoveryRequestsInParallel()
Discovery
Discovery.fetchClusterMembers(String)
sequentiallysendDiscoveryRequestsInParallel
in class Discovery
public Object down(Event evt)
Discovery
PassDown
. 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()
.
The PING protocol is interested in several different down events,
Event.FIND_INITIAL_MBRS - sent by the GMS layer and expecting a GET_MBRS_OK
Event.TMP_VIEW and Event.VIEW_CHANGE - a view change event
Event.BECOME_SERVER - called after client has joined and is fully working group member
Event.CONNECT, Event.DISCONNECT.public void discoveryRequestReceived(Address sender, String logical_name, Collection<PhysicalAddress> physical_addrs)
discoveryRequestReceived
in class Discovery
Copyright © 2014 JBoss, a division of Red Hat. All rights reserved.