com.fr.third.jgroups.protocols

类 SHARED_LOOPBACK

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.TP

com.fr.third.jgroups.protocols.SHARED_LOOPBACK

所有已实现的接口:

DiagnosticsHandler.ProbeHandler

public class SHARED_LOOPBACK
extends TP

Loopback transport shared by all channels within the same VM. Property for testing is that no messages are lost. Allows us to test various protocols (with ProtocolTester) at maximum speed.

作者:

Bela Ban

嵌套类概要

从类继承的嵌套类/接口 com.fr.third.jgroups.protocols.TP

TP.BaseBundler, TP.BatchHandler, TP.Bundler, TP.MyHandler, TP.ProtocolAdapter, TP.SenderSendsBundler, TP.SenderSendsWithTimerBundler, TP.SingleMessageHandler, TP.TransferQueueBundler

字段概要

字段

限定符和类型	字段和说明
protected boolean	is_coord
protected boolean	is_server
protected PhysicalAddress	physical_addr
protected View	view

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

avg_batch_size, bind_addr, bind_interface_str, bind_port, BUNDLE_MSG, bundler, bundler_capacity, bundler_type, can_bind_to_mcast_addr, cluster_name, connect_count, connectLock, default_thread_factory, diag_handler, diagnostics_addr, diagnostics_bind_interfaces, diagnostics_passcode, diagnostics_port, diagnostics_ttl, discard_incompatible_packets, enable_batching, enable_bundling, enable_diagnostics, enable_unicast_bundling, external_addr, external_port, f, global_thread_factory, header, ignore_dont_bundle, internal_thread_factory, internal_thread_pool, internal_thread_pool_enabled, internal_thread_pool_keep_alive_time, internal_thread_pool_max_threads, internal_thread_pool_min_threads, internal_thread_pool_queue, internal_thread_pool_queue_enabled, internal_thread_pool_queue_max_size, internal_thread_pool_rejection_policy, last_discovery_request, LIST, local_addr, local_physical_addr, log_discard_msgs, log_discard_msgs_version, logical_addr_cache, logical_addr_cache_expiration, logical_addr_cache_max_size, logical_addr_cache_reaper_interval, loopback, loopback_copy, loopback_separate_thread, max_bundle_size, max_bundle_timeout, members, MSG_OFFSET, MSG_OVERHEAD, MULTICAST, num_batches_received, num_batches_sent, num_bytes_received, num_bytes_sent, num_incoming_msgs_received, num_internal_msgs_received, num_msgs_received, num_msgs_sent, num_oob_msgs_received, num_rejected_msgs, num_single_msgs_received, num_single_msgs_sent, oob_thread_factory, oob_thread_pool, oob_thread_pool_enabled, oob_thread_pool_keep_alive_time, oob_thread_pool_max_threads, oob_thread_pool_min_threads, oob_thread_pool_queue, oob_thread_pool_queue_enabled, oob_thread_pool_queue_max_size, oob_thread_pool_rejection_policy, physical_addr_max_fetch_attempts, port_range, preregistered_probe_handlers, print_function, receive_interfaces, receive_on_all_interfaces, singleton_name, socket_factory, suppress_log_different_cluster, suppress_log_different_version, suppress_time_different_cluster_warnings, suppress_time_different_version_warnings, thread_naming_pattern, thread_pool, thread_pool_enabled, thread_pool_keep_alive_time, thread_pool_max_threads, thread_pool_min_threads, thread_pool_queue, thread_pool_queue_enabled, thread_pool_queue_max_size, thread_pool_rejection_policy, tick_time, time_service, time_service_interval, timer, timer_keep_alive_time, timer_max_threads, timer_min_threads, timer_queue_max_size, timer_rejection_policy, timer_thread_factory, timer_type, up_prots, wheel_size, who_has_cache, who_has_cache_timeout

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

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

构造器概要

构造器

构造器和说明
SHARED_LOOPBACK()

方法概要

方法

