|
19 | 19 | import java.util.UUID;
|
20 | 20 | import java.util.concurrent.Phaser;
|
21 | 21 | import java.util.concurrent.TimeUnit;
|
22 |
| -import java.util.concurrent.atomic.AtomicBoolean; |
23 | 22 | import java.util.concurrent.locks.LockSupport;
|
24 | 23 | import java.util.stream.Stream;
|
25 | 24 | import org.junit.jupiter.api.Test;
|
@@ -80,8 +79,7 @@ void testFromConfigNotWritable() throws Exception {
|
80 | 79 | Properties props = new Properties();
|
81 | 80 | props.put(ProfilingConfig.PROFILING_TEMP_DIR, myDir.toString());
|
82 | 81 | ConfigProvider configProvider = ConfigProvider.withPropertiesOverride(props);
|
83 |
| - TempLocationManager tempLocationManager = new TempLocationManager(configProvider); |
84 |
| - assertThrows(IllegalStateException.class, tempLocationManager::getTempDir); |
| 82 | + assertThrows(IllegalStateException.class, () -> new TempLocationManager(configProvider)); |
85 | 83 | }
|
86 | 84 |
|
87 | 85 | @ParameterizedTest
|
@@ -246,29 +244,6 @@ public FileVisitResult visitFile(Path file, BasicFileAttributes attrs)
|
246 | 244 | assertEquals(shouldSucceed, rslt);
|
247 | 245 | }
|
248 | 246 |
|
249 |
| - @Test |
250 |
| - void testShortCircuit() throws Exception { |
251 |
| - Path baseDir = |
252 |
| - Files.createTempDirectory( |
253 |
| - "ddprof-test-", |
254 |
| - PosixFilePermissions.asFileAttribute(PosixFilePermissions.fromString("rwx------"))); |
255 |
| - AtomicBoolean executed = new AtomicBoolean(); |
256 |
| - TempLocationManager.CleanupHook hook = |
257 |
| - new TempLocationManager.CleanupHook() { |
258 |
| - @Override |
259 |
| - public void onCleanupStart(boolean selfCleanup, long timeout, TimeUnit unit) { |
260 |
| - executed.set(true); |
261 |
| - } |
262 |
| - }; |
263 |
| - TempLocationManager instance = instance(baseDir, false, hook); |
264 |
| - |
265 |
| - instance.createDirStructure(); |
266 |
| - |
267 |
| - boolean ret = instance.cleanup(false); |
268 |
| - assertTrue(ret); |
269 |
| - assertFalse(executed.get()); |
270 |
| - } |
271 |
| - |
272 | 247 | private static Stream<Arguments> timeoutTestArguments() {
|
273 | 248 | List<Arguments> argumentsList = new ArrayList<>();
|
274 | 249 | for (boolean selfCleanup : new boolean[] {true, false}) {
|
|
0 commit comments