public class SWIFT_PING extends FILE_PING
Modifier and Type | Class and Description |
---|---|
protected static class |
SWIFT_PING.SwiftClient
A thread safe Swift client
|
FILE_PING.InfoWriter
Discovery.DiscoveryCacheDisseminationTask
Modifier and Type | Field and Description |
---|---|
protected String |
auth_type |
protected String |
auth_url |
protected String |
container |
protected String |
password |
protected SWIFT_PING.SwiftClient |
swiftClient |
protected String |
tenant |
protected String |
username |
filter, info_writer, info_writer_max_writes_after_view, info_writer_sleep_time, interval, location, reads, regexp, remove_all_files_on_view_change, remove_old_coords_on_view_change, root_dir, SUFFIX, 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, name, stack, stats, up_prot
Constructor and Description |
---|
SWIFT_PING() |
Modifier and Type | Method and Description |
---|---|
protected void |
createRootDir() |
void |
init()
Called after instance has been created (null constructor) and before protocol is started.
|
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
|
protected void |
write(List<PingData> list,
String clustername) |
addDiscoveryResponseToCaches, addressToFilename, deleteFile, down, findMembers, handleView, isDynamic, isInfoWriterRunning, read, read, resetStats, startInfoWriter, stopInfoWriter, write, writeAll, 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 SWIFT_PING.SwiftClient swiftClient
protected String auth_url
protected String auth_type
protected String tenant
protected String username
protected String password
protected String container
public void init() throws Exception
Protocol
protected void createRootDir()
createRootDir
in class FILE_PING
Copyright © 2019 JBoss, a division of Red Hat. All rights reserved.