限定符和类型	方法和说明
void	destroy() This method is called on a Channel.close().
java.lang.Object	down(Event evt) Caller by the layer above this layer.
static java.lang.String	dumpRoutingTable()
static java.util.List<PingData>	getDiscoveryResponsesFor(java.lang.String cluster_name)
java.lang.String	getInfo()
protected PhysicalAddress	getPhysicalAddress()
View	getView()
boolean	isCoord()
boolean	isServer()
protected static void	register(AsciiString channel_name, Address local_addr, SHARED_LOOPBACK shared_loopback)
void	sendMulticast(AsciiString cluster_name, byte[] data, int offset, int length) Send to all members in the group.
protected void	sendToSingleMember(Address dest, byte[] buf, int offset, int length)
void	sendUnicast(PhysicalAddress dest, byte[] data, int offset, int length) Send a unicast to 1 member.
void	stop() This method is called on a Channel.disconnect().
boolean	supportsMulticasting() Whether or not hardware multicasting is supported
java.lang.String	toString()
protected static void	unregister(AsciiString channel_name, Address local_addr)

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

_send, addPhysicalAddressToCache, clearDifferentClusterCache, clearDifferentVersionCache, clearLogicalAddressCache, createThreadPool, disableDiagnostics, doSend, dumpTimerTasks, enableDiagnostics, evictLogicalAddressCache, evictLogicalAddressCache, fetchLocalAddresses, fetchPhysicalAddrs, fetchResponsesFromDiscoveryProtocol, getAllPhysicalAddressesFromCache, getAvgBatchSize, getBindAddress, getBindPort, getBundlerBufferSize, getClusterName, getClusterName, getDefaultThreadPool, getDefaultThreadPoolThreadFactory, getDifferentClusterMessages, getDifferentVersionMessages, getInternalMaxQueueSize, getInternalMessages, getInternalPoolSize, getInternalPoolSizeActive, getInternalQueueSize, getInternalThreadPool, getInternalThreadPoolThreadFactory, getLocalAddress, getLocalPhysicalAddress, getLogDiscardMessages, getLogDiscardMessagesVersion, getMaxBundleSize, getMaxBundleTimeout, getNumBytesReceived, getNumBytesSent, getNumMessagesReceived, getNumMessagesSent, getNumThreads, getNumTimerTasks, getOOBMaxQueueSize, getOOBMessages, getOOBPoolSize, getOOBPoolSizeActive, getOOBQueueSize, getOOBThreadPool, getOOBThreadPoolKeepAliveTime, getOOBThreadPoolMaxThreads, getOOBThreadPoolMinThreads, getOOBThreadPoolThreadFactory, getPhysicalAddressFromCache, getPortRange, getReceiveInterfaces, getRegularMaxQueueSize, getRegularMessages, getRegularPoolSize, getRegularPoolSizeActive, getRegularQueueSize, getSingletonName, getSocketFactory, getThreadFactory, getThreadNamingPattern, getThreadPoolKeepAliveTime, getThreadPoolMaxThreads, getThreadPoolMinThreads, getTimer, getTimerClass, getTimerKeepAliveTime, getTimerMaxThreads, getTimerMinThreads, getTimerQueueSize, getTimerThreadFactory, getTimerThreads, getTimeService, getUpProtocols, handleConnect, handleDisconnect, handleDownEvent, handleMessageBatch, handleProbe, handleSingleMessage, init, isDefaulThreadPoolEnabled, isDiagnosticsHandlerRunning, isDiscardIncompatiblePackets, isEnableBundling, isEnableUnicastBundling, isLogicalAddressCacheReaperRunning, isLoopback, isMulticastCapable, isOOBThreadPoolEnabled, isReceiveOnAllInterfaces, isSingleton, loggerType, loopback, passBatchUp, passMessageUp, passToAllUpProtocols, pickThreadPool, printLogicalAddressCache, printWhoHasCache, readMessage, readMessageBatch, readMessageList, receive, registerLocalAddress, registerProbeHandler, removeAndDispatchNonBundledMessages, removeLogicalAddressFromCache, resetStats, send, sendToMembers, setBindAddress, setBindPort, setBindToAllInterfaces, setBundler, setDefaultThreadPool, setDefaultThreadPoolThreadFactory, setDiagnosticsHandler, setDiscardIncompatiblePackets, setEnableBundling, setEnableUnicastBundling, setInAllThreadFactories, setInternalThreadPool, setInternalThreadPoolThreadFactory, setLogDiscardMessages, setLogDiscardMessagesVersion, setLoopback, setMaxBundleSize, setMaxBundleTimeout, setOOBRejectionPolicy, setOOBThreadPool, setOOBThreadPoolKeepAliveTime, setOOBThreadPoolMaxThreads, setOOBThreadPoolMinThreads, setOOBThreadPoolQueueEnabled, setOOBThreadPoolThreadFactory, setPingData, setPortRange, setRegularRejectionPolicy, setSocketFactory, setSourceAddress, setThreadFactory, setThreadNames, setThreadPoolKeepAliveTime, setThreadPoolMaxThreads, setThreadPoolMinThreads, setThreadPoolQueueEnabled, setTimer, setTimerKeepAliveTime, setTimerMaxThreads, setTimerMinThreads, setTimerThreadFactory, setTimeService, shutdownThreadPool, start, startDiagnostics, stopDiagnostics, supportedKeys, unregisterProbeHandler, unsetThreadNames, up, versionMatch, writeMessage, writeMessageList

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

