public class FILE_PING extends Discovery
Modifier and Type | Class and Description |
---|---|
protected class |
FILE_PING.InfoWriter
Class which calls writeAll() a few times.
|
Discovery.DiscoveryCacheDisseminationTask
Modifier and Type | Field and Description |
---|---|
protected static FilenameFilter |
filter |
protected Future<?> |
info_writer |
protected int |
info_writer_max_writes_after_view |
protected long |
info_writer_sleep_time |
protected long |
interval
Deprecated.
|
protected String |
location |
protected int |
reads |
protected static Pattern |
regexp |
protected boolean |
remove_all_files_on_view_change |
protected boolean |
remove_old_coords_on_view_change |
protected File |
root_dir |
protected static String |
SUFFIX |
protected int |
writes |
always_send_physical_addr_with_discovery_request, async_discovery, async_discovery_use_separate_thread_per_request, 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, send_cache_on_join, stagger_timeout, timeout, timer, transport_supports_multicasting, use_disk_cache, view, WHITESPACE
after_creation_hook, down_prot, ergonomics, id, log, name, stack, stats, up_prot
Constructor and Description |
---|
FILE_PING() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
addDiscoveryResponseToCaches(Address mbr,
String logical_name,
PhysicalAddress physical_addr)
Only add the discovery response if the logical address is not present or the physical addrs are different
|
protected static String |
addressToFilename(Address mbr) |
protected void |
createRootDir() |
protected boolean |
deleteFile(File file) |
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.
|
protected void |
handleView(View new_view,
View old_view,
boolean coord_changed) |
void |
init()
Called after instance has been created (null constructor) and before protocol is started.
|
boolean |
isDynamic() |
boolean |
isInfoWriterRunning() |
protected List<PingData> |
read(File file) |
protected List<PingData> |
read(InputStream in) |
protected void |
readAll(List<Address> members,
String clustername,
Responses responses) |
protected void |
remove(String clustername,
Address addr) |
protected void |
removeAll(String clustername)
Removes all files for the given cluster name
|
void |
resetStats() |
protected void |
startInfoWriter() |
protected void |
stopInfoWriter() |
protected void |
write(List<PingData> list,
OutputStream out) |
protected void |
write(List<PingData> list,
String clustername) |
protected void |
writeAll()
Write information about all of the member to file (only if I'm the coord)
|
void |
writeInfo() |
addResponse, addressAsString, addToCache, breakOnCoordResponse, breakOnCoordResponse, deserialize, discoveryRequestReceived, discoveryRspExpiryTime, disseminateDiscoveryInformation, dumpCache, findInitialMembersAsString, findMembers, forceDiscoveryResponses, forceDiscoveryResponses, getCurrentCoord, getNumberOfDiscoveryRequestsSent, getNumInitialMembers, getTimeout, getView, getViewId, handleConnect, handleDisconnect, handleDiscoveryResponse, isCoord, isMergeRunning, marshal, numInitialMembers, numInitialMembers, providedUpServices, readPingData, returnEntireCache, returnEntireCache, sendCacheInformation, sendDiscoveryResponse, serializeWithoutView, setForceSendingDiscoveryRsps, setNumInitialMembers, setTimeout, staggerTimeout, staggerTimeout, start, startCacheDissemination, stop, timeout, timeout, up, useDiskCache, useDiskCache, weedOutCompletedDiscoveryResponses
accept, afterCreationHook, destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, 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
protected static final String SUFFIX
protected static final Pattern regexp
protected String location
@Deprecated protected long interval
protected boolean remove_old_coords_on_view_change
protected boolean remove_all_files_on_view_change
protected int info_writer_max_writes_after_view
protected long info_writer_sleep_time
protected int writes
protected int reads
protected File root_dir
protected static final FilenameFilter filter
protected Future<?> info_writer
public boolean isInfoWriterRunning()
public void writeInfo()
public void init() throws Exception
Protocol
public void resetStats()
resetStats
in class Discovery
public Object down(Event evt)
Protocol
down_prot.down()
. 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()
.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 boolean addDiscoveryResponseToCaches(Address mbr, String logical_name, PhysicalAddress physical_addr)
addDiscoveryResponseToCaches
in class Discovery
protected void createRootDir()
protected void removeAll(String clustername)
protected List<PingData> read(InputStream in)
protected void writeAll()
protected void write(List<PingData> list, OutputStream out) throws Exception
protected boolean deleteFile(File file)
protected void startInfoWriter()
protected void stopInfoWriter()
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.