public abstract class BasicTCP extends TP implements Receiver
Modifier and Type | Field and Description |
---|---|
protected 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 |
sock_conn_timeout |
protected boolean |
tcp_nodelay |
avg_batch_size, bind_addr, bind_port, bundler, bundler_capacity, bundler_num_spins, bundler_type, bundler_wait_strategy, can_bind_to_mcast_addr, cluster_name, connectLock, diag_handler, diagnostics_addr, diagnostics_bind_interfaces, diagnostics_passcode, diagnostics_port, diagnostics_ttl, enable_diagnostics, external_addr, external_port, header, internal_pool, internal_thread_factory, is_trace, 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, logical_addr_cache_reaper_interval, loopback_copy, loopback_separate_thread, max_bundle_size, members, message_processing_policy, MIN_WAIT_BETWEEN_DISCOVERIES, MSG_OVERHEAD, msg_processing_max_buffer_size, msg_processing_policy, msg_stats, MULTICAST, port_range, preregistered_probe_handlers, print_function, receive_interfaces, receive_on_all_interfaces, socket_factory, suppress_log_different_cluster, suppress_log_different_version, suppress_time_different_cluster_warnings, suppress_time_different_version_warnings, thread_factory, thread_naming_pattern, thread_pool, thread_pool_enabled, thread_pool_keep_alive_time, thread_pool_max_threads, thread_pool_min_threads, time_service, time_service_interval, timer, timer_handle_non_blocking_tasks, use_common_fork_join_pool, use_fork_join_pool, use_ip_addrs, view, who_has_cache, who_has_cache_timeout
after_creation_hook, down_prot, ergonomics, id, log, stack, stats, up_prot
Modifier | Constructor and Description |
---|---|
protected |
BasicTCP() |
Modifier and Type | Method and Description |
---|---|
long |
getConnExpireTime() |
String |
getInfo() |
long |
getReaperInterval() |
protected Object |
handleDownEvent(Event evt) |
void |
init()
Called after instance has been created (null constructor) and before protocol is started.
|
abstract String |
printConnections() |
void |
receive(Address sender,
ByteBuffer buf)
Delivers a message from a given sender to the application
|
abstract void |
retainAll(Collection<Address> members) |
abstract void |
send(Address dest,
byte[] data,
int offset,
int length) |
void |
sendMulticast(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
|
_send, addPhysicalAddressToCache, addPhysicalAddressToCache, avgBatchSize, bundler, bundlerNumSpins, bundlerNumSpins, bundlerStats, bundlerStatsReset, bundlerWaitStrategy, bundlerWaitStrategy, clearDifferentClusterCache, clearDifferentVersionCache, clearLogicalAddressCache, createBundler, createThreadPool, destroy, disableDiagnostics, doSend, down, down, dumpTimerTasks, enableBlockingTimerTasks, enableDiagnostics, evictLogicalAddressCache, evictLogicalAddressCache, fetchLocalAddresses, fetchPhysicalAddrs, fetchResponsesFromDiscoveryProtocol, getAllPhysicalAddressesFromCache, getAvgBatchSize, getBindAddress, getBindPort, getBundler, getBundlerBufferSize, getBundlerCapacity, getBundlerClass, getClusterName, getClusterNameAscii, getDifferentClusterMessages, getDifferentVersionMessages, getInternalThreadPool, getInternalThreadPoolSize, getInternalThreadPoolSizeLargest, getInternalThreadPoolThreadFactory, getJmxObjects, getLocalAddress, getLocalPhysicalAddress, getLogDiscardMessages, getLogDiscardMessagesVersion, getMaxBundleSize, getMessageProcessingMaxBufferSize, getMessageStats, getNumMessagesSent, getNumThreads, getNumTimerTasks, getPhysicalAddress, getPhysicalAddressFromCache, getPortRange, getReceiveInterfaces, getSocketFactory, getThreadFactory, getThreadNamingPattern, getThreadPool, getThreadPoolKeepAliveTime, getThreadPoolMaxThreads, getThreadPoolMinThreads, getThreadPoolSize, getThreadPoolSizeActive, getThreadPoolSizeLargest, getThreadPoolThreadFactory, getTimer, getTimerClass, getTimerThreads, getTimeService, getUseIpAddresses, handleConnect, handleDisconnect, handleMessageBatch, handleProbe, handleSingleMessage, incrBatchesSent, incrNumSingleMsgsSent, isDiagnosticsHandlerRunning, isLogicalAddressCacheReaperRunning, isMulticastCapable, isReceiveOnAllInterfaces, localAddress, loggerType, loopback, passBatchUp, passMessageUp, printLogicalAddressCache, printWhoHasCache, processBatch, receive, receive, registerLocalAddress, registerProbeHandler, removeLogicalAddressFromCache, resetStats, runInNewThread, send, sendToMembers, sendToSingleMember, setBindAddress, setBindPort, setBindToAllInterfaces, setBundler, setDiagnosticsHandler, setInAllThreadFactories, setInternalThreadPool, setInternalThreadPoolThreadFactory, setLevel, setLogDiscardMessages, setLogDiscardMessagesVersion, setMaxBundleSize, setMessageProcessingPolicy, setPortRange, setSocketFactory, setSourceAddress, setThreadFactory, setThreadNames, setThreadPool, setThreadPoolKeepAliveTime, setThreadPoolMaxThreads, setThreadPoolMinThreads, setThreadPoolThreadFactory, setTimer, setTimeService, shutdownThreadPool, start, startDiagnostics, stop, stopDiagnostics, submitToThreadPool, submitToThreadPool, supportedKeys, toString, unicastDestMismatch, unregisterProbeHandler, unsetThreadNames, versionMatch, view
accept, afterCreationHook, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getProtocolStack, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setProperties, setProtocolStack, setUpProtocol, setValue, statsEnabled, up, up, up
protected long reaper_interval
protected long conn_expire_time
protected int recv_buf_size
protected int send_buf_size
protected int sock_conn_timeout
protected int peer_addr_read_timeout
protected boolean tcp_nodelay
protected int linger
protected InetAddress client_bind_addr
protected int client_bind_port
protected boolean defer_client_bind_addr
public boolean supportsMulticasting()
TP
supportsMulticasting
in class TP
public long getReaperInterval()
public void setReaperInterval(long interval)
public long getConnExpireTime()
public void setConnExpireTime(long time)
public void init() throws Exception
Protocol
public void sendMulticast(byte[] data, int offset, int length) throws Exception
TP
sendMulticast
in class TP
data
- The data to be sent. This is not a copy, so don't modify itException
public void sendUnicast(PhysicalAddress dest, byte[] data, int offset, int length) throws Exception
TP
sendUnicast
in class TP
dest
- Must be a non-null unicast addressdata
- The data to be sent. This is not a copy, so don't modify itException
public abstract String printConnections()
public abstract void send(Address dest, byte[] data, int offset, int length) throws Exception
Exception
public abstract void retainAll(Collection<Address> members)
public void receive(Address sender, ByteBuffer buf)
Receiver
receive
in interface Receiver
sender
- The sender of the messagebuf
- The buffer. An application typically de-serializes data from the buffer into objects used by the
application. Note that when receive() returns, it is not safe to use the buffer any longer;
if an application needs to use a buffer after this callback returns, it must make a copy.
Note that buf could be a direct ByteBuffer.protected Object handleDownEvent(Event evt)
handleDownEvent
in class TP
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.