| org.jgroups.tests.ChannelTestBase org.jgroups.tests.ConcurrentStartupTest
ConcurrentStartupTest | public class ConcurrentStartupTest extends ChannelTestBase (Code) | | Tests concurrent startup with state transfer and concurrent state tranfer.
author: bela version: $Id: ConcurrentStartupTest.java,v 1.16.2.1 2006/12/04 22:45:49 vlada Exp $ |
Inner Class :protected class ConcurrentStateTransfer extends ConcurrentStartupChannel | |
Inner Class :protected class ConcurrentLargeStateTransfer extends ConcurrentStateTransfer | |
Inner Class :protected class ConcurrentStartupChannelWithLargeState extends ConcurrentStartupChannel | |
Inner Class :protected class ConcurrentStartupChannel extends PushChannelApplicationWithSemaphore | |
concurrentStartupHelper | protected void concurrentStartupHelper(boolean largeState, boolean useDispatcher)(Code) | | Tests concurrent startup and message sending directly after joining
See doc/design/ConcurrentStartupTest.txt for details. This will only work 100% correctly once we have
FLUSH support (JGroups 2.4)
NOTE: This test is not guaranteed to pass at 100% rate until combined join
and state transfer using one FLUSH phase is introduced (Jgroups 2.5)[1].
[1] http://jira.jboss.com/jira/browse/JGRP-236
|
concurrentStateTranferHelper | protected void concurrentStateTranferHelper(boolean largeState, boolean useDispatcher)(Code) | | Tests concurrent state transfer. This test should pass at 100% rate when [1]
is solved.
[1]http://jira.jboss.com/jira/browse/JGRP-332
|
getMod | protected int getMod()(Code) | | |
printLists | protected void printLists(List[] lists)(Code) | | |
printModifications | protected void printModifications(Map[] modifications)(Code) | | |
suite | public static Test suite()(Code) | | |
testConcurrentLargeStateTranfer | public void testConcurrentLargeStateTranfer()(Code) | | |
testConcurrentSmallStateTranfer | public void testConcurrentSmallStateTranfer()(Code) | | |
testConcurrentStartupLargeState | public void testConcurrentStartupLargeState()(Code) | | |
testConcurrentStartupSmallState | public void testConcurrentStartupSmallState()(Code) | | |
useBlocking | public boolean useBlocking()(Code) | | |
Methods inherited from org.jgroups.tests.ChannelTestBase | public static void acquireSemaphore(Semaphore semaphore, long timeout, int count) throws Exception(Code)(Java Doc) public static boolean areViewsComplete(MemberRetrievable[] channels, int memberCount)(Code)(Java Doc) public static void blockUntilViewsReceived(MemberRetrievable[] channels, long timeout)(Code)(Java Doc) public static void blockUntilViewsReceived(Collection channels, long timeout)(Code)(Java Doc) public static void blockUntilViewsReceived(MemberRetrievable[] channels, int count, long timeout)(Code)(Java Doc) public static void blockUntilViewsReceived(Collection channels, int count, long timeout)(Code)(Java Doc) protected String[] createApplicationNames(int applicationCount)(Code)(Java Doc) protected Channel createChannel(Object id) throws Exception(Code)(Java Doc) protected Channel createChannel() throws Exception(Code)(Java Doc) protected String[] createMuxApplicationNames(int muxApplicationstPerChannelCount)(Code)(Java Doc) protected String[] createMuxApplicationNames(int muxApplicationstPerChannelCount, int muxFactoryCount)(Code)(Java Doc) protected int getMuxFactoryCount()(Code)(Java Doc) protected String getNextChannelName()(Code)(Java Doc) protected boolean isMuxChannelUsed()(Code)(Java Doc) public static boolean isViewComplete(MemberRetrievable channel, int memberCount)(Code)(Java Doc) protected void setUp() throws Exception(Code)(Java Doc) protected boolean shouldCompareThreadCount()(Code)(Java Doc) public static void sleepRandom(int maxTime)(Code)(Java Doc) public static void sleepThread(long sleeptime)(Code)(Java Doc) public static void takeAllPermits(Semaphore semaphore, int count)(Code)(Java Doc) protected void tearDown() throws Exception(Code)(Java Doc) protected boolean useBlocking()(Code)(Java Doc)
|
|
|