com.fr.third.jgroups.protocols

类 BasicTCP

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.TP

com.fr.third.jgroups.protocols.BasicTCP

所有已实现的接口:

DiagnosticsHandler.ProbeHandler

直接已知子类:

TCP, TCP_NIO

public abstract class BasicTCP
extends TP

Shared base class for TCP protocols

作者:

Scott Marlow, 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 java.net.InetAddress	client_bind_addr
protected int	client_bind_port
protected long	conn_expire_time
protected boolean	defer_client_bind_addr
protected int	linger
protected int	peer_addr_read_timeout
protected long	reaper_interval
protected int	recv_buf_size
protected int	send_buf_size
protected int	send_queue_size
protected int	sock_conn_timeout
protected boolean	tcp_nodelay
protected boolean	use_send_queues

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

构造器概要

构造器

限定符	构造器和说明
protected	BasicTCP()

方法概要

方法

限定符和类型	方法和说明
long	getConnExpireTime()
java.lang.String	getInfo()
long	getReaperInterval()
protected java.lang.Object	handleDownEvent(Event evt)
void	init() Called after instance has been created (null constructor) and before protocol is started.
abstract java.lang.String	printConnections()
void	receive(Address sender, byte[] data, int offset, int length) ConnectionMap.Receiver interface
abstract void	retainAll(java.util.Collection<Address> members)
abstract void	send(Address dest, byte[] data, int offset, int length)
void	sendMulticast(AsciiString cluster_name, byte[] data, int offset, int length) Send to all members in the group.
void	sendUnicast(PhysicalAddress dest, byte[] data, int offset, int length) Send a unicast to 1 member.
void	setConnExpireTime(long time)
void	setReaperInterval(long interval)
boolean	supportsMulticasting() Whether or not hardware multicasting is supported

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

_send, addPhysicalAddressToCache, clearDifferentClusterCache, clearDifferentVersionCache, clearLogicalAddressCache, createThreadPool, destroy, disableDiagnostics, doSend, down, 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, getPhysicalAddress, 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, handleMessageBatch, handleProbe, handleSingleMessage, isDefaulThreadPoolEnabled, isDiagnosticsHandlerRunning, isDiscardIncompatiblePackets, isEnableBundling, isEnableUnicastBundling, isLogicalAddressCacheReaperRunning, isLoopback, isMulticastCapable, isOOBThreadPoolEnabled, isReceiveOnAllInterfaces, isSingleton, loggerType, loopback, passBatchUp, passMessageUp, passToAllUpProtocols, pickThreadPool, printLogicalAddressCache, printWhoHasCache, readMessage, readMessageBatch, readMessageList, registerLocalAddress, registerProbeHandler, removeAndDispatchNonBundledMessages, removeLogicalAddressFromCache, resetStats, send, sendToMembers, sendToSingleMember, 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, stop, stopDiagnostics, supportedKeys, toString, 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

字段详细资料

reaper_interval

protected long reaper_interval

conn_expire_time

protected long conn_expire_time

use_send_queues

protected boolean use_send_queues

send_queue_size

protected int send_queue_size

recv_buf_size

protected int recv_buf_size

send_buf_size

protected int send_buf_size

sock_conn_timeout

protected int sock_conn_timeout

peer_addr_read_timeout

protected int peer_addr_read_timeout

tcp_nodelay

protected boolean tcp_nodelay

linger

protected int linger

client_bind_addr

protected java.net.InetAddress client_bind_addr

client_bind_port

protected int client_bind_port

defer_client_bind_addr

protected boolean defer_client_bind_addr

构造器详细资料

BasicTCP

protected BasicTCP()

方法详细资料

supportsMulticasting

public boolean supportsMulticasting()

从类复制的说明: TP

Whether or not hardware multicasting is supported

指定者:

supportsMulticasting 在类中 TP

getReaperInterval

public long getReaperInterval()

setReaperInterval

public void setReaperInterval(long interval)

getConnExpireTime

public long getConnExpireTime()

setConnExpireTime

public void setConnExpireTime(long time)

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

抛出:

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

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

getInfo

public java.lang.String getInfo()

指定者:

getInfo 在类中 TP

printConnections

public abstract java.lang.String printConnections()

send

public abstract void send(Address dest,
        byte[] data,
        int offset,
        int length)
                   throws java.lang.Exception

抛出:

java.lang.Exception

retainAll

public abstract void retainAll(java.util.Collection<Address> members)

receive

public void receive(Address sender,
           byte[] data,
           int offset,
           int length)

ConnectionMap.Receiver interface

覆盖:

receive 在类中 TP

handleDownEvent

protected java.lang.Object handleDownEvent(Event evt)

覆盖:

handleDownEvent 在类中 TP