org.jgroups.tests |
|
Java Source File Name | Type | Comment |
AckCollectorTest.java | Class | |
AckMcastSenderWindowTest.java | Class | Test AckMcastSenderWindow
testAck() :
1. |
AckReceiverWindowTest.java | Class | |
AckSenderWindowTest.java | Class | |
AddDataTest.java | Class | |
bla.java | Class | |
BoundedListTest.java | Class | |
Bsh.java | Class | |
ChannelCallbackTest.java | Class | |
ChannelTest.java | Class | |
ChannelTestBase.java | Class | |
CheckMonotonicallyIncreasingNumbers.java | Class | Checks whether numbers in a stream are monotonically increasing, e.g. |
CloseTest.java | Class | Demos the creation of a channel and subsequent connection and closing. |
ConcurrentStartupTest.java | Class | Tests concurrent startup with state transfer and concurrent state tranfer. |
CondVarTest.java | Class | |
ConnectionTableDemo.java | Class | |
ConnectionTableDemo_NIO.java | Class | |
ConnectionTableUnitTest.java | Class | |
ConnectStressTest.java | Class | Creates 1 channel, then creates NUM channels, all try to join the same channel concurrently. |
ConnectTest.java | Class | Runs through multiple channel connect and disconnects, without closing the channel. |
ContinousThroughputTest.java | Class | ContinousThroughputTest.java
This is a program to make Throughput tests. |
CustomProtocolTest.java | Class | Tests custom protocol. |
Deadlock2Test.java | Class | Test the distributed RPC deadlock detection mechanism, using one or two channels. |
DeadlockTest.java | Class | Class which tests deadlock detection in RequestCorrelator. |
DetermineFragSize.java | Class | Determine the fragmentation size of a system. |
DigestTest.java | Class | |
DiscardTest.java | Class | |
DisconnectStressTest.java | Class | |
DisconnectTest.java | Class | Ensures that a disconnected channel reconnects correctly, for different
stack configurations. |
DiscoveryTest.java | Class | Simple test for multicast discovery. |
DistributedHashDeadLock.java | Class | |
DistributedHashtableTest.java | Class | |
DistributedHashtableUnitTest.java | Class | |
EncryptMessageOrderTestCase.java | Class | This test case checks ordering of messages using the Encrypt protocol
using UDP protocols. |
FCTest.java | Class | |
FlushTest.java | Class | |
FragTest.java | Class | Class to test FRAG protocol. |
FragTest2.java | Class | Tests the fragmentation protocol (FRAG). |
FragTestUnicast.java | Class | Tests the fragmentation protocol (FRAG) for large unicast messages. |
GetStateTest.java | Class | Example of the STATE_TRANSFER protocol and API. |
GroupRequestPull.java | Class | |
HammerListener.java | Class | |
HammerSender.java | Class | |
HashMapTest.java | Class | |
HashtableTest.java | Class | |
InterruptTest.java | Class | |
IpAddressTest.java | Class | |
JmxTest.java | Class | |
JoinTest.java | Class | |
LargeState.java | Class | Tests transfer of large states. |
LargeStateClient.java | Class | |
LargeStateServer.java | Class | |
LargeStateTransferTest.java | Class | |
LogicalAddressTest.java | Class | |
LogTest.java | Class | |
McastDiscovery.java | Class | Discovers all neighbors in an IP multicast environment by using expanding ring multicasts (increasing TTL).
The sender multicasts a discovery packet on all available network interfaces, while also listening on
all interfaces. |
McastLoopbackTest.java | Class | |
McastReceiverTest.java | Class | Tests IP multicast. |
McastReceiverTest1_4.java | Class | Tests IP multicast. |
McastSenderTest.java | Class | Tests IP multicast. |
McastSenderTest1_4.java | Class | |
McastTest.java | Class | |
MembershipTest.java | Class | |
MergeStressTest.java | Class | Creates NUM channels, all trying to join the same channel concurrently. |
MergeTest.java | Class | |
MessageDispatcherShunTest.java | Class | |
MessageDispatcherSpeedTest.java | Class | |
MessageDispatcherTest.java | Class | Example for MessageDispatcher (see also RpcDispatcherTest). |
MessageDispatcherTestAsync.java | Class | Asynchronous example for MessageDispatcher; message is mcast to all members, responses are received
asynchronously by calling RspCollector.receiveResponse(). |
MessageListStreamableTest.java | Class | |
MessageSerializationTest.java | Class | |
MessageSerializationTest2.java | Class | |
MessageTest.java | Class | |
MethodCallTest.java | Class | |
MultiplexerMergeTest.java | Class | |
MultiplexerTest.java | Class | |
MultiplexerViewTest.java | Class | |
NakackTest.java | Class | |
NAKACKTest2.java | Class | Tests the "NAKACK retransmit message lost" problem. |
NakReceiverWindowStressTest.java | Class | Adds a large number of messages (with gaps to simulate message loss) into NakReceiverWindow. |
NakReceiverWindowTest.java | Class | |
NetworkUtilization.java | Class | |
PartitionerTest.java | Class | Title: Demos of PARTITIONER protocol. |
PerfTest.java | Class | Test which multicasts n messages to all members. |
PerfTpTest.java | Class | Test of PERF_TP. |
Ping.java | Class | Determines the initial set of members given a group name and properties and prints them to stdout. |
Probe.java | Class | |
PromiseTest.java | Class | |
PullPushTest.java | Class | Uses PullPush building block to send/receive messages. |
PullPushTestMux.java | Class | Uses PullPush building block to send/receive messages. |
QueueSpeedTest.java | Class | Measures the speed of inserting and removing 1 million elements into/from a Queue and a LinkedQueue. |
QueueTest.java | Class | |
QueueTest2.java | Class | |
ReadWriteLockTest.java | Class | |
ReentrantLockTest.java | Class | |
RetransmitterTest.java | Class | |
ReusableThreadTest.java | Class | |
RoundTrip.java | Class | |
RoundTripMulticast.java | Class | |
RoundTripTcp.java | Class | |
RoundTripUdp.java | Class | |
RpcDispatcherBlocking.java | Class | Tests synchronous group RPCs. |
RpcDispatcherMultiplexerTest.java | Class | |
RpcDispatcherShunTest.java | Class | |
RpcDispatcherSimpleTest.java | Class | Example for RpcDispatcher (see also MessageDispatcher). |
RpcDispatcherSpeedTest.java | Class | Interactive test for measuring group RPCs using different invocation techniques. |
RpcDispatcherStressTest.java | Class | Example for RpcDispatcher (see also MessageDispatcher). |
RspListTest.java | Class | |
SchedulerTest.java | Class | |
SendAndReceiveTest.java | Class | Tests sending and receiving of messages within the same VM. |
SequencerFailoverTest.java | Class | Tests a SEQUENCER based stack: A, B and C. |
SimplePerfTest.java | Class | Sends num_msgs up the stack. |
SizeTest.java | Class | |
SpeedTest.java | Class | Test time taken for multicasting n local messages (messages sent to self). |
SpeedTest_NIO.java | Class | Same test as SpeedTest, but using NIO ByteBuffer rather than serialization. |
StateTransferTest.java | Class | |
StreamableTest.java | Class | |
StreamingStateTransferTest.java | Class | Tests streaming state transfer for both pull and push mode of channel
operations. |
StressTester.java | Class | Test driver for testing JGroups-based HttpSession replication. |
StringTest.java | Class | |
SynchronousMessageSpeedTest.java | Class | |
TestPoolExecutor.java | Class | |
ThreadPoolTest.java | Class | |
TimerTest.java | Class | Test cases for Timer. |
TimeSchedulerTest.java | Class | |
TUNNELDeadLockTest.java | Class | Test designed to make sure the TUNNEL doesn't lock the client and the GossipRouter
under heavy load. |
UcastTest.java | Class | |
UnicastChannelTest.java | Class | |
UnicastLoopbackTest.java | Class | |
UnicastTest.java | Class | |
UnicastTest2.java | Class | Demos the UNICAST protocol. |
UNICAST_Test.java | Class | |
UnmodifiableVectorTest.java | Class | |
UpHandlerTest.java | Class | Uses the pass-though facility of the Channel: events are passed (mostly) unfiltered from the channel
to the application. |
UtilTest.java | Class | |
VersionTest.java | Class | |
ViewIdTest.java | Class | |
ViewTest.java | Class | |
VirtualSynchronyTest.java | Class | Virtual Synchrony guarantees that views in a group are observed
in the same order by all group members and that views are totally ordered
with respect to all regular messages in a group. |
XmlConfigurationTest.java | Class | |