|
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