public class org.apache.zookeeper.server.DatadirCleanupManagerTest extends org.apache.zookeeper.ZKTestCase
{
private org.apache.zookeeper.server.DatadirCleanupManager purgeMgr;
private java.io.File snapDir;
private java.io.File dataLogDir;
public void <init>()
{
org.apache.zookeeper.server.DatadirCleanupManagerTest v;
v := @this: org.apache.zookeeper.server.DatadirCleanupManagerTest;
specialinvoke v.<org.apache.zookeeper.ZKTestCase: void <init>()>();
return;
}
public void setUp() throws java.lang.Exception
{
org.apache.zookeeper.server.DatadirCleanupManagerTest v;
java.io.File v;
v := @this: org.apache.zookeeper.server.DatadirCleanupManagerTest;
v = staticinvoke <org.apache.zookeeper.test.ClientBase: java.io.File createTmpDir()>();
v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: java.io.File snapDir> = v;
v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: java.io.File dataLogDir> = v;
return;
}
public void testPurgeTask() throws java.lang.Exception
{
org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus v, v, v, v;
int v;
org.apache.zookeeper.server.DatadirCleanupManagerTest v;
org.apache.zookeeper.server.DatadirCleanupManager v, v, v, v, v, v, v, v;
java.io.File v, v, v, v, v, v;
v := @this: org.apache.zookeeper.server.DatadirCleanupManagerTest;
v = new org.apache.zookeeper.server.DatadirCleanupManager;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: java.io.File snapDir>;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: java.io.File dataLogDir>;
specialinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: void <init>(java.io.File,java.io.File,int,int)>(v, v, 3, 1);
v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr> = v;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: void start()>();
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: java.io.File dataLogDir>;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
v = virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: java.io.File getDataLogDir()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Data log directory is not set as configured");
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: java.io.File snapDir>;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
v = virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: java.io.File getSnapDir()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Snapshot directory is not set as configured");
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
v = virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: int getSnapRetainCount()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int,java.lang.String)>(3, v, "Snapshot retain count is not set as configured");
v = <org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus: org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus STARTED>;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
v = virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus getPurgeTaskStatus()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Purge task is not started");
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: void shutdown()>();
v = <org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus: org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus COMPLETED>;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
v = virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus getPurgeTaskStatus()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Purge task is still running after shutdown");
return;
}
public void testWithZeroPurgeInterval() throws java.lang.Exception
{
org.apache.zookeeper.server.DatadirCleanupManager v, v, v, v, v;
org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus v, v, v, v;
java.io.File v, v;
org.apache.zookeeper.server.DatadirCleanupManagerTest v;
v := @this: org.apache.zookeeper.server.DatadirCleanupManagerTest;
v = new org.apache.zookeeper.server.DatadirCleanupManager;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: java.io.File snapDir>;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: java.io.File dataLogDir>;
specialinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: void <init>(java.io.File,java.io.File,int,int)>(v, v, 3, 0);
v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr> = v;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: void start()>();
v = <org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus: org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus NOT_STARTED>;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
v = virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus getPurgeTaskStatus()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Purge task is scheduled with zero purge interval");
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: void shutdown()>();
v = <org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus: org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus NOT_STARTED>;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
v = virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus getPurgeTaskStatus()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Purge task is scheduled with zero purge interval");
return;
}
public void testWithNegativePurgeInterval() throws java.lang.Exception
{
org.apache.zookeeper.server.DatadirCleanupManager v, v, v, v, v;
org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus v, v, v, v;
java.io.File v, v;
int v;
org.apache.zookeeper.server.DatadirCleanupManagerTest v;
v := @this: org.apache.zookeeper.server.DatadirCleanupManagerTest;
v = new org.apache.zookeeper.server.DatadirCleanupManager;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: java.io.File snapDir>;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: java.io.File dataLogDir>;
v = (int) -1;
specialinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: void <init>(java.io.File,java.io.File,int,int)>(v, v, 3, v);
v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr> = v;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: void start()>();
v = <org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus: org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus NOT_STARTED>;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
v = virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus getPurgeTaskStatus()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Purge task is scheduled with negative purge interval");
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: void shutdown()>();
v = <org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus: org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus NOT_STARTED>;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
v = virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: org.apache.zookeeper.server.DatadirCleanupManager$PurgeTaskStatus getPurgeTaskStatus()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, "Purge task is scheduled with negative purge interval");
return;
}
public void tearDown() throws java.lang.Exception
{
org.apache.zookeeper.server.DatadirCleanupManagerTest v;
org.apache.zookeeper.server.DatadirCleanupManager v, v;
v := @this: org.apache.zookeeper.server.DatadirCleanupManagerTest;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
if v == null goto label;
v = v.<org.apache.zookeeper.server.DatadirCleanupManagerTest: org.apache.zookeeper.server.DatadirCleanupManager purgeMgr>;
virtualinvoke v.<org.apache.zookeeper.server.DatadirCleanupManager: void shutdown()>();
label:
return;
}
}