|
@@ -27,10 +27,9 @@ import java.util.List;
|
|
import java.util.ListIterator;
|
|
import java.util.ListIterator;
|
|
import java.util.Map;
|
|
import java.util.Map;
|
|
|
|
|
|
-import org.junit.After;
|
|
|
|
-import org.junit.Assert;
|
|
|
|
-import org.junit.Before;
|
|
|
|
-import org.junit.Test;
|
|
|
|
|
|
+import org.junit.jupiter.api.AfterEach;
|
|
|
|
+import org.junit.jupiter.api.BeforeEach;
|
|
|
|
+import org.junit.jupiter.api.Test;
|
|
|
|
|
|
import org.apache.hadoop.conf.Configuration;
|
|
import org.apache.hadoop.conf.Configuration;
|
|
import org.apache.hadoop.fs.CommonConfigurationKeys;
|
|
import org.apache.hadoop.fs.CommonConfigurationKeys;
|
|
@@ -42,6 +41,12 @@ import org.apache.hadoop.fs.permission.FsPermission;
|
|
import org.apache.hadoop.yarn.conf.YarnConfiguration;
|
|
import org.apache.hadoop.yarn.conf.YarnConfiguration;
|
|
import org.apache.hadoop.yarn.server.nodemanager.DirectoryCollection.DirsChangeListener;
|
|
import org.apache.hadoop.yarn.server.nodemanager.DirectoryCollection.DirsChangeListener;
|
|
|
|
|
|
|
|
+import static org.junit.jupiter.api.Assertions.assertEquals;
|
|
|
|
+import static org.junit.jupiter.api.Assertions.assertFalse;
|
|
|
|
+import static org.junit.jupiter.api.Assertions.assertNotNull;
|
|
|
|
+import static org.junit.jupiter.api.Assertions.assertNull;
|
|
|
|
+import static org.junit.jupiter.api.Assertions.assertTrue;
|
|
|
|
+
|
|
public class TestDirectoryCollection {
|
|
public class TestDirectoryCollection {
|
|
|
|
|
|
private File testDir;
|
|
private File testDir;
|
|
@@ -50,7 +55,7 @@ public class TestDirectoryCollection {
|
|
private Configuration conf;
|
|
private Configuration conf;
|
|
private FileContext localFs;
|
|
private FileContext localFs;
|
|
|
|
|
|
- @Before
|
|
|
|
|
|
+ @BeforeEach
|
|
public void setupForTests() throws IOException {
|
|
public void setupForTests() throws IOException {
|
|
conf = new Configuration();
|
|
conf = new Configuration();
|
|
localFs = FileContext.getLocalFSFileContext(conf);
|
|
localFs = FileContext.getLocalFSFileContext(conf);
|
|
@@ -59,7 +64,7 @@ public class TestDirectoryCollection {
|
|
testFile.createNewFile();
|
|
testFile.createNewFile();
|
|
}
|
|
}
|
|
|
|
|
|
- @After
|
|
|
|
|
|
+ @AfterEach
|
|
public void teardown() {
|
|
public void teardown() {
|
|
FileUtil.fullyDelete(testDir);
|
|
FileUtil.fullyDelete(testDir);
|
|
}
|
|
}
|
|
@@ -81,8 +86,8 @@ public class TestDirectoryCollection {
|
|
// DiskErrorException will invalidate iterator of non-concurrent
|
|
// DiskErrorException will invalidate iterator of non-concurrent
|
|
// collections. ConcurrentModificationException will be thrown upon next
|
|
// collections. ConcurrentModificationException will be thrown upon next
|
|
// use of the iterator.
|
|
// use of the iterator.
|
|
- Assert.assertTrue("checkDirs did not remove test file from directory list",
|
|
|
|
- dc.checkDirs());
|
|
|
|
|
|
+ assertTrue(dc.checkDirs(),
|
|
|
|
+ "checkDirs did not remove test file from directory list");
|
|
|
|
|
|
// Verify no ConcurrentModification is thrown
|
|
// Verify no ConcurrentModification is thrown
|
|
li.next();
|
|
li.next();
|
|
@@ -110,17 +115,17 @@ public class TestDirectoryCollection {
|
|
FsPermission defaultPerm = FsPermission.getDefault()
|
|
FsPermission defaultPerm = FsPermission.getDefault()
|
|
.applyUMask(new FsPermission((short)FsPermission.DEFAULT_UMASK));
|
|
.applyUMask(new FsPermission((short)FsPermission.DEFAULT_UMASK));
|
|
boolean createResult = dc.createNonExistentDirs(localFs, defaultPerm);
|
|
boolean createResult = dc.createNonExistentDirs(localFs, defaultPerm);
|
|
- Assert.assertTrue(createResult);
|
|
|
|
|
|
+ assertTrue(createResult);
|
|
|
|
|
|
FileStatus status = localFs.getFileStatus(new Path(dirA));
|
|
FileStatus status = localFs.getFileStatus(new Path(dirA));
|
|
- Assert.assertEquals("local dir parent not created with proper permissions",
|
|
|
|
- defaultPerm, status.getPermission());
|
|
|
|
|
|
+ assertEquals(defaultPerm, status.getPermission(),
|
|
|
|
+ "local dir parent not created with proper permissions");
|
|
status = localFs.getFileStatus(new Path(dirB));
|
|
status = localFs.getFileStatus(new Path(dirB));
|
|
- Assert.assertEquals("local dir not created with proper permissions",
|
|
|
|
- defaultPerm, status.getPermission());
|
|
|
|
|
|
+ assertEquals(defaultPerm, status.getPermission(),
|
|
|
|
+ "local dir not created with proper permissions");
|
|
status = localFs.getFileStatus(pathC);
|
|
status = localFs.getFileStatus(pathC);
|
|
- Assert.assertEquals("existing local directory permissions modified",
|
|
|
|
- permDirC, status.getPermission());
|
|
|
|
|
|
+ assertEquals(permDirC, status.getPermission(),
|
|
|
|
+ "existing local directory permissions modified");
|
|
}
|
|
}
|
|
|
|
|
|
@Test
|
|
@Test
|
|
@@ -130,52 +135,53 @@ public class TestDirectoryCollection {
|
|
String[] dirs = { dirA };
|
|
String[] dirs = { dirA };
|
|
DirectoryCollection dc = new DirectoryCollection(dirs, 0.0F);
|
|
DirectoryCollection dc = new DirectoryCollection(dirs, 0.0F);
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertEquals(1, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(1, dc.getFullDirs().size());
|
|
|
|
- Assert.assertNotNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
- Assert.assertEquals(DirectoryCollection.DiskErrorCause.DISK_FULL, dc.getDirectoryErrorInfo(dirA).cause);
|
|
|
|
|
|
+ assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
+ assertEquals(1, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(1, dc.getFullDirs().size());
|
|
|
|
+ assertNotNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
+ assertEquals(DirectoryCollection.DiskErrorCause.DISK_FULL,
|
|
|
|
+ dc.getDirectoryErrorInfo(dirA).cause);
|
|
|
|
|
|
// no good dirs
|
|
// no good dirs
|
|
- Assert.assertEquals(0, dc.getGoodDirsDiskUtilizationPercentage());
|
|
|
|
|
|
+ assertEquals(0, dc.getGoodDirsDiskUtilizationPercentage());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, 100.0F);
|
|
dc = new DirectoryCollection(dirs, 100.0F);
|
|
int utilizedSpacePerc =
|
|
int utilizedSpacePerc =
|
|
(int) ((testDir.getTotalSpace() - testDir.getUsableSpace()) * 100 /
|
|
(int) ((testDir.getTotalSpace() - testDir.getUsableSpace()) * 100 /
|
|
testDir.getTotalSpace());
|
|
testDir.getTotalSpace());
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFullDirs().size());
|
|
|
|
- Assert.assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
+ assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFullDirs().size());
|
|
|
|
+ assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
- Assert.assertEquals(utilizedSpacePerc,
|
|
|
|
|
|
+ assertEquals(utilizedSpacePerc,
|
|
dc.getGoodDirsDiskUtilizationPercentage());
|
|
dc.getGoodDirsDiskUtilizationPercentage());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, testDir.getTotalSpace() / (1024 * 1024));
|
|
dc = new DirectoryCollection(dirs, testDir.getTotalSpace() / (1024 * 1024));
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertEquals(1, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(1, dc.getFullDirs().size());
|
|
|
|
- Assert.assertNotNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
+ assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
+ assertEquals(1, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(1, dc.getFullDirs().size());
|
|
|
|
+ assertNotNull(dc.getDirectoryErrorInfo(dirA));
|
|
// no good dirs
|
|
// no good dirs
|
|
- Assert.assertEquals(0, dc.getGoodDirsDiskUtilizationPercentage());
|
|
|
|
|
|
+ assertEquals(0, dc.getGoodDirsDiskUtilizationPercentage());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, 100.0F, 100.0F, 0);
|
|
dc = new DirectoryCollection(dirs, 100.0F, 100.0F, 0);
|
|
utilizedSpacePerc =
|
|
utilizedSpacePerc =
|
|
(int)((testDir.getTotalSpace() - testDir.getUsableSpace()) * 100 /
|
|
(int)((testDir.getTotalSpace() - testDir.getUsableSpace()) * 100 /
|
|
testDir.getTotalSpace());
|
|
testDir.getTotalSpace());
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFullDirs().size());
|
|
|
|
- Assert.assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
+ assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFullDirs().size());
|
|
|
|
+ assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
- Assert.assertEquals(utilizedSpacePerc,
|
|
|
|
|
|
+ assertEquals(utilizedSpacePerc,
|
|
dc.getGoodDirsDiskUtilizationPercentage());
|
|
dc.getGoodDirsDiskUtilizationPercentage());
|
|
}
|
|
}
|
|
|
|
|
|
@@ -188,30 +194,30 @@ public class TestDirectoryCollection {
|
|
|
|
|
|
// Disable disk utilization threshold.
|
|
// Disable disk utilization threshold.
|
|
dc.setDiskUtilizationThresholdEnabled(false);
|
|
dc.setDiskUtilizationThresholdEnabled(false);
|
|
- Assert.assertFalse(dc.getDiskUtilizationThresholdEnabled());
|
|
|
|
|
|
+ assertFalse(dc.getDiskUtilizationThresholdEnabled());
|
|
|
|
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFullDirs().size());
|
|
|
|
- Assert.assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
+ assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFullDirs().size());
|
|
|
|
+ assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
// Enable disk utilization threshold.
|
|
// Enable disk utilization threshold.
|
|
dc.setDiskUtilizationThresholdEnabled(true);
|
|
dc.setDiskUtilizationThresholdEnabled(true);
|
|
- Assert.assertTrue(dc.getDiskUtilizationThresholdEnabled());
|
|
|
|
|
|
+ assertTrue(dc.getDiskUtilizationThresholdEnabled());
|
|
|
|
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertEquals(1, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(1, dc.getFullDirs().size());
|
|
|
|
- Assert.assertNotNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
- Assert.assertEquals(DirectoryCollection.DiskErrorCause.DISK_FULL,
|
|
|
|
|
|
+ assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
+ assertEquals(1, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(1, dc.getFullDirs().size());
|
|
|
|
+ assertNotNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
+ assertEquals(DirectoryCollection.DiskErrorCause.DISK_FULL,
|
|
dc.getDirectoryErrorInfo(dirA).cause);
|
|
dc.getDirectoryErrorInfo(dirA).cause);
|
|
|
|
|
|
// no good dirs
|
|
// no good dirs
|
|
- Assert.assertEquals(0,
|
|
|
|
|
|
+ assertEquals(0,
|
|
dc.getGoodDirsDiskUtilizationPercentage());
|
|
dc.getGoodDirsDiskUtilizationPercentage());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, 100.0F);
|
|
dc = new DirectoryCollection(dirs, 100.0F);
|
|
@@ -219,13 +225,13 @@ public class TestDirectoryCollection {
|
|
(int) ((testDir.getTotalSpace() - testDir.getUsableSpace()) * 100 /
|
|
(int) ((testDir.getTotalSpace() - testDir.getUsableSpace()) * 100 /
|
|
testDir.getTotalSpace());
|
|
testDir.getTotalSpace());
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFullDirs().size());
|
|
|
|
- Assert.assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
+ assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFullDirs().size());
|
|
|
|
+ assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
- Assert.assertEquals(utilizedSpacePerc,
|
|
|
|
|
|
+ assertEquals(utilizedSpacePerc,
|
|
dc.getGoodDirsDiskUtilizationPercentage());
|
|
dc.getGoodDirsDiskUtilizationPercentage());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs,
|
|
dc = new DirectoryCollection(dirs,
|
|
@@ -233,48 +239,48 @@ public class TestDirectoryCollection {
|
|
|
|
|
|
// Disable disk utilization threshold.
|
|
// Disable disk utilization threshold.
|
|
dc.setDiskUtilizationThresholdEnabled(false);
|
|
dc.setDiskUtilizationThresholdEnabled(false);
|
|
- Assert.assertFalse(dc.getDiskUtilizationThresholdEnabled());
|
|
|
|
|
|
+ assertFalse(dc.getDiskUtilizationThresholdEnabled());
|
|
|
|
|
|
// Disable disk free space threshold.
|
|
// Disable disk free space threshold.
|
|
dc.setDiskFreeSpaceThresholdEnabled(false);
|
|
dc.setDiskFreeSpaceThresholdEnabled(false);
|
|
- Assert.assertFalse(dc.getDiskFreeSpaceThresholdEnabled());
|
|
|
|
|
|
+ assertFalse(dc.getDiskFreeSpaceThresholdEnabled());
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
|
|
|
|
- Assert.assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFullDirs().size());
|
|
|
|
- Assert.assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
+ assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFullDirs().size());
|
|
|
|
+ assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
dc = new DirectoryCollection(dirs,
|
|
dc = new DirectoryCollection(dirs,
|
|
testDir.getTotalSpace() / (1024 * 1024));
|
|
testDir.getTotalSpace() / (1024 * 1024));
|
|
|
|
|
|
// Enable disk free space threshold.
|
|
// Enable disk free space threshold.
|
|
dc.setDiskFreeSpaceThresholdEnabled(true);
|
|
dc.setDiskFreeSpaceThresholdEnabled(true);
|
|
- Assert.assertTrue(dc.getDiskFreeSpaceThresholdEnabled());
|
|
|
|
|
|
+ assertTrue(dc.getDiskFreeSpaceThresholdEnabled());
|
|
|
|
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
|
|
|
|
- Assert.assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertEquals(1, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(1, dc.getFullDirs().size());
|
|
|
|
- Assert.assertNotNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
+ assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
+ assertEquals(1, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(1, dc.getFullDirs().size());
|
|
|
|
+ assertNotNull(dc.getDirectoryErrorInfo(dirA));
|
|
// no good dirs
|
|
// no good dirs
|
|
- Assert.assertEquals(0, dc.getGoodDirsDiskUtilizationPercentage());
|
|
|
|
|
|
+ assertEquals(0, dc.getGoodDirsDiskUtilizationPercentage());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, 100.0F, 100.0F, 0);
|
|
dc = new DirectoryCollection(dirs, 100.0F, 100.0F, 0);
|
|
utilizedSpacePerc =
|
|
utilizedSpacePerc =
|
|
(int)((testDir.getTotalSpace() - testDir.getUsableSpace()) * 100 /
|
|
(int)((testDir.getTotalSpace() - testDir.getUsableSpace()) * 100 /
|
|
testDir.getTotalSpace());
|
|
testDir.getTotalSpace());
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFullDirs().size());
|
|
|
|
- Assert.assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
+ assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFullDirs().size());
|
|
|
|
+ assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
- Assert.assertEquals(utilizedSpacePerc,
|
|
|
|
|
|
+ assertEquals(utilizedSpacePerc,
|
|
dc.getGoodDirsDiskUtilizationPercentage());
|
|
dc.getGoodDirsDiskUtilizationPercentage());
|
|
}
|
|
}
|
|
|
|
|
|
@@ -286,48 +292,48 @@ public class TestDirectoryCollection {
|
|
float testValue = 57.5F;
|
|
float testValue = 57.5F;
|
|
float delta = 0.1F;
|
|
float delta = 0.1F;
|
|
dc.setDiskUtilizationPercentageCutoff(testValue, 50.0F);
|
|
dc.setDiskUtilizationPercentageCutoff(testValue, 50.0F);
|
|
- Assert.assertEquals(testValue, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(testValue, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(50.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(50.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
|
|
|
|
testValue = -57.5F;
|
|
testValue = -57.5F;
|
|
dc.setDiskUtilizationPercentageCutoff(testValue, testValue);
|
|
dc.setDiskUtilizationPercentageCutoff(testValue, testValue);
|
|
- Assert.assertEquals(0.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(0.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(0.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(0.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
|
|
|
|
testValue = 157.5F;
|
|
testValue = 157.5F;
|
|
dc.setDiskUtilizationPercentageCutoff(testValue, testValue);
|
|
dc.setDiskUtilizationPercentageCutoff(testValue, testValue);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
|
|
|
|
long lowSpaceValue = 57;
|
|
long lowSpaceValue = 57;
|
|
dc.setDiskUtilizationSpaceCutoff(lowSpaceValue);
|
|
dc.setDiskUtilizationSpaceCutoff(lowSpaceValue);
|
|
- Assert.assertEquals(lowSpaceValue, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(lowSpaceValue, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(lowSpaceValue, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(lowSpaceValue, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
long highSpaceValue = 73;
|
|
long highSpaceValue = 73;
|
|
dc.setDiskUtilizationSpaceCutoff(lowSpaceValue, highSpaceValue);
|
|
dc.setDiskUtilizationSpaceCutoff(lowSpaceValue, highSpaceValue);
|
|
- Assert.assertEquals(lowSpaceValue, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(highSpaceValue, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(lowSpaceValue, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(highSpaceValue, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
lowSpaceValue = -57;
|
|
lowSpaceValue = -57;
|
|
dc.setDiskUtilizationSpaceCutoff(lowSpaceValue);
|
|
dc.setDiskUtilizationSpaceCutoff(lowSpaceValue);
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
dc.setDiskUtilizationSpaceCutoff(lowSpaceValue, highSpaceValue);
|
|
dc.setDiskUtilizationSpaceCutoff(lowSpaceValue, highSpaceValue);
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(highSpaceValue, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(highSpaceValue, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
highSpaceValue = -10;
|
|
highSpaceValue = -10;
|
|
dc.setDiskUtilizationSpaceCutoff(lowSpaceValue, highSpaceValue);
|
|
dc.setDiskUtilizationSpaceCutoff(lowSpaceValue, highSpaceValue);
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
lowSpaceValue = 33;
|
|
lowSpaceValue = 33;
|
|
dc.setDiskUtilizationSpaceCutoff(lowSpaceValue, highSpaceValue);
|
|
dc.setDiskUtilizationSpaceCutoff(lowSpaceValue, highSpaceValue);
|
|
- Assert.assertEquals(lowSpaceValue, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(lowSpaceValue, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(lowSpaceValue, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(lowSpaceValue, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
@@ -338,20 +344,21 @@ public class TestDirectoryCollection {
|
|
String[] dirs = { dirA };
|
|
String[] dirs = { dirA };
|
|
DirectoryCollection dc = new DirectoryCollection(dirs, 0.0F);
|
|
DirectoryCollection dc = new DirectoryCollection(dirs, 0.0F);
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(1, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(1, dc.getFullDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertNotNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
- Assert.assertEquals(DirectoryCollection.DiskErrorCause.DISK_FULL, dc.getDirectoryErrorInfo(dirA).cause);
|
|
|
|
|
|
+ assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(1, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(1, dc.getFullDirs().size());
|
|
|
|
+ assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
+ assertNotNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
+ assertEquals(DirectoryCollection.DiskErrorCause.DISK_FULL,
|
|
|
|
+ dc.getDirectoryErrorInfo(dirA).cause);
|
|
|
|
|
|
dc.setDiskUtilizationPercentageCutoff(100.0F, 100.0F);
|
|
dc.setDiskUtilizationPercentageCutoff(100.0F, 100.0F);
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFullDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
+ assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFullDirs().size());
|
|
|
|
+ assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
+ assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
conf.set(CommonConfigurationKeys.FS_PERMISSIONS_UMASK_KEY, "077");
|
|
conf.set(CommonConfigurationKeys.FS_PERMISSIONS_UMASK_KEY, "077");
|
|
|
|
|
|
@@ -366,21 +373,21 @@ public class TestDirectoryCollection {
|
|
|
|
|
|
dc = new DirectoryCollection(dirs2, 100.0F);
|
|
dc = new DirectoryCollection(dirs2, 100.0F);
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(1, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFullDirs().size());
|
|
|
|
- Assert.assertEquals(1, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertNotNull(dc.getDirectoryErrorInfo(dirB));
|
|
|
|
- Assert.assertEquals(DirectoryCollection.DiskErrorCause.OTHER, dc.getDirectoryErrorInfo(dirB).cause);
|
|
|
|
|
|
+ assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(1, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFullDirs().size());
|
|
|
|
+ assertEquals(1, dc.getErroredDirs().size());
|
|
|
|
+ assertNotNull(dc.getDirectoryErrorInfo(dirB));
|
|
|
|
+ assertEquals(DirectoryCollection.DiskErrorCause.OTHER, dc.getDirectoryErrorInfo(dirB).cause);
|
|
|
|
|
|
permDirB = new FsPermission((short) 0700);
|
|
permDirB = new FsPermission((short) 0700);
|
|
localFs.setPermission(pathB, permDirB);
|
|
localFs.setPermission(pathB, permDirB);
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getFullDirs().size());
|
|
|
|
- Assert.assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
- Assert.assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
|
|
|
|
+ assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFailedDirs().size());
|
|
|
|
+ assertEquals(0, dc.getFullDirs().size());
|
|
|
|
+ assertEquals(0, dc.getErroredDirs().size());
|
|
|
|
+ assertNull(dc.getDirectoryErrorInfo(dirA));
|
|
}
|
|
}
|
|
|
|
|
|
@Test
|
|
@Test
|
|
@@ -389,100 +396,100 @@ public class TestDirectoryCollection {
|
|
String[] dirs = { "dir" };
|
|
String[] dirs = { "dir" };
|
|
float delta = 0.1F;
|
|
float delta = 0.1F;
|
|
DirectoryCollection dc = new DirectoryCollection(dirs);
|
|
DirectoryCollection dc = new DirectoryCollection(dirs);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, 57.5F);
|
|
dc = new DirectoryCollection(dirs, 57.5F);
|
|
- Assert.assertEquals(57.5F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(57.5F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(57.5F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(57.5F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, 57);
|
|
dc = new DirectoryCollection(dirs, 57);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(57, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(57, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(57, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(57, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, 57, 73);
|
|
dc = new DirectoryCollection(dirs, 57, 73);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(57, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(73, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(57, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(73, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, 57, 33);
|
|
dc = new DirectoryCollection(dirs, 57, 33);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(57, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(57, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(57, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(57, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, 57, -33);
|
|
dc = new DirectoryCollection(dirs, 57, -33);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(57, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(57, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(57, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(57, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, -57, -33);
|
|
dc = new DirectoryCollection(dirs, -57, -33);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, -57, 33);
|
|
dc = new DirectoryCollection(dirs, -57, 33);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(33, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(33, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, 57.5F, 50.5F, 67);
|
|
dc = new DirectoryCollection(dirs, 57.5F, 50.5F, 67);
|
|
- Assert.assertEquals(57.5F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(57.5F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(50.5F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(50.5F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(67, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(67, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(67, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(67, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, -57.5F, -57.5F, -67);
|
|
dc = new DirectoryCollection(dirs, -57.5F, -57.5F, -67);
|
|
- Assert.assertEquals(0.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(0.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(0.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(0.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, 157.5F, 157.5F, -67);
|
|
dc = new DirectoryCollection(dirs, 157.5F, 157.5F, -67);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(0, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
dc = new DirectoryCollection(dirs, 157.5F, 157.5F, 5, 10);
|
|
dc = new DirectoryCollection(dirs, 157.5F, 157.5F, 5, 10);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffHigh(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
|
|
|
|
+ assertEquals(100.0F, dc.getDiskUtilizationPercentageCutoffLow(),
|
|
delta);
|
|
delta);
|
|
- Assert.assertEquals(5, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
- Assert.assertEquals(10, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
|
|
|
|
+ assertEquals(5, dc.getDiskUtilizationSpaceCutoffLow());
|
|
|
|
+ assertEquals(10, dc.getDiskUtilizationSpaceCutoffHigh());
|
|
}
|
|
}
|
|
|
|
|
|
@Test
|
|
@Test
|
|
@@ -494,31 +501,31 @@ public class TestDirectoryCollection {
|
|
String dirA = new File(testDir, "dirA").getPath();
|
|
String dirA = new File(testDir, "dirA").getPath();
|
|
String[] dirs = { dirA };
|
|
String[] dirs = { dirA };
|
|
DirectoryCollection dc = new DirectoryCollection(dirs, 0.0F);
|
|
DirectoryCollection dc = new DirectoryCollection(dirs, 0.0F);
|
|
- Assert.assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(listener1.num, 0);
|
|
|
|
- Assert.assertEquals(listener2.num, 0);
|
|
|
|
- Assert.assertEquals(listener3.num, 0);
|
|
|
|
|
|
+ assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(listener1.num, 0);
|
|
|
|
+ assertEquals(listener2.num, 0);
|
|
|
|
+ assertEquals(listener3.num, 0);
|
|
dc.registerDirsChangeListener(listener1);
|
|
dc.registerDirsChangeListener(listener1);
|
|
dc.registerDirsChangeListener(listener2);
|
|
dc.registerDirsChangeListener(listener2);
|
|
dc.registerDirsChangeListener(listener3);
|
|
dc.registerDirsChangeListener(listener3);
|
|
- Assert.assertEquals(listener1.num, 1);
|
|
|
|
- Assert.assertEquals(listener2.num, 1);
|
|
|
|
- Assert.assertEquals(listener3.num, 1);
|
|
|
|
|
|
+ assertEquals(listener1.num, 1);
|
|
|
|
+ assertEquals(listener2.num, 1);
|
|
|
|
+ assertEquals(listener3.num, 1);
|
|
|
|
|
|
dc.deregisterDirsChangeListener(listener3);
|
|
dc.deregisterDirsChangeListener(listener3);
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(listener1.num, 2);
|
|
|
|
- Assert.assertEquals(listener2.num, 2);
|
|
|
|
- Assert.assertEquals(listener3.num, 1);
|
|
|
|
|
|
+ assertEquals(0, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(listener1.num, 2);
|
|
|
|
+ assertEquals(listener2.num, 2);
|
|
|
|
+ assertEquals(listener3.num, 1);
|
|
|
|
|
|
dc.deregisterDirsChangeListener(listener2);
|
|
dc.deregisterDirsChangeListener(listener2);
|
|
dc.setDiskUtilizationPercentageCutoff(100.0F, 100.0F);
|
|
dc.setDiskUtilizationPercentageCutoff(100.0F, 100.0F);
|
|
dc.checkDirs();
|
|
dc.checkDirs();
|
|
- Assert.assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
- Assert.assertEquals(listener1.num, 3);
|
|
|
|
- Assert.assertEquals(listener2.num, 2);
|
|
|
|
- Assert.assertEquals(listener3.num, 1);
|
|
|
|
|
|
+ assertEquals(1, dc.getGoodDirs().size());
|
|
|
|
+ assertEquals(listener1.num, 3);
|
|
|
|
+ assertEquals(listener2.num, 2);
|
|
|
|
+ assertEquals(listener3.num, 1);
|
|
}
|
|
}
|
|
|
|
|
|
@Test
|
|
@Test
|
|
@@ -531,8 +538,8 @@ public class TestDirectoryCollection {
|
|
dc.setSubAccessibilityValidationEnabled(true);
|
|
dc.setSubAccessibilityValidationEnabled(true);
|
|
Map<String, DirectoryCollection.DiskErrorInformation> diskErrorInformationMap =
|
|
Map<String, DirectoryCollection.DiskErrorInformation> diskErrorInformationMap =
|
|
dc.testDirs(Collections.singletonList(testDir.toString()), Collections.emptySet());
|
|
dc.testDirs(Collections.singletonList(testDir.toString()), Collections.emptySet());
|
|
- Assert.assertEquals(1, diskErrorInformationMap.size());
|
|
|
|
- Assert.assertTrue(diskErrorInformationMap.values().iterator().next()
|
|
|
|
|
|
+ assertEquals(1, diskErrorInformationMap.size());
|
|
|
|
+ assertTrue(diskErrorInformationMap.values().iterator().next()
|
|
.message.contains(testFile.getName()));
|
|
.message.contains(testFile.getName()));
|
|
}
|
|
}
|
|
|
|
|