public class org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest extends org.apache.zookeeper.ZKTestCase
{
private static final org.slf4j.Logger LOG;
public void <init>()
{
org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest v;
v := @this: org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest;
specialinvoke v.<org.apache.zookeeper.ZKTestCase: void <init>()>();
return;
}
public void testTooManySyncsNonessential(org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType)
{
org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType v;
org.junit.jupiter.api.function.Executable v;
v := @this: org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest;
v := @parameter: org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType;
v = staticinvoke <org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest$lambda_testTooManySyncsNonessential_0__186: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Lorg/apache/zookeeper/server/quorum/SyncThrottleException;", v);
return;
}
public void testTooManySyncsEssential(org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType)
{
org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType v;
org.junit.jupiter.api.function.Executable v;
v := @this: org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest;
v := @parameter: org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType;
v = staticinvoke <org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest$lambda_testTooManySyncsEssential_1__187: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Lorg/apache/zookeeper/server/quorum/SyncThrottleException;", v);
return;
}
public void testNoThrottle(org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType) throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType v;
int v, v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler v;
v := @this: org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest;
v := @parameter: org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType;
v = new org.apache.zookeeper.server.quorum.LearnerSyncThrottler;
specialinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void <init>(int,org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType)>(5, v);
label:
v = 0;
label:
if v >= 6 goto label;
virtualinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void beginSync(boolean)>(1);
v = v + 1;
goto label;
label:
v := @caughtexception;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("essential syncs should not be throttled");
label:
virtualinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void endSync()>();
v = 0;
label:
if v >= 5 goto label;
virtualinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void endSync()>();
virtualinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void beginSync(boolean)>(0);
v = v + 1;
goto label;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean,java.lang.String)>(1, "should get here without exception");
return;
catch org.apache.zookeeper.server.quorum.SyncThrottleException from label to label with label;
}
public void testTryWithResourceNoThrottle(org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType) throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType v;
int v, v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler v;
v := @this: org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest;
v := @parameter: org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType;
v = new org.apache.zookeeper.server.quorum.LearnerSyncThrottler;
specialinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void <init>(int,org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType)>(1, v);
v = 0;
label:
if v >= 3 goto label;
virtualinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void beginSync(boolean)>(0);
label:
v = virtualinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: int getSyncInProgress()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
label:
virtualinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void endSync()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void endSync()>();
throw v;
label:
v = v + 1;
goto label;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void testTryWithResourceThrottle(org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType) throws java.lang.Exception
{
java.lang.Throwable v, v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler v;
v := @this: org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest;
v := @parameter: org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType;
v = new org.apache.zookeeper.server.quorum.LearnerSyncThrottler;
specialinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void <init>(int,org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType)>(1, v);
label:
virtualinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void beginSync(boolean)>(1);
label:
virtualinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void beginSync(boolean)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("shouldn\'t be able to have both syncs open");
label:
goto label;
label:
v := @caughtexception;
label:
virtualinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void endSync()>();
label:
goto label;
label:
v := @caughtexception;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("First sync shouldn\'t be throttled");
label:
return;
catch org.apache.zookeeper.server.quorum.SyncThrottleException from label to label with label;
catch org.apache.zookeeper.server.quorum.SyncThrottleException from label to label with label;
}
public void testParallelNoThrottle(org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType)
{
java.lang.Throwable v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest$1 v;
java.util.ArrayList v;
java.util.concurrent.Future v;
int v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler v;
java.util.concurrent.ExecutorService v;
boolean v, v;
java.util.Iterator v;
java.lang.Exception v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest v;
java.util.concurrent.CountDownLatch v, v;
org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType v;
java.lang.Object v, v;
v := @this: org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest;
v := @parameter: org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType;
v = new org.apache.zookeeper.server.quorum.LearnerSyncThrottler;
specialinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottler: void <init>(int,org.apache.zookeeper.server.quorum.LearnerSyncThrottler$SyncType)>(50, v);
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.ExecutorService newFixedThreadPool(int)>(50);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(50);
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(50);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(50);
v = 0;
label:
if v >= 50 goto label;
v = new org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest$1;
specialinvoke v.<org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest$1: void <init>(org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest,java.util.concurrent.CountDownLatch,org.apache.zookeeper.server.quorum.LearnerSyncThrottler,java.util.concurrent.CountDownLatch)>(v, v, v, v);
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.concurrent.Future submit(java.util.concurrent.Callable)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.concurrent.Future: java.lang.Object get()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
goto label;
label:
interfaceinvoke v.<java.util.concurrent.ExecutorService: void shutdown()>();
goto label;
label:
v := @caughtexception;
label:
interfaceinvoke v.<java.util.concurrent.ExecutorService: void shutdown()>();
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<java.util.concurrent.ExecutorService: void shutdown()>();
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/zookeeper/server/quorum/LearnerSyncThrottlerTest;");
<org.apache.zookeeper.server.quorum.LearnerSyncThrottlerTest: org.slf4j.Logger LOG> = v;
return;
}
}