public class TUNNEL extends TP implements RouterStub.StubReceiver
router_host
and router_port
. All outgoing traffic is sent
via this TCP socket to the Router which distributes it to all connected TUNNELs in this group.
Incoming traffic received from Router will simply be passed up the stack.
A TUNNEL layer can be used to penetrate a firewall, most firewalls allow creating TCP connections to the outside world, however, they do not permit outside hosts to initiate a TCP connection to a host inside the firewall. Therefore, the connection created by the inside host is reused by Router to send traffic from an outside host to a host inside the firewall.
Modifier and Type | Class and Description |
---|---|
static interface |
TUNNEL.TUNNELPolicy |
Modifier and Type | Field and Description |
---|---|
protected List<InetSocketAddress> |
gossip_router_hosts |
protected long |
reconnect_interval |
protected DatagramSocket |
sock |
protected RouterStubManager |
stubManager |
protected boolean |
tcp_nodelay |
protected TUNNEL.TUNNELPolicy |
tunnel_policy |
protected boolean |
use_nio |
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
Constructor and Description |
---|
TUNNEL() |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
This method is called on a
JChannel.close() . |
String |
getInfo() |
protected PhysicalAddress |
getPhysicalAddress() |
long |
getReconnectInterval() |
RouterStubManager |
getStubManager() |
Object |
handleDownEvent(Event evt) |
void |
init()
Called after instance has been created (null constructor) and before protocol is started.
|
String |
print() |
String |
printReconnectList() |
String |
printStubs() |
void |
receive(GossipData data) |
protected void |
send(Message msg,
Address dest)
Serializes and sends a message.
|
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 |
setGossipRouterHosts(String hosts) |
void |
setReconnectInterval(long reconnect_interval) |
void |
setTUNNELPolicy(TUNNEL.TUNNELPolicy policy) |
boolean |
supportsMulticasting()
We can simply send a message with dest == null and the GossipRouter will take care of routing it to all
members in the cluster
|
String |
toString() |
_send, addPhysicalAddressToCache, addPhysicalAddressToCache, avgBatchSize, bundler, bundlerNumSpins, bundlerNumSpins, bundlerStats, bundlerStatsReset, bundlerWaitStrategy, bundlerWaitStrategy, clearDifferentClusterCache, clearDifferentVersionCache, clearLogicalAddressCache, createBundler, createThreadPool, 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, 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, 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, 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 reconnect_interval
protected boolean tcp_nodelay
protected boolean use_nio
protected final List<InetSocketAddress> gossip_router_hosts
protected TUNNEL.TUNNELPolicy tunnel_policy
protected DatagramSocket sock
protected volatile RouterStubManager stubManager
public boolean supportsMulticasting()
supportsMulticasting
in class TP
public void setGossipRouterHosts(String hosts) throws UnknownHostException
UnknownHostException
public String print()
public String printStubs()
public String printReconnectList()
public RouterStubManager getStubManager()
public long getReconnectInterval()
public void setReconnectInterval(long reconnect_interval)
public void setTUNNELPolicy(TUNNEL.TUNNELPolicy policy)
public void init() throws Exception
Protocol
public void destroy()
Protocol
JChannel.close()
.
Does some cleanup; after the call the VM will terminatepublic Object handleDownEvent(Event evt)
handleDownEvent
in class TP
public void receive(GossipData data)
receive
in interface RouterStub.StubReceiver
protected void send(Message msg, Address dest) throws Exception
TP
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
protected PhysicalAddress getPhysicalAddress()
getPhysicalAddress
in class TP
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.