PMD.java
| Index Score | ||
|---|---|---|
![]() |
![]() |
net.sourceforge.pmd |
![]() |
![]() |
PMD |
View: Reasons, Metrics, Source Code
These are the metrics that contribute to the Enerjy Score for this file, ranked by impact. So the metrics listed at the top influence the score to a greater extent that the metrics listed at the bottom.
/**
* BSD-style license; for more info see http://pmd.sourceforge.net/license.html
*/
package net.sourceforge.pmd;
import java.io.BufferedInputStream;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.Reader;
import java.io.UnsupportedEncodingException;
import java.io.Writer;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.Enumeration;
import java.util.LinkedList;
import java.util.List;
import java.util.StringTokenizer;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.logging.Level;
import java.util.logging.Logger;
import java.util.zip.ZipEntry;
import java.util.zip.ZipFile;
import net.sourceforge.pmd.ast.CompilationUnit;
import net.sourceforge.pmd.ast.ParseException;
import net.sourceforge.pmd.cpd.FileFinder;
import net.sourceforge.pmd.cpd.SourceFileOrDirectoryFilter;
import net.sourceforge.pmd.parsers.Parser;
import net.sourceforge.pmd.renderers.Renderer;
import net.sourceforge.pmd.sourcetypehandlers.SourceTypeHandler;
import net.sourceforge.pmd.sourcetypehandlers.SourceTypeHandlerBroker;
import net.sourceforge.pmd.util.Benchmark;
import net.sourceforge.pmd.util.ConsoleLogHandler;
public class PMD {
public static final String EOL = System.getProperty("line.separator", "\n");
public static final String VERSION = "4.1rc1";
public static final String EXCLUDE_MARKER = "NOPMD";
private static final Logger LOG = Logger.getLogger(PMD.class.getName());
private String excludeMarker = EXCLUDE_MARKER;
private SourceTypeDiscoverer sourceTypeDiscoverer = new SourceTypeDiscoverer();
public PMD() {}
/**
* Processes the file read by the reader against the rule set.
*
* @param reader input stream reader
* @param ruleSets set of rules to process against the file
* @param ctx context in which PMD is operating. This contains the Renderer and
* whatnot
* @throws PMDException if the input could not be parsed or processed
*/
public void processFile(Reader reader, RuleSets ruleSets, RuleContext ctx)
throws PMDException {
SourceType sourceType = getSourceTypeOfFile(ctx.getSourceCodeFilename());
processFile(reader, ruleSets, ctx, sourceType);
}
/**
* Processes the file read by the reader against the rule set.
*
* @param reader input stream reader
* @param ruleSets set of rules to process against the file
* @param ctx context in which PMD is operating. This contains the Renderer and
* whatnot
* @param sourceType the SourceType of the source
* @throws PMDException if the input could not be parsed or processed
*/
public void processFile(Reader reader, RuleSets ruleSets, RuleContext ctx,
SourceType sourceType) throws PMDException {
try {
SourceTypeHandler sourceTypeHandler = SourceTypeHandlerBroker.getVisitorsFactoryForSourceType(sourceType);
ctx.setSourceType(sourceType);
Parser parser = sourceTypeHandler.getParser();
parser.setExcludeMarker(excludeMarker);
long start = System.nanoTime();
CompilationUnit rootNode = (CompilationUnit) parser.parse(reader);
ctx.excludeLines(parser.getExcludeMap());
long end = System.nanoTime();
Benchmark.mark(Benchmark.TYPE_PARSER, end - start, 0);
start = System.nanoTime();
sourceTypeHandler.getSymbolFacade().start(rootNode);
end = System.nanoTime();
Benchmark.mark(Benchmark.TYPE_SYMBOL_TABLE, end - start, 0);
Language language = SourceTypeToRuleLanguageMapper.getMappedLanguage(sourceType);
if (ruleSets.usesDFA(language)) {
start = System.nanoTime();
sourceTypeHandler.getDataFlowFacade().start(rootNode);
end = System.nanoTime();
Benchmark.mark(Benchmark.TYPE_DFA, end - start, 0);
}
if (ruleSets.usesTypeResolution(language)) {
start = System.nanoTime();
sourceTypeHandler.getTypeResolutionFacade().start(rootNode);
end = System.nanoTime();
Benchmark.mark(Benchmark.TYPE_TYPE_RESOLUTION, end - start, 0);
}
List<CompilationUnit> acus = new ArrayList<CompilationUnit>();
acus.add(rootNode);
ruleSets.apply(acus, ctx, language);
} catch (ParseException pe) {
throw new PMDException("Error while parsing "
+ ctx.getSourceCodeFilename(), pe);
} catch (Exception e) {
throw new PMDException("Error while processing "
+ ctx.getSourceCodeFilename(), e);
} finally {
try {
reader.close();
} catch (IOException e) {
throw new PMDException("Error while closing "
+ ctx.getSourceCodeFilename(), e);
}
}
}
/**
* Get the SourceType of the source file with given name. This depends on the fileName
* extension, and the java version.
* <p/>
* For compatibility with older code that does not always pass in a correct filename,
* unrecognized files are assumed to be java files.
*
* @param fileName Name of the file, can be absolute, or simple.
* @return the SourceType
*/
private SourceType getSourceTypeOfFile(String fileName) {
SourceType sourceType = sourceTypeDiscoverer.getSourceTypeOfFile(fileName);
if (sourceType == null) {
// For compatibility with older code that does not always pass in
// a correct filename.
sourceType = sourceTypeDiscoverer.getSourceTypeOfJavaFiles();
}
return sourceType;
}
/**
* Processes the file read by the reader agains the rule set.
*
* @param reader input stream reader
* @param ruleSet set of rules to process against the file
* @param ctx context in which PMD is operating. This contains the Renderer and
* whatnot
* @throws PMDException if the input could not be parsed or processed
*/
public void processFile(Reader reader, RuleSet ruleSet, RuleContext ctx)
throws PMDException {
processFile(reader, new RuleSets(ruleSet), ctx);
}
/**
* Processes the input stream agains a rule set using the given input encoding.
*
* @param fileContents an input stream to analyze
* @param encoding input stream's encoding
* @param ruleSet set of rules to process against the file
* @param ctx context in which PMD is operating. This contains the Report and whatnot
* @throws PMDException if the input encoding is unsupported or the input stream could
* not be parsed
* @see #processFile(Reader, RuleSet, RuleContext)
*/
public void processFile(InputStream fileContents, String encoding,
RuleSet ruleSet, RuleContext ctx) throws PMDException {
try {
processFile(new InputStreamReader(fileContents, encoding), ruleSet, ctx);
} catch (UnsupportedEncodingException uee) {
throw new PMDException("Unsupported encoding exception: "
+ uee.getMessage());
}
}
/**
* Processes the input stream agains a rule set using the given input encoding.
*
* @param fileContents an input stream to analyze
* @param encoding input stream's encoding
* @param ruleSets set of rules to process against the file
* @param ctx context in which PMD is operating. This contains the Report and whatnot
* @throws PMDException if the input encoding is unsupported or the input stream could
* not be parsed
* @see #processFile(Reader, RuleSet, RuleContext)
*/
public void processFile(InputStream fileContents, String encoding,
RuleSets ruleSets, RuleContext ctx) throws PMDException {
try {
processFile(new InputStreamReader(fileContents, encoding), ruleSets, ctx);
} catch (UnsupportedEncodingException uee) {
throw new PMDException("Unsupported encoding exception: "
+ uee.getMessage());
}
}
/**
* Processes the input stream against a rule set assuming the platform character set.
*
* @param fileContents input stream to check
* @param ruleSet the set of rules to process against the source code
* @param ctx the context in which PMD is operating. This contains the Report and
* whatnot
* @throws PMDException if the input encoding is unsupported or the input input stream
* could not be parsed
* @see #processFile(InputStream, String, RuleSet, RuleContext)
*/
public void processFile(InputStream fileContents, RuleSet ruleSet,
RuleContext ctx) throws PMDException {
processFile(fileContents, System.getProperty("file.encoding"), ruleSet, ctx);
}
public void setExcludeMarker(String marker) {
this.excludeMarker = marker;
}
/**
* Set the SourceType to be used for ".java" files.
*
* @param javaVersion the SourceType that indicates the java version
*/
public void setJavaVersion(SourceType javaVersion) {
sourceTypeDiscoverer.setSourceTypeOfJavaFiles(javaVersion);
}
public static void main(String[] args) {
long start = System.nanoTime();
CommandLineOptions opts = new CommandLineOptions(args);
initializeLogger(opts.debugEnabled());
long startFiles = System.nanoTime();
SourceFileSelector fileSelector = new SourceFileSelector();
fileSelector.setSelectJavaFiles(opts.isCheckJavaFiles());
fileSelector.setSelectJspFiles(opts.isCheckJspFiles());
List<DataSource> files;
if (opts.containsCommaSeparatedFileList()) {
files = collectFromCommaDelimitedString(opts.getInputPath(),
fileSelector);
} else {
files = collectFilesFromOneName(opts.getInputPath(), fileSelector);
}
long endFiles = System.nanoTime();
Benchmark.mark(Benchmark.TYPE_COLLECT_FILES, endFiles - startFiles, 0);
SourceType sourceType;
if (opts.getTargetJDK().equals("1.3")) {
LOG.fine("In JDK 1.3 mode");
sourceType = SourceType.JAVA_13;
} else if (opts.getTargetJDK().equals("1.5")) {
LOG.fine("In JDK 1.5 mode");
sourceType = SourceType.JAVA_15;
} else if (opts.getTargetJDK().equals("1.6")) {
LOG.fine("In JDK 1.6 mode");
sourceType = SourceType.JAVA_16;
} else {
LOG.fine("In JDK 1.4 mode");
sourceType = SourceType.JAVA_14;
}
long reportStart, reportEnd;
Renderer renderer;
Writer w = null;
reportStart = System.nanoTime();
try {
renderer = opts.createRenderer();
List<Renderer> renderers = new LinkedList<Renderer>();
renderers.add(renderer);
if (opts.getReportFile() != null) {
w = new BufferedWriter(new FileWriter(opts.getReportFile()));
} else {
w = new OutputStreamWriter(System.out);
}
renderer.setWriter(w);
renderer.start();
reportEnd = System.nanoTime();
Benchmark.mark(Benchmark.TYPE_REPORTING, reportEnd - reportStart, 0);
RuleContext ctx = new RuleContext();
try {
long startLoadRules = System.nanoTime();
RuleSetFactory ruleSetFactory = new RuleSetFactory();
ruleSetFactory.setMinimumPriority(opts.getMinPriority());
RuleSets rulesets = ruleSetFactory.createRuleSets(opts.getRulesets());
printRuleNamesInDebug(rulesets);
long endLoadRules = System.nanoTime();
Benchmark.mark(Benchmark.TYPE_LOAD_RULES, endLoadRules - startLoadRules, 0);
processFiles(opts.getCpus(), ruleSetFactory, sourceType, files, ctx, renderers,
opts.getRulesets(), opts.shortNamesEnabled(),
opts.getInputPath(), opts.getEncoding(), opts.getExcludeMarker());
} catch (RuleSetNotFoundException rsnfe) {
LOG.log(Level.SEVERE, "Ruleset not found", rsnfe);
System.out.println(opts.usage());
}
reportStart = System.nanoTime();
renderer.end();
w.write(EOL);
w.flush();
if (opts.getReportFile() != null) {
w.close();
w = null;
}
} catch (Exception e) {
LOG.severe(e.getMessage());
LOG.log(Level.FINE, "Exception during processing", e); //Only displayed when debug logging is on
LOG.info(opts.usage());
} finally {
if (opts.getReportFile() != null && w != null) {
try {
w.close();
} catch (Exception e) {
System.out.println(e.getMessage());
}
}
reportEnd = System.nanoTime();
Benchmark.mark(Benchmark.TYPE_REPORTING, reportEnd - reportStart, 0);
}
if (opts.benchmark()) {
long end = System.nanoTime();
Benchmark.mark(Benchmark.TYPE_TOTAL_PMD, end - start, 0);
System.err.println(Benchmark.report());
}
}
private static void initializeLogger(boolean debugEnabled) {
Logger rootLogger = Logger.getLogger("");
rootLogger.removeHandler(rootLogger.getHandlers()[0]);
rootLogger.addHandler(new ConsoleLogHandler());
if (debugEnabled) {
rootLogger.setLevel(Level.FINER);
LOG.setLevel(Level.FINER); //Need to do this, since the static logger has already been initialized at this point
} else {
//Info-level and up is normally logged, which matches Ant logging
rootLogger.setLevel(Level.INFO);
LOG.setLevel(Level.INFO);
}
}
private static class PmdRunnable extends PMD implements Callable<Report> {
private final ExecutorService executor;
private final DataSource dataSource;
private final String fileName;
private final String encoding;
private final String rulesets;
private final List<Renderer> renderers;
public PmdRunnable(ExecutorService executor, DataSource dataSource, String fileName, SourceType sourceType,
List<Renderer> renderers, String encoding, String rulesets, String excludeMarker) {
this.executor = executor;
this.dataSource = dataSource;
this.fileName = fileName;
this.encoding = encoding;
this.rulesets = rulesets;
this.renderers = renderers;
setJavaVersion(sourceType);
setExcludeMarker(excludeMarker);
}
public Report call() {
PmdThread thread = (PmdThread) Thread.currentThread();
RuleContext ctx = thread.getRuleContext();
RuleSets rs = thread.getRuleSets(rulesets);
Report report = new Report();
ctx.setReport(report);
ctx.setSourceCodeFilename(fileName);
if (LOG.isLoggable(Level.FINE)) {
LOG.fine("Processing " + ctx.getSourceCodeFilename());
}
for(Renderer r: renderers) {
r.startFileAnalysis(dataSource);
}
try {
InputStream stream = new BufferedInputStream(dataSource.getInputStream());
processFile(stream, encoding, rs, ctx);
} catch (PMDException pmde) {
LOG.log(Level.FINE, "Error while processing file", pmde.getReason());
report.addError(
new Report.ProcessingError(pmde.getMessage(),
fileName));
} catch (IOException ioe) {
// unexpected exception: log and stop executor service
LOG.log(Level.FINE, "IOException during processing", ioe);
report.addError(
new Report.ProcessingError(ioe.getMessage(),
fileName));
executor.shutdownNow();
} catch (RuntimeException re) {
// unexpected exception: log and stop executor service
LOG.log(Level.FINE, "RuntimeException during processing", re);
report.addError(
new Report.ProcessingError(re.getMessage(),
fileName));
executor.shutdownNow();
}
return report;
}
}
private static class PmdThreadFactory implements ThreadFactory {
public PmdThreadFactory(RuleSetFactory ruleSetFactory) {
this.ruleSetFactory = ruleSetFactory;
}
private final RuleSetFactory ruleSetFactory;
private final AtomicInteger counter = new AtomicInteger();
public Thread newThread(Runnable r) {
PmdThread t = new PmdThread(counter.incrementAndGet(), r, ruleSetFactory);
threadList.add(t);
return t;
}
public List<PmdThread> threadList = Collections.synchronizedList(new LinkedList<PmdThread>());
}
private static class PmdThread extends Thread {
public PmdThread(int id, Runnable r, RuleSetFactory ruleSetFactory) {
super(r, "PmdThread " + id);
this.id = id;
context = new RuleContext();
this.ruleSetFactory = ruleSetFactory;
}
private int id;
private RuleContext context;
private RuleSets rulesets;
private RuleSetFactory ruleSetFactory;
public RuleContext getRuleContext() {
return context;
}
public RuleSets getRuleSets(String rsList) {
if (rulesets == null) {
try {
rulesets = ruleSetFactory.createRuleSets(rsList);
} catch (Exception e) {
e.printStackTrace();
}
}
return rulesets;
}
public String toString() {
return "PmdThread " + id;
}
}
/**
* Do we have proper permissions to use multithreading?
*/
private static final boolean mtSupported;
static {
boolean error = false;
try {
/*
* ant task ran from Eclipse with jdk 1.5.0 raises an AccessControlException
* when shutdown is called. Standalone pmd or ant from command line are fine.
*
* With jdk 1.6.0, ant task from Eclipse also works.
*/
ExecutorService executor = Executors.newFixedThreadPool(1);
executor.shutdown();
} catch (RuntimeException e) {
error = true;
}
mtSupported = !error;
}
/**
* Run PMD on a list of files using multiple threads.
*
* @throws IOException If one of the files could not be read
*/
public static void processFiles(int threadCount, RuleSetFactory ruleSetFactory, SourceType sourceType, List<DataSource> files, RuleContext ctx,
List<Renderer> renderers, String rulesets, final boolean shortNamesEnabled, final String inputPath,
String encoding, String excludeMarker) {
/*
* Check if multithreaded is supported.
* ExecutorService can also be disabled if threadCount is not positive, e.g. using the
* "-cpus 0" command line option.
*/
boolean useMT = mtSupported && (threadCount > 0);
Collections.sort(files, new Comparator<DataSource>() {
public int compare(DataSource d1,DataSource d2) {
String s1 = d1.getNiceFileName(shortNamesEnabled, inputPath);
String s2 = d2.getNiceFileName(shortNamesEnabled, inputPath);
return s1.compareTo(s2);
}
});
if (useMT) {
PmdThreadFactory factory = new PmdThreadFactory(ruleSetFactory);
ExecutorService executor = Executors.newFixedThreadPool(threadCount, factory);
List<Future<Report>> tasks = new LinkedList<Future<Report>>();
for (DataSource dataSource:files) {
String niceFileName = dataSource.getNiceFileName(shortNamesEnabled,
inputPath);
PmdRunnable r = new PmdRunnable(executor, dataSource, niceFileName, sourceType, renderers,
encoding, rulesets, excludeMarker);
Future<Report> future = executor.submit(r);
tasks.add(future);
}
executor.shutdown();
while (!tasks.isEmpty()) {
Future<Report> future = tasks.remove(0);
Report report = null;
try {
report = future.get();
} catch (InterruptedException ie) {
Thread.currentThread().interrupt();
future.cancel(true);
} catch (ExecutionException ee) {
Throwable t = ee.getCause();
if (t instanceof RuntimeException) {
throw (RuntimeException) t;
} else if (t instanceof Error) {
throw (Error) t;
} else {
throw new IllegalStateException("PmdRunnable exception", t);
}
}
try {
long start = System.nanoTime();
for (Renderer r: renderers) {
r.renderFileReport(report);
}
long end = System.nanoTime();
Benchmark.mark(Benchmark.TYPE_REPORTING, end - start, 1);
} catch (IOException ioe) {
}
}
} else {
// single threaded execution
PMD pmd = new PMD();
pmd.setJavaVersion(sourceType);
pmd.setExcludeMarker(excludeMarker);
RuleSets rs = null;
try {
rs = ruleSetFactory.createRuleSets(rulesets);
} catch (RuleSetNotFoundException rsnfe) {
// should not happen: parent already created a ruleset
}
for (DataSource dataSource: files) {
String niceFileName = dataSource.getNiceFileName(shortNamesEnabled,
inputPath);
Report report = new Report();
ctx.setReport(report);
ctx.setSourceCodeFilename(niceFileName);
if (LOG.isLoggable(Level.FINE)) {
LOG.fine("Processing " + ctx.getSourceCodeFilename());
}
for(Renderer r: renderers) {
r.startFileAnalysis(dataSource);
}
try {
InputStream stream = new BufferedInputStream(dataSource.getInputStream());
pmd.processFile(stream, encoding, rs, ctx);
} catch (PMDException pmde) {
LOG.log(Level.FINE, "Error while processing file", pmde.getReason());
report.addError(
new Report.ProcessingError(pmde.getMessage(),
niceFileName));
} catch (IOException ioe) {
// unexpected exception: log and stop executor service
LOG.log(Level.FINE, "Unable to read source file", ioe);
report.addError(
new Report.ProcessingError(ioe.getMessage(),
niceFileName));
} catch (RuntimeException re) {
// unexpected exception: log and stop executor service
LOG.log(Level.FINE, "RuntimeException while processing file", re);
report.addError(
new Report.ProcessingError(re.getMessage(),
niceFileName));
}
try {
long start = System.nanoTime();
for (Renderer r: renderers) {
r.renderFileReport(report);
}
long end = System.nanoTime();
Benchmark.mark(Benchmark.TYPE_REPORTING, end - start, 1);
} catch (IOException ioe) {
}
}
}
}
/**
* Run PMD on a list of files.
*
* @param files the List of DataSource instances.
* @param ctx the context in which PMD is operating. This contains the Report and
* whatnot
* @param rulesets the RuleSets
* @param debugEnabled
* @param shortNamesEnabled
* @param inputPath
* @param encoding
* @throws IOException If one of the files could not be read
*/
public void processFiles(List<DataSource> files, RuleContext ctx, RuleSets rulesets,
boolean debugEnabled, boolean shortNamesEnabled, String inputPath,
String encoding) throws IOException {
for (DataSource dataSource: files) {
String niceFileName = dataSource.getNiceFileName(shortNamesEnabled,
inputPath);
ctx.setSourceCodeFilename(niceFileName);
LOG.fine("Processing " + ctx.getSourceCodeFilename());
try {
InputStream stream = new BufferedInputStream(dataSource
.getInputStream());
processFile(stream, encoding, rulesets, ctx);
} catch (PMDException pmde) {
LOG.log(Level.FINE, "Error while processing files", pmde.getReason());
ctx.getReport().addError(new Report.ProcessingError(pmde.getMessage(), niceFileName));
}
}
}
/**
* If in debug modus, print the names of the rules.
*
* @param rulesets the RuleSets to print
*/
private static void printRuleNamesInDebug(RuleSets rulesets) {
if (LOG.isLoggable(Level.FINER)) {
for (Rule r: rulesets.getAllRules()) {
LOG.finer("Loaded rule " + r.getName());
}
}
}
/**
* Collects the given file into a list.
*
* @param inputFileName a file name
* @param fileSelector Filtering of wanted source files
* @return the list of files collected from the <code>inputFileName</code>
* @see #collect(String, SourceFileSelector)
*/
private static List<DataSource> collectFilesFromOneName(String inputFileName,
SourceFileSelector fileSelector) {
return collect(inputFileName, fileSelector);
}
/**
* Collects the files from the given comma-separated list.
*
* @param fileList comma-separated list of filenames
* @param fileSelector Filtering of wanted source files
* @return list of files collected from the <code>fileList</code>
*/
private static List<DataSource> collectFromCommaDelimitedString(String fileList,
SourceFileSelector fileSelector) {
List<DataSource> files = new ArrayList<DataSource>();
for (StringTokenizer st = new StringTokenizer(fileList, ","); st
.hasMoreTokens();) {
files.addAll(collect(st.nextToken(), fileSelector));
}
return files;
}
/**
* Collects the files from the given <code>filename</code>.
*
* @param filename the source from which to collect files
* @param fileSelector Filtering of wanted source files
* @return a list of files found at the given <code>filename</code>
* @throws RuntimeException if <code>filename</code> is not found
*/
private static List<DataSource> collect(String filename, SourceFileSelector fileSelector) {
File inputFile = new File(filename);
if (!inputFile.exists()) {
throw new RuntimeException("File " + inputFile.getName()
+ " doesn't exist");
}
List<DataSource> dataSources = new ArrayList<DataSource>();
if (!inputFile.isDirectory()) {
if (filename.endsWith(".zip") || filename.endsWith(".jar")) {
ZipFile zipFile;
try {
zipFile = new ZipFile(inputFile);
Enumeration e = zipFile.entries();
while (e.hasMoreElements()) {
ZipEntry zipEntry = (ZipEntry) e.nextElement();
if (fileSelector.isWantedFile(zipEntry.getName())) {
dataSources.add(new ZipDataSource(zipFile, zipEntry));
}
}
} catch (IOException ze) {
throw new RuntimeException("Zip file " + inputFile.getName()
+ " can't be opened");
}
} else {
dataSources.add(new FileDataSource(inputFile));
}
} else {
FileFinder finder = new FileFinder();
List<File> files = finder.findFilesFrom(inputFile.getAbsolutePath(),
new SourceFileOrDirectoryFilter(fileSelector), true);
for (File f: files) {
dataSources.add(new FileDataSource(f));
}
}
return dataSources;
}
}
The table below shows all metrics for PMD.java.



