com.fr.third.jgroups.protocols

类 FILE_PING

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.Discovery

com.fr.third.jgroups.protocols.FILE_PING

直接已知子类:

RACKSPACE_PING, S3_PING, SWIFT_PING

public class FILE_PING
extends Discovery

Simple discovery protocol which uses a file on shared storage such as an SMB share, NFS mount or S3. The local address information, e.g. UUID and physical addresses mappings are written to the file and the content is read and added to our transport's UUID-PhysicalAddress cache.

The design is at doc/design/FILE_PING.txt

作者:

Bela Ban

字段概要

字段

限定符和类型	字段和说明
protected static java.io.FilenameFilter	filter
protected long	interval 已过时。
protected java.lang.String	location
protected View	prev_view
protected int	reads
protected java.io.File	root_dir
protected static java.lang.String	SUFFIX
protected int	writes

从类继承的字段 com.fr.third.jgroups.protocols.Discovery

always_send_physical_addr_with_discovery_request, async_discovery, 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, stagger_timeout, timeout, timer, transport_supports_multicasting, use_disk_cache, view, WHITESPACE

从类继承的字段 com.fr.third.jgroups.stack.Protocol

down_prot, ergonomics, id, log, name, stack, stats, up_prot

构造器概要

构造器

构造器和说明
FILE_PING()

方法概要

方法

限定符和类型	方法和说明
protected boolean	addDiscoveryResponseToCaches(Address mbr, java.lang.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 java.lang.String	addressToFilename(Address mbr)
protected void	createRootDir()
protected boolean	deleteFile(java.io.File file)
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. physical address, logical name) for the given member addresses.
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()
protected java.util.List<PingData>	read(java.io.File file)
protected java.util.List<PingData>	read(java.io.InputStream in)
protected void	readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
protected void	remove(java.lang.String clustername, Address addr)
void	resetStats()
protected void	write(java.util.List<PingData> list, java.io.OutputStream out)
protected void	write(java.util.List<PingData> list, java.lang.String clustername)
protected void	writeAll() Write information about all of the member to file (only if I'm the coord)

从类继承的方法 com.fr.third.jgroups.protocols.Discovery

addResponse, addressAsString, addToCache, breakOnCoordResponse, breakOnCoordResponse, deserialize, discoveryRequestReceived, dumpCache, findInitialMembersAsString, findMembers, forceDiscoveryResponses, forceDiscoveryResponses, getCurrentCoord, getNumberOfDiscoveryRequestsSent, getNumInitialMembers, getTimeout, getView, getViewId, handleConnect, handleDisconnect, handleDiscoveryResponse, isCoord, isMergeRunning, marshal, numInitialMembers, numInitialMembers, providedUpServices, readPingData, returnEntireCache, returnEntireCache, sendDiscoveryResponse, serializeWithoutView, setForceSendingDiscoveryRsps, setNumInitialMembers, setTimeout, staggerTimeout, staggerTimeout, start, stop, timeout, timeout, up, useDiskCache, useDiskCache

从类继承的方法 com.fr.third.jgroups.stack.Protocol

accept, destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, 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

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

SUFFIX

protected static final java.lang.String SUFFIX

另请参阅:

常量字段值

location

protected java.lang.String location

interval

@Deprecated
protected long interval

已过时。

writes

protected int writes

reads

protected int reads

root_dir

protected java.io.File root_dir

filter

protected static final java.io.FilenameFilter filter

prev_view

protected volatile View prev_view

构造器详细资料

FILE_PING

public FILE_PING()

方法详细资料

isDynamic

public boolean isDynamic()

指定者:

isDynamic 在类中 Discovery

init

public void init()
          throws java.lang.Exception

从类复制的说明: Protocol

Called after instance has been created (null constructor) and before protocol is started. Properties are already set. Other protocols are not yet connected and events cannot yet be sent.

覆盖:

init 在类中 Discovery

抛出:

java.lang.Exception - Thrown if protocol cannot be initialized successfully. This will cause the ProtocolStack to fail, so the channel constructor will throw an exception

resetStats

public void resetStats()

覆盖:

resetStats 在类中 Discovery

down

public java.lang.Object down(Event evt)

从类复制的说明: Protocol

An event is to be sent down the stack. The layer may want to examine its type and perform some action on it, depending on the event's type. If the event is a message MSG, then the layer may need to add a header to it (or do nothing at all) before sending it down the stack using 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().

覆盖:

down 在类中 Discovery

findMembers

public void findMembers(java.util.List<Address> members,
               boolean initial_discovery,
               Responses responses)

从类复制的说明: Discovery

Fetches information (e.g. physical address, logical name) for the given member addresses. Needs to add responses to the 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 在类中 Discovery

参数:

members - A list of logical addresses (typically UUIDs). If null, then information for all members is fetched

initial_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 added

addDiscoveryResponseToCaches

protected boolean addDiscoveryResponseToCaches(Address mbr,
                                   java.lang.String logical_name,
                                   PhysicalAddress physical_addr)

Only add the discovery response if the logical address is not present or the physical addrs are different

覆盖:

addDiscoveryResponseToCaches 在类中 Discovery

addressToFilename

protected static java.lang.String addressToFilename(Address mbr)

createRootDir

protected void createRootDir()

handleView

protected void handleView(View new_view,
              View old_view,
              boolean coord_changed)

remove

protected void remove(java.lang.String clustername,
          Address addr)

readAll

protected void readAll(java.util.List<Address> members,
           java.lang.String clustername,
           Responses responses)

read

protected java.util.List<PingData> read(java.io.File file)
                                 throws java.lang.Exception

抛出:

java.lang.Exception

read

protected java.util.List<PingData> read(java.io.InputStream in)

覆盖:

read 在类中 Discovery

writeAll

protected void writeAll()

Write information about all of the member to file (only if I'm the coord)

write

protected void write(java.util.List<PingData> list,
         java.lang.String clustername)

write

protected void write(java.util.List<PingData> list,
         java.io.OutputStream out)
              throws java.lang.Exception

覆盖:

write 在类中 Discovery

抛出:

java.lang.Exception

deleteFile

protected boolean deleteFile(java.io.File file)