github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 14:47:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

Write generated Java files to disk only if debug flag is set

Browse source 
Fixes #11082
This commit is contained in:
Dan Hermann 2019-08-13 14:36:09 -05:00
parent 44f08e20c7
commit 5125e0729e
1 changed files with 11 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

20
logstash-core/src/main/java/org/logstash/config/ir/compiler/ComputeStepSyntaxElement.java
View file

@ -74,9 +74,13 @@ public final class ComputeStepSyntaxElement<T extends Dataset> {
} else {
final String name = String.format("CompiledDataset%d", CLASS_CACHE.size());
final String code = generateCode(name);
final Path sourceFile = SOURCE_DIR.resolve(String.format("%s.java", name));
Files.write(sourceFile, code.getBytes(StandardCharsets.UTF_8));
COMPILER.cookFile(sourceFile.toFile());
if (SOURCE_DIR != null) {
final Path sourceFile = SOURCE_DIR.resolve(String.format("%s.java", name));
Files.write(sourceFile, code.getBytes(StandardCharsets.UTF_8));
COMPILER.cookFile(sourceFile.toFile());
} else {
COMPILER.cook(code);
}
COMPILER.setParentClassLoader(COMPILER.getClassLoader());
clazz = (Class<T>) COMPILER.getClassLoader().loadClass(
String.format("org.logstash.generated.%s", name)
@ -125,17 +129,15 @@ public final class ComputeStepSyntaxElement<T extends Dataset> {
}
private static Path debugDir() {
final Path sourceDir;
Path sourceDir = null;
try {
final Path parentDir;
final String dir = System.getProperty(ICookable.SYSTEM_PROPERTY_SOURCE_DEBUGGING_DIR);
if (dir == null) {
parentDir = Files.createTempDirectory("logstash");
} else {
if (dir != null) {
parentDir = Paths.get(dir);
sourceDir = parentDir.resolve("org").resolve("logstash").resolve("generated");
Files.createDirectories(sourceDir);
}
sourceDir = parentDir.resolve("org").resolve("logstash").resolve("generated");
Files.createDirectories(sourceDir);
} catch (final IOException ex) {
throw new IllegalStateException(ex);
}