add #Entrypoints in csv file

Author: yiming-tang-cs

edu.cuny.hunter.streamrefactoring.core/src/edu/cuny/hunter/streamrefactoring/core/analysis/StreamAnalyzer.java

@@ -53,6 +53,8 @@ private static void addImplicitEntryPoints(Collection<Entrypoint> target, Iterab
 	private boolean findImplicitTestEntryPoints;
 
 	private Set<Stream> streamSet = new HashSet<>();
+	
+	private Set<Entrypoint> entryPoints = new HashSet<>();
 
 	public StreamAnalyzer() {
 		this(false);
@@ -194,6 +196,8 @@ protected void buildCallGraph(EclipseProjectAnalysisEngine<InstanceKey> engine)
 			// TODO: Can I slice the graph so that only nodes relevant to the
 			// instance in question are present?
 			this.enginesWithBuiltCallGraphs.add(engine);
+
+			setEntryPoints(entryPoints);
 		}
 	}
 
@@ -248,4 +252,13 @@ public boolean visit(MethodInvocation node) {
 
 		return super.visit(node);
 	}
+
+	protected void setEntryPoints(Set<Entrypoint> entryPoints) {
+		this.entryPoints = entryPoints;
+	}
+	
+	public Set<Entrypoint> getEntryPoints() {
+		return this.entryPoints;
+	}
+
 }

edu.cuny.hunter.streamrefactoring.core/src/edu/cuny/hunter/streamrefactoring/core/refactorings/ConvertToParallelStreamRefactoringProcessor.java

@@ -5,6 +5,7 @@
 
 import java.text.MessageFormat;
 import java.util.HashMap;
+import java.util.HashSet;
 import java.util.Map;
 import java.util.Optional;
 import java.util.Set;
@@ -49,6 +50,8 @@
 import org.eclipse.ltk.core.refactoring.participants.SharableParticipants;
 import org.osgi.framework.FrameworkUtil;
 
+import com.ibm.wala.ipa.callgraph.Entrypoint;
+
 import edu.cuny.hunter.streamrefactoring.core.analysis.PreconditionFailure;
 import edu.cuny.hunter.streamrefactoring.core.analysis.Stream;
 import edu.cuny.hunter.streamrefactoring.core.analysis.StreamAnalyzer;
@@ -129,6 +132,8 @@ public static void setLoggingLevel(int level) {
 	private IJavaProject[] javaProjects;
 
 	private Set<Stream> streamSet;
+	
+	private Set<Entrypoint> entryPoints = new HashSet<>();
 
 	private boolean useImplicitEntrypoints = true;
 
@@ -208,6 +213,9 @@ public RefactoringStatus checkFinalConditions(final IProgressMonitor monitor, fi
 			RefactoringStatus collectedStatus = getStreamSet().stream().map(Stream::getStatus)
 					.collect(() -> new RefactoringStatus(), (a, b) -> a.merge(b), (a, b) -> a.merge(b));
 			status.merge(collectedStatus);
+			
+			// set entry points
+		    setEntryPoints(analyzer.getEntryPoints());
 
 			// if there are no fatal errors.
 			if (!status.hasFatalError()) {
@@ -232,6 +240,14 @@ public RefactoringStatus checkFinalConditions(final IProgressMonitor monitor, fi
 		}
 	}
 
+	private void setEntryPoints(Set<Entrypoint> entryPoints) {
+		this.entryPoints = entryPoints;
+	}
+	
+	public Set<Entrypoint> getEntryPoints() {
+		return this.entryPoints;
+	}
+
 	private boolean getUseImplicitEntrypoints() {
 		return this.useImplicitEntrypoints;
 	}

edu.cuny.hunter.streamrefactoring.eval/META-INF/MANIFEST.MF

@@ -22,6 +22,8 @@ Export-Package: edu.cuny.hunter.streamrefactoring.eval.handlers,
  edu.cuny.hunter.streamrefactoring.eval.utils,
  edu.cuny.hunter.streamrefactoring.ui.plugins
 Import-Package: com.google.common.io,
+ com.ibm.wala.classLoader,
+ com.ibm.wala.ipa.callgraph,
  edu.cuny.hunter.streamrefactoring.core.analysis,
  edu.cuny.hunter.streamrefactoring.core.refactorings,
  edu.cuny.hunter.streamrefactoring.core.utils,

edu.cuny.hunter.streamrefactoring.eval/src/edu/cuny/hunter/streamrefactoring/eval/handlers/EvaluateConvertToParallelStreamRefactoringHandler.java

@@ -51,6 +51,7 @@
 
 import com.google.common.collect.Sets;
 import com.google.common.collect.Sets.SetView;
+import com.ibm.wala.ipa.callgraph.Entrypoint;
 
 import edu.cuny.hunter.streamrefactoring.core.analysis.PreconditionFailure;
 import edu.cuny.hunter.streamrefactoring.core.analysis.PreconditionSuccess;
@@ -162,6 +163,7 @@ public Object execute(ExecutionEvent event) throws ExecutionException {
 			CSVPrinter streamActionsPrinter = null;
 			CSVPrinter streamExecutionModePrinter = null;
 			CSVPrinter streamOrderingPrinter = null;
+			CSVPrinter entryPointsPrinter = null;
 
 			ConvertToParallelStreamRefactoringProcessor processor = null;
 
@@ -175,8 +177,9 @@ public Object execute(ExecutionEvent event) throws ExecutionException {
 
 				IJavaProject[] javaProjects = Util.getSelectedJavaProjectsFromEvent(event);
 
-				List<String> resultsHeader = new ArrayList<>(Arrays.asList("subject", "SLOC", "#streams",
-						"#optimization available streams", "#optimizable streams", "#failed preconditions"));
+				List<String> resultsHeader = new ArrayList<>(
+						Arrays.asList("subject", "SLOC", "#entrypoints", "#streams", "#optimization available streams",
+								"#optimizable streams", "#failed preconditions"));
 
 				for (Refactoring refactoring : Refactoring.values())
 					resultsHeader.add(refactoring.toString());
@@ -216,6 +219,9 @@ public Object execute(ExecutionEvent event) throws ExecutionException {
 
 				streamOrderingPrinter = createCSVPrinter("stream_orderings.csv", buildAttributeColumns("ordering"));
 
+				entryPointsPrinter = createCSVPrinter("entry_points.csv",
+						new String[] { "subject", "method", "type FQN" });
+
 				for (IJavaProject javaProject : javaProjects) {
 					if (!javaProject.isStructureKnown())
 						throw new IllegalStateException(
@@ -240,6 +246,15 @@ public Object execute(ExecutionEvent event) throws ExecutionException {
 					RefactoringStatus status = new ProcessorBasedRefactoring(processor)
 							.checkAllConditions(new NullProgressMonitor());
 					resultsTimeCollector.stop();
+					
+					// print entry points
+					Set<Entrypoint> entryPoints = processor.getEntryPoints();
+					resultsPrinter.print(entryPoints.size());
+
+					for (Entrypoint entryPoint : entryPoints) {
+						entryPointsPrinter.printRecord(javaProject.getElementName(),
+								entryPoint.getMethod().getSignature(), "! not implement now");
+					}
 
 					// #streams.
 					resultsPrinter.print(processor.getStreamSet().size());
@@ -414,6 +429,8 @@ public Object execute(ExecutionEvent event) throws ExecutionException {
 						streamExecutionModePrinter.close();
 					if (streamOrderingPrinter != null)
 						streamOrderingPrinter.close();
+					if (entryPointsPrinter != null)
+						entryPointsPrinter.close();
 
 					// clear cache.
 					if (processor != null)