accept, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getName, getProtocolStack, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setUpProtocol, setValue, setValues, statsEnabled, up

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

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

字段详细资料

physical_addr

protected PhysicalAddress physical_addr

view

protected volatile View view

is_server

protected volatile boolean is_server

is_coord

protected volatile boolean is_coord

构造器详细资料

SHARED_LOOPBACK

public SHARED_LOOPBACK()

方法详细资料

supportsMulticasting

public boolean supportsMulticasting()

从类复制的说明: TP

Whether or not hardware multicasting is supported

指定者:

supportsMulticasting 在类中 TP

getView

public View getView()

isServer

public boolean isServer()

isCoord

public boolean isCoord()

toString

public java.lang.String toString()

覆盖:

toString 在类中 TP

dumpRoutingTable

public static java.lang.String dumpRoutingTable()

sendMulticast

public void sendMulticast(AsciiString cluster_name,
                 byte[] data,
                 int offset,
                 int length)
                   throws java.lang.Exception

从类复制的说明: TP

Send to all members in the group. UDP would use an IP multicast message, whereas TCP would send N messages, one for each member

指定者:

sendMulticast 在类中 TP

参数:

cluster_name - The name of the cluster. Null if not a shared transport

data - The data to be sent. This is not a copy, so don't modify it

抛出:

java.lang.Exception

sendUnicast

public void sendUnicast(PhysicalAddress dest,
               byte[] data,
               int offset,
               int length)
                 throws java.lang.Exception

从类复制的说明: TP

Send a unicast to 1 member. Note that the destination address is a *physical*, not a logical address

指定者:

sendUnicast 在类中 TP

参数:

dest - Must be a non-null unicast address

data - The data to be sent. This is not a copy, so don't modify it

抛出:

java.lang.Exception

sendToSingleMember

protected void sendToSingleMember(Address dest,
                      byte[] buf,
                      int offset,
                      int length)
                           throws java.lang.Exception

覆盖:

sendToSingleMember 在类中 TP

抛出:

java.lang.Exception

getDiscoveryResponsesFor

public static java.util.List<PingData> getDiscoveryResponsesFor(java.lang.String cluster_name)

getInfo

public java.lang.String getInfo()

指定者:

getInfo 在类中 TP

getPhysicalAddress

protected PhysicalAddress getPhysicalAddress()

指定者:

getPhysicalAddress 在类中 TP

down

public java.lang.Object down(Event evt)

从类复制的说明: TP

Caller by the layer above this layer. Usually we just put this Message into the send queue and let one or more worker threads handle it. A worker thread then removes the Message from the send queue, performs a conversion and adds the modified Message to the send queue of the layer below it, by calling down()).

覆盖:

down 在类中 TP

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 在类中 TP

destroy

public void destroy()

从类复制的说明: Protocol

This method is called on a Channel.close(). Does some cleanup; after the call the VM will terminate

覆盖:

destroy 在类中 TP

register

protected static void register(AsciiString channel_name,
            Address local_addr,
            SHARED_LOOPBACK shared_loopback)

unregister

protected static void unregister(AsciiString channel_name,
              Address local_addr)