Class MockTransport

java.lang.Object

org.jgroups.stack.Protocol

org.jgroups.protocols.TPConfig

org.jgroups.protocols.TP

org.jgroups.util.MockTransport

All Implemented Interfaces:

Lifecycle, DiagnosticsHandler.ProbeHandler

public class MockTransport
extends TP

A dummy implementation of TP

Since:

5.4

Author:

Bela Ban

Field Summary

Fields inherited from class TP

LIST, MIN_WAIT_BETWEEN_DISCOVERIES, MSG_OVERHEAD, MULTICAST

Fields inherited from class TPConfig

async_executor, bind_addr, bind_port, bundler, bundler_type, cluster_name, connectLock, diag_handler, external_addr, external_port, header, is_trace, last_discovery_request, local_physical_addr, local_transport, local_transport_class, 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, members, message_processing_policy, msg_processing_policy, msg_stats, port_range, print_function, receive_interfaces, receive_on_all_interfaces, rtt, 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, time_service, time_service_interval, timer, timer_handle_non_blocking_tasks, use_direct_memory, use_vthreads, view, who_has_cache, who_has_cache_timeout

Fields inherited from class Protocol

after_creation_hook, down_prot, ergonomics, id, local_addr, log, policies, preview_warning, stack, stats, up_prot

Constructor Summary

Constructors

Constructor	Description
MockTransport()

Method Summary

Modifier and Type	Method	Description
MockTransport	cluster(AsciiString s)
Object	down(Message msg)	A message needs to be sent to a single member or all members
protected PhysicalAddress	getPhysicalAddress()	Returns the physical address of this transport
void	init()	Called after a protocol has been created and before the protocol is started.
void	sendUnicast(PhysicalAddress dest, ByteBuffer data)	Send a unicast message to a member.
boolean	supportsMulticasting()	Whether hardware multicasting is supported

Methods inherited from class TP

addPhysicalAddressToCache, addPhysicalAddressToCache, clearLogicalAddressCache, destroy, disableDiagnostics, doSend, down, enableDiagnostics, evictLogicalAddressCache, evictLogicalAddressCache, fetchLocalAddresses, fetchPhysicalAddrs, fetchResponsesFromDiscoveryProtocol, getAllPhysicalAddressesFromCache, getPhysicalAddressFromCache, handleConnect, handleDisconnect, handleMessageBatch, handleProbe, handleSingleMessage, passBatchUp, passMessageUp, processBatch, receive, receive, registerLocalAddress, removeLogicalAddressFromCache, sendTo, sendToAll, sendUnicasts, setAddress, setInAllThreadFactories, setSourceAddress, setThreadNames, start, startDiagnostics, stop, stopDiagnostics, supportedKeys, toString, unicastDestMismatch, unsetThreadNames, versionMatch

Methods inherited from class TPConfig

bundler, clearDifferentClusterCache, clearDifferentVersionCache, clusterName, createBundler, createDiagnosticsHandler, defaultHeaders, dumpTimerTasks, enableAllStats, enableBlockingTimerTasks, enableStats, getAsyncExecutor, getBindAddr, getBindAddress, getBindPort, getBundler, getBundlerClass, getBundlerType, getClusterName, getClusterNameAscii, getDiagnosticsHandler, getDifferentClusterMessages, getDifferentVersionMessages, getExternalAddr, getExternalPort, getLocalPhysicalAddress, getLocalTransport, getLogDiscardMessages, getLogDiscardMessagesVersion, getLogicalAddrCacheExpiration, getLogicalAddrCacheMaxSize, getLogicalAddrCacheReaperInterval, getLogicalAddressCache, getMessageProcessingPolicy, getMessageStats, getNumberOfThreadDumps, getNumMcastMsgsReceived, getNumMcastMsgsSent, getNumRejectedMsgs, getNumThreads, getNumTimerTasks, getNumUcastMsgsReceived, getNumUcastMsgsSent, getPortRange, getReceiveInterfaces, getRTT, getSocketFactory, getSuppressTimeDifferentClusterWarnings, getSuppressTimeDifferentVersionWarnings, getThreadFactory, getThreadNamingPattern, getThreadPool, getTimer, getTimerClass, getTimerThreads, getTimeService, getTimeServiceInterval, getWhoHasCacheTimeout, isLogicalAddressCacheReaperRunning, isReceiveOnAllInterfaces, isTrace, isTrace, localPhysicalAddress, logDiscardMsgs, logDiscardMsgs, logDiscardMsgsVersion, logDiscardMsgsVersion, loggerType, msgProcessingPolicy, msgProcessingPolicy, printLogicalAddressCache, printWhoHasCache, receiveOnAllInterfaces, receiveOnAllInterfaces, registerProbeHandler, removeCancelledTimerTasks, resetStats, sameCluster, setAsyncExecutor, setBindAddr, setBindAddress, setBindPort, setBindToAllInterfaces, setBundler, setBundlerType, setDiagnosticsHandler, setExternalAddr, setExternalPort, setLevel, setLocalTransport, setLocalTransport, setLogDiscardMessages, setLogDiscardMessagesVersion, setLogicalAddrCacheExpiration, setLogicalAddrCacheMaxSize, setLogicalAddrCacheReaperInterval, setMessageProcessingPolicy, setMessageStats, setPortRange, setSocketFactory, setSuppressTimeDifferentClusterWarnings, setSuppressTimeDifferentVersionWarnings, setThreadFactory, setThreadPool, setTimer, setTimeService, setTimeServiceInterval, setWhoHasCacheTimeout, threadNamingPattern, timestamp, unregisterProbeHandler, unregisterProbeHandler, useDirectMemory, useDirectMemory, useVirtualThreads, useVirtualThreads, view

Methods inherited from class Protocol

accept, addPolicy, addr, addr, afterCreationHook, down, getAddress, getComponents, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getLog, getName, getPolicies, getProtocolStack, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, policies, previewWarning, previewWarning, providedDownServices, providedUpServices, removePolicy, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setPolicies, setProtocolStack, setUpProtocol, setValue, statsEnabled, up, up, up

Methods inherited from class Object

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

Constructor Details

MockTransport

public MockTransport()

Method Details

init

public void init()
          throws Exception

Description copied from class: Protocol

Called after a protocol has been created and before the protocol is started. Attributes are already set. Other protocols are not yet connected and events cannot yet be sent.

Specified by:

init in interface Lifecycle

Overrides:

init in class TP

Throws:

Exception - Thrown if protocol cannot be initialized successfully. This will cause the ProtocolStack to fail, so the the channel constructor will throw an exception

supportsMulticasting

public boolean supportsMulticasting()

Description copied from class: TP

Whether hardware multicasting is supported

Specified by:

supportsMulticasting in class TP

sendUnicast

public void sendUnicast(PhysicalAddress dest,
 ByteBuffer data)
                 throws Exception

Description copied from class: TP

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

Specified by:

sendUnicast in class TP

Parameters:

dest - Must be a non-null physical unicast address (e.g. IpAddress)

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

Throws:

Exception

getPhysicalAddress

protected PhysicalAddress getPhysicalAddress()

Description copied from class: TP

Returns the physical address of this transport

Specified by:

getPhysicalAddress in class TP

cluster

public MockTransport cluster(AsciiString s)

down

public Object down(Message msg)

Description copied from class: TP

A message needs to be sent to a single member or all members

Overrides:

down in class TP