com.fr.third.jgroups.protocols

类 BPING

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.Discovery

com.fr.third.jgroups.protocols.PING

com.fr.third.jgroups.protocols.BPING

所有已实现的接口:

java.lang.Runnable

public class BPING
extends PING
implements java.lang.Runnable

Broadcast PING. Uses UDP broadcasts to discover initial membership. This protocol is useless in IPv6 environments, as IPv6 has no notion of broadcast addresses. Use IP multicasts instead (e.g. PING or MPING) when running in IPv6.

从以下版本开始:

2.12

作者:

Bela Ban

字段概要

字段

限定符和类型	字段和说明
protected int	bind_port
protected java.lang.String	dest
protected java.net.InetAddress	dest_addr
protected int	port_range
protected java.lang.Thread	receiver
protected java.net.DatagramSocket	sock

从类继承的字段 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

构造器概要

构造器

构造器和说明
BPING()

方法概要

方法

限定符和类型	方法和说明
int	getBindPort()
void	init() Called after instance has been created (null constructor) and before protocol is started.
void	run()
protected void	sendMcastDiscoveryRequest(Message msg)
void	setBindPort(int bind_port)
void	start() This method is called on a Channel.connect(String).
void	stop() This method is called on a Channel.disconnect().

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

findMembers, isDynamic, sendDiscoveryRequest

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

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

从类继承的方法 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

字段详细资料

dest

protected java.lang.String dest

bind_port

protected int bind_port

port_range

protected int port_range

sock

protected java.net.DatagramSocket sock

receiver

protected volatile java.lang.Thread receiver

dest_addr

protected java.net.InetAddress dest_addr

构造器详细资料

BPING

public BPING()

方法详细资料

getBindPort

public int getBindPort()

setBindPort

public void setBindPort(int bind_port)

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

start

public void start()
           throws java.lang.Exception

从类复制的说明: Protocol

This method is called on a Channel.connect(String). Starts work. Protocols are connected and queues are ready to receive events. Will be called from bottom to top. This call will replace the START and START_OK events.

覆盖:

start 在类中 Discovery

抛出:

java.lang.Exception - Thrown if protocol cannot be started successfully. This will cause the ProtocolStack to fail, so Channel.connect(String) will throw an exception

stop

public void stop()

从类复制的说明: Protocol

This method is called on a Channel.disconnect(). Stops work (e.g. by closing multicast socket). Will be called from top to bottom. This means that at the time of the method invocation the neighbor protocol below is still working. This method will replace the STOP, STOP_OK, CLEANUP and CLEANUP_OK events. The ProtocolStack guarantees that when this method is called all messages in the down queue will have been flushed

覆盖:

stop 在类中 Discovery

sendMcastDiscoveryRequest

protected void sendMcastDiscoveryRequest(Message msg)

覆盖:

sendMcastDiscoveryRequest 在类中 PING

run

public void run()

指定者:

run 在接口中 java.lang.Runnable