Logo Search packages:      
Sourcecode: libjgroups-java version File versions

org::jgroups::tests::MultiplexerStateTransferTest Class Reference

Inheritance diagram for org::jgroups::tests::MultiplexerStateTransferTest:

org::jgroups::tests::ChannelTestBase

List of all members.


Detailed Description

Test the multiplexer functionality provided by JChannelFactory
Author:
Bela Ban
Version:
Id
MultiplexerStateTransferTest.java,v 1.2.2.2 2008/02/19 23:16:52 vlada Exp

Definition at line 19 of file MultiplexerStateTransferTest.java.


Public Member Functions

 MultiplexerStateTransferTest (String name)
void setUp () throws Exception
void tearDown () throws Exception
void testConnectAndGetSubstates () throws Exception
void testConnectAndStateTransfer () throws Exception
void testConnectAndStateTransferWithTwoApplications () throws Exception
void testGetSubstates () throws Exception
void testGetSubstatesMultipleTimes () throws Exception
void testStateTransfer () throws Exception
void testStateTransferFromSelf () throws Exception
void testStateTransferWithReconnect () throws Exception
void testStateTransferWithRegistration () throws Exception
void testStateTransferWithTwoApplications () throws Exception

Static Public Member Functions

static boolean areViewsComplete (Channel[] channels, int memberCount)
static void blockUntilViewsReceived (Collection< Channel > channels, int count, long timeout)
static void blockUntilViewsReceived (ChannelRetrievable[] channels, long timeout)
static void blockUntilViewsReceived (ChannelRetrievable[] channels, int count, long timeout)
static void blockUntilViewsReceived (Channel channel, int count, long timeout)
static void blockUntilViewsReceived (Channel[] channels, int count, long timeout)
static void blockUntilViewsReceived (List<?extends ChannelRetrievable > channels, long timeout)
static void blockUntilViewsReceived (List<?extends ChannelRetrievable > channels, int count, long timeout)
static void blockUntilViewsReceived (Channel[] channels, long timeout)
static boolean isViewComplete (Channel channel, int memberCount)
static void main (String[] args)
static void sleepRandom (int minTime, int maxTime)
static Test suite ()
static String translateEventTrace (List< Object > et) throws Exception
static boolean validateEventTrace (List< Object > eventTrace)

Protected Member Functions

void checkEventStateTransferSequence (EventSequence receiver)
String[] createApplicationNames (int applicationCount)
JChannel createChannel () throws Exception
JChannel createChannel (Object id) throws Exception
String[] createMuxApplicationNames (int muxApplicationstPerChannelCount, int muxFactoryCount)
String[] createMuxApplicationNames (int muxApplicationstPerChannelCount)
int getMuxFactoryCount ()
String getNextChannelName ()
boolean useBlocking ()

Static Protected Member Functions

static boolean isMuxChannelUsed ()
static boolean isTunnelUsed ()
static boolean shouldCompareThreadCount ()
static boolean validateEventString (String eventString, String spec)

Protected Attributes

int active_threads = 0
int currentChannelGeneratedName = LETTER_A
final Log log = LogFactory.getLog(this.getClass())
JChannelFactory muxFactory [] = null
String thread_dump = null

Static Protected Attributes

static String CHANNEL_CONFIG = "udp.xml"
static final String DEFAULT_MUX_FACTORY_COUNT = "4"
static String MUX_CHANNEL_CONFIG = "stacks.xml"
static String MUX_CHANNEL_CONFIG_STACK_NAME = "udp"
static final Random RANDOM = new Random()

Package Attributes

JChannelFactory factory
JChannelFactory factory2
GossipRouter router = null

Private Member Functions

void _testEvenNumbersPresent (Cache c)
void _testNumbersPresent (Cache c, Integer[] numbers)
void _testOddNumbersPresent (Cache c)
void assertServiceAndClusterView (Channel ch, int num_service_view_mbrs, int num_cluster_view_mbrs)
void getSubstates (boolean joinAndFetch) throws Exception
void regularStateTransfer (boolean joinAndFetch) throws Exception
void setCorrectPortRange (Channel ch)
void stateTransferWithTwoApplications (boolean joinAndFetch) throws Exception

Private Attributes

Cache c1
Cache c1_repl
Cache c2
Cache c2_repl
Channel ch1
Channel ch1_repl
Channel ch2
Channel ch2_repl

Classes

class  Cache
class  ExtendedCache

The documentation for this class was generated from the following file:

Generated by  Doxygen 1.6.0   Back to index