public class UDP extends TP
The following properties are read by the UDP protocol:
Modifier and Type | Class and Description |
---|---|
class |
UDP.PacketReceiver |
TP.BatchHandler, TP.ProtocolAdapter, TP.SingleMessageHandler, TP.SingleMessageHandlerWithClusterName
Modifier and Type | Field and Description |
---|---|
protected boolean |
disable_loopback |
protected boolean |
ip_mcast |
protected int |
ip_ttl |
protected static boolean |
is_android |
protected static boolean |
is_mac |
protected IpAddress |
mcast_addr
The multicast address (mcast address and port) this member uses
|
protected java.net.InetAddress |
mcast_group_addr |
protected int |
mcast_port |
protected UDP.PacketReceiver |
mcast_receiver
Runnable to receive multicast packets
|
protected int |
mcast_recv_buf_size |
protected int |
mcast_send_buf_size |
protected java.net.MulticastSocket |
mcast_sock
IP multicast socket for receiving multicast packets
|
protected java.net.MulticastSocket |
sock
Socket used for
sending unicast and multicast packets and
receiving unicast packets
The address of this socket will be our local address (local_addr)
|
protected SuppressLog<java.net.InetAddress> |
suppress_log_out_of_buffer_space |
protected long |
suppress_time_out_of_buffer_space |
protected int |
tos
Traffic class for sending unicast and multicast datagrams.
|
protected UDP.PacketReceiver |
ucast_receiver
Runnable to receive unicast packets
|
protected int |
ucast_recv_buf_size |
protected int |
ucast_send_buf_size |
avg_batch_size, bind_addr, bind_interface_str, bind_port, BUNDLE_MSG, bundler, bundler_capacity, bundler_num_spins, bundler_type, bundler_wait_strategy, 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, MIN_WAIT_BETWEEN_DISCOVERIES, MSG_OVERHEAD, MULTICAST, no_bundler_initial_buf_size, no_bundler_pool_size, 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, num_single_msgs_sent_instead_of_batch, 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, view, wheel_size, who_has_cache, who_has_cache_timeout
after_creation_hook, down_prot, ergonomics, id, log, name, stack, stats, up_prot
Constructor and Description |
---|
UDP() |
Modifier and Type | Method and Description |
---|---|
protected void |
_send(java.net.InetAddress dest,
int port,
boolean mcast,
byte[] data,
int offset,
int length) |
protected void |
bindToInterfaces(java.util.List<java.net.NetworkInterface> interfaces,
java.net.MulticastSocket s,
java.net.InetAddress mcastAddr) |
void |
clearDroppedMessagesCache() |
protected void |
closeUnicastSocket() |
protected IpAddress |
createLocalAddress() |
protected java.net.MulticastSocket |
createMulticastSocket(java.lang.String service_name,
int port) |
protected java.net.MulticastSocket |
createMulticastSocketWithBindPort()
Creates a DatagramSocket when bind_port > 0.
|
protected void |
createSockets()
Creates the UDP sender and receiver sockets
|
void |
destroy()
This method is called on a
Channel.close() . |
protected void |
destroySockets() |
protected java.lang.String |
dumpSocketInfo() |
protected static java.lang.reflect.Method |
findMethod(java.lang.Class<?> clazz,
java.lang.String method_name,
java.lang.Class<?>... parameters) |
int |
getDroppedMessage() |
java.lang.String |
getInfo() |
java.net.InetAddress |
getMulticastAddress() |
int |
getMulticastPort() |
int |
getMulticastTTL()
Getter for current multicast TTL
|
protected PhysicalAddress |
getPhysicalAddress() |
protected void |
handleConfigEvent(java.util.Map<java.lang.String,java.lang.Object> map) |
protected void |
handleConnect() |
protected void |
handleDisconnect() |
protected java.lang.Object |
handleDownEvent(Event evt) |
void |
init()
Called after instance has been created (null constructor) and before protocol is started.
|
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.
|
protected void |
setBufferSize(java.net.DatagramSocket sock,
int send_buf_size,
int recv_buf_size) |
protected void |
setInterface(java.net.InetAddress intf,
java.net.MulticastSocket s) |
void |
setMaxBundleSize(int size) |
void |
setMcastPort(int mcast_port) |
void |
setMulticastAddress(java.net.InetAddress addr) |
void |
setMulticastPort(int mcast_port) |
void |
setMulticastTTL(int ttl)
Set the ttl for multicast socket
|
protected void |
setTimeToLive(int ttl,
java.net.MulticastSocket s) |
void |
start()
Creates the unicast and multicast sockets and starts the unicast and multicast receiver threads
|
void |
stop()
This method is called on a
Channel.disconnect() . |
boolean |
supportsMulticasting()
Whether or not hardware multicasting is supported
|
_send, addPhysicalAddressToCache, assertPositive, bundler, bundlerNumSpins, bundlerNumSpins, bundlerWaitStrategy, bundlerWaitStrategy, clearDifferentClusterCache, clearDifferentVersionCache, clearLogicalAddressCache, createBundler, createThreadPool, disableDiagnostics, doSend, down, dumpTimerTasks, enableDiagnostics, evictLogicalAddressCache, evictLogicalAddressCache, fetchLocalAddresses, fetchPhysicalAddrs, fetchResponsesFromDiscoveryProtocol, getAllPhysicalAddressesFromCache, getAvgBatchSize, getBindAddress, getBindPort, getBundler, getBundlerBufferSize, getBundlerCapacity, getBundlerClass, getClusterName, getClusterName, getClusterNameAscii, 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, handleMessageBatch, handleProbe, handleSingleMessage, incrBatchesSent, incrBatchesSent, incrSingleMsgsInsteadOfBatches, isDefaulThreadPoolEnabled, isDiagnosticsHandlerRunning, isDiscardIncompatiblePackets, isEnableBundling, isEnableUnicastBundling, isLogicalAddressCacheReaperRunning, isLoopback, isMulticastCapable, isOOBThreadPoolEnabled, isReceiveOnAllInterfaces, isSingleton, localAddress, loggerType, loopback, passBatchUp, passMessageUp, passToAllUpProtocols, pickThreadPool, printLogicalAddressCache, printWhoHasCache, readMessage, readMessageBatch, readMessageList, receive, registerLocalAddress, registerProbeHandler, removeAndDispatchNonBundledMessages, removeLogicalAddressFromCache, resetStats, send, sendToMembers, sendToSingleMember, setBindAddress, setBindPort, setBindToAllInterfaces, setBundler, setDefaultThreadPool, setDefaultThreadPoolThreadFactory, setDiagnosticsHandler, setDiscardIncompatiblePackets, setEnableBundling, setEnableUnicastBundling, setInAllThreadFactories, setInternalThreadPool, setInternalThreadPoolThreadFactory, setLogDiscardMessages, setLogDiscardMessagesVersion, setLoopback, 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, startDiagnostics, stopDiagnostics, supportedKeys, toString, unregisterProbeHandler, unsetThreadNames, up, versionMatch, view, writeMessage, writeMessageList, writeMessageListHeader
accept, afterCreationHook, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, 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
protected int tos
DatagramSocket.setTrafficClass(int)
); for details):
IPTOS_LOWCOST (0x02)
, decimal 2IPTOS_RELIABILITY (0x04)
<, decimal 4/LI>
IPTOS_THROUGHPUT (0x08)
, decimal 8IPTOS_LOWDELAY (0x10)
, decimal 16protected java.net.InetAddress mcast_group_addr
protected int mcast_port
protected boolean ip_mcast
protected int ip_ttl
protected int mcast_send_buf_size
protected int mcast_recv_buf_size
protected int ucast_send_buf_size
protected int ucast_recv_buf_size
protected boolean disable_loopback
protected long suppress_time_out_of_buffer_space
protected IpAddress mcast_addr
protected java.net.MulticastSocket sock
protected java.net.MulticastSocket mcast_sock
protected UDP.PacketReceiver mcast_receiver
protected UDP.PacketReceiver ucast_receiver
protected SuppressLog<java.net.InetAddress> suppress_log_out_of_buffer_space
protected static final boolean is_android
protected static final boolean is_mac
public boolean supportsMulticasting()
TP
supportsMulticasting
in class TP
public void setMulticastAddress(java.net.InetAddress addr)
public java.net.InetAddress getMulticastAddress()
public int getMulticastPort()
public void setMulticastPort(int mcast_port)
public void setMcastPort(int mcast_port)
public void setMulticastTTL(int ttl)
ttl
- the time to live for the socket.java.io.IOException
public int getMulticastTTL()
public void setMaxBundleSize(int size)
setMaxBundleSize
in class TP
public int getDroppedMessage()
public void clearDroppedMessagesCache()
public void sendMulticast(AsciiString cluster_name, byte[] data, int offset, int length) throws java.lang.Exception
TP
sendMulticast
in class TP
cluster_name
- The name of the cluster. Null if not a shared transportdata
- The data to be sent. This is not a copy, so don't modify itjava.lang.Exception
public void sendUnicast(PhysicalAddress dest, byte[] data, int offset, int length) throws java.lang.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 itjava.lang.Exception
protected void _send(java.net.InetAddress dest, int port, boolean mcast, byte[] data, int offset, int length) throws java.lang.Exception
java.lang.Exception
protected java.lang.Object handleDownEvent(Event evt)
handleDownEvent
in class TP
public void init() throws java.lang.Exception
Protocol
public void start() throws java.lang.Exception
start
in class TP
java.lang.Exception
- Thrown if protocol cannot be started successfully. This will cause the ProtocolStack
to fail, so Channel.connect(String)
will throw an exceptionpublic void stop()
Protocol
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 flushedpublic void destroy()
Protocol
Channel.close()
.
Does some cleanup; after the call the VM will terminateprotected void handleConnect() throws java.lang.Exception
handleConnect
in class TP
java.lang.Exception
protected void handleDisconnect()
handleDisconnect
in class TP
protected static java.lang.reflect.Method findMethod(java.lang.Class<?> clazz, java.lang.String method_name, java.lang.Class<?>... parameters)
protected void createSockets() throws java.lang.Exception
java.lang.Exception
protected void destroySockets()
protected IpAddress createLocalAddress()
protected void setTimeToLive(int ttl, java.net.MulticastSocket s)
protected void setInterface(java.net.InetAddress intf, java.net.MulticastSocket s)
protected PhysicalAddress getPhysicalAddress()
getPhysicalAddress
in class TP
protected void bindToInterfaces(java.util.List<java.net.NetworkInterface> interfaces, java.net.MulticastSocket s, java.net.InetAddress mcastAddr)
interfaces
- Lists
- mcastAddr
- java.io.IOException
protected java.net.MulticastSocket createMulticastSocketWithBindPort() throws java.lang.Exception
java.lang.Exception
protected java.net.MulticastSocket createMulticastSocket(java.lang.String service_name, int port) throws java.lang.Exception
java.lang.Exception
protected java.lang.String dumpSocketInfo() throws java.lang.Exception
java.lang.Exception
protected void setBufferSize(java.net.DatagramSocket sock, int send_buf_size, int recv_buf_size)
protected void closeUnicastSocket()
protected void handleConfigEvent(java.util.Map<java.lang.String,java.lang.Object> map)
Copyright © 1998-2020 Red Hat. All Rights Reserved.