package dotty
package tools
package dotc
import java.io.{ File => JFile }
import scala.io.Source
import core.Contexts._
import reporting.{ Reporter, UniqueMessagePositions, HideNonSensicalMessages, MessageRendering }
import reporting.diagnostic.MessageContainer
import interfaces.Diagnostic.ERROR
import java.lang.reflect.InvocationTargetException
import java.nio.file.StandardCopyOption.REPLACE_EXISTING
import java.nio.file.{ Files, Path, Paths }
import java.util.concurrent.{ Executors => JExecutors, TimeUnit }
import scala.util.control.NonFatal
import java.util.HashMap
trait ParallelTesting {
private abstract class CompileRun(targetDirs: List[JFile], fromDir: String, flags: Array[String]) {
val totalTargets = targetDirs.length
private[this] var _errors = 0
def errors: Int = synchronized { _errors }
private[this] var _targetsCompiled = 0
private def targetsCompiled: Int = synchronized { _targetsCompiled }
protected final def completeCompilation(newErrors: Int) = synchronized {
_targetsCompiled += 1
_errors += newErrors
}
private[this] var _failed = false
final protected[this] def fail(): Unit = synchronized { _failed = true }
def didFail: Boolean = _failed
private def statusRunner: Runnable = new Runnable {
def run(): Unit = {
val start = System.currentTimeMillis
var tCompiled = targetsCompiled
while (tCompiled < totalTargets) {
val timestamp = (System.currentTimeMillis - start) / 1000
val progress = (tCompiled.toDouble / totalTargets * 40).toInt
print(
s"Compiling tests in $fromDir [" +
("=" * (math.max(progress - 1, 0))) +
(if (progress > 0) ">" else "") +
(" " * (39 - progress)) +
s"] $tCompiled/$totalTargets, ${timestamp}s, errors: $errors\r"
)
Thread.sleep(50)
tCompiled = targetsCompiled
}
// println, otherwise no newline and cursor at start of line
println(
s"Compiled tests in $fromDir " +
s"[=======================================] $totalTargets/$totalTargets, " +
s"${(System.currentTimeMillis - start) / 1000}s, errors: $errors "
)
}
}
protected def compilationRunnable(dir: JFile): Runnable
private[ParallelTesting] def execute(): this.type = {
assert(_targetsCompiled == 0, "not allowed to re-use a `CompileRun`")
val pool = JExecutors.newWorkStealingPool()
pool.submit(statusRunner)
targetDirs.foreach { dir =>
pool.submit(compilationRunnable(dir))
}
pool.shutdown()
pool.awaitTermination(10, TimeUnit.MINUTES)
this
}
}
private final class PosCompileRun(targetDirs: List[JFile], fromDir: String, flags: Array[String])
extends CompileRun(targetDirs, fromDir, flags) {
protected def compilationRunnable(dir: JFile): Runnable = new Runnable {
def run(): Unit =
try {
val sourceFiles = dir.listFiles.filter(f => f.getName.endsWith(".scala") || f.getName.endsWith(".java"))
val reporter = compile(sourceFiles, flags ++ Array("-d", dir.getAbsolutePath), false)
completeCompilation(reporter.errorCount)
}
catch {
case NonFatal(e) => {
// if an exception is thrown during compilation, the complete test
// run should fail
fail()
System.err.println(s"\n${e.getMessage}\n")
completeCompilation(1)
throw e
}
}
}
}
private final class RunCompileRun(targetDirs: List[JFile], fromDir: String, flags: Array[String])
extends CompileRun(targetDirs, fromDir, flags) {
private def verifyOutput(checkFile: JFile, dir: JFile) = try {
// Do classloading magic and running here:
import java.net.{ URL, URLClassLoader }
import java.io.ByteArrayOutputStream
val ucl = new URLClassLoader(Array(dir.toURI.toURL))
val cls = ucl.loadClass("Test")
val meth = cls.getMethod("main", classOf[Array[String]])
val printStream = new ByteArrayOutputStream
Console.withOut(printStream) {
meth.invoke(null, Array("jvm")) // partest passes at least "jvm" as an arg
}
val outputLines = printStream.toString("utf-8").lines.toArray
val checkLines = Source.fromFile(checkFile).getLines.toArray
def linesMatch =
outputLines
.zip(checkLines)
.forall { case (x, y) => x == y }
if (outputLines.length != checkLines.length || !linesMatch) {
System.err.println {
s"\nOutput from run test '$dir' did not match expected, output:\n${outputLines.mkString("\n")}"
}
fail()
}
}
catch {
case _: NoSuchMethodException =>
System.err.println(s"\ntest in '$dir' did not contain a main method")
fail()
case _: ClassNotFoundException =>
System.err.println(s"\ntest in '$dir' did was not contained within a `Test` object")
fail()
case _: InvocationTargetException =>
System.err.println(s"\nTest in '$dir' might be using args(X) where X > 0")
fail()
}
protected def compilationRunnable(dir: JFile): Runnable = new Runnable {
def run(): Unit =
try {
val sourceFiles = dir.listFiles.filter(f => f.getName.endsWith(".scala") || f.getName.endsWith(".java"))
val checkFile = dir.listFiles.find(_.getName.endsWith(".check"))
val reporter = compile(sourceFiles, flags ++ Array("-d", dir.getAbsolutePath), false)
completeCompilation(reporter.errorCount)
if (reporter.errorCount == 0 && checkFile.isDefined) verifyOutput(checkFile.get, dir)
else if (reporter.errorCount > 0) {
System.err.println(s"\nCompilation failed for: '$dir'")
fail()
}
}
catch {
case NonFatal(e) => {
System.err.println(s"\n$e\n${e.getMessage}")
completeCompilation(1)
fail()
throw e
}
}
}
}
private final class NegCompileRun(targetDirs: List[JFile], fromDir: String, flags: Array[String])
extends CompileRun(targetDirs, fromDir, flags) {
protected def compilationRunnable(dir: JFile): Runnable = new Runnable {
def run(): Unit =
try {
val sourceFiles = dir.listFiles.filter(f => f.getName.endsWith(".scala") || f.getName.endsWith(".java"))
// In neg-tests we allow two types of error annotations,
// "nopos-error" which doesn't care about position and "error" which
// has to be annotated on the correct line number.
//
// We collect these in a map `"file:row" -> numberOfErrors`, for
// nopos errors we save them in `"file" -> numberOfNoPosErrors`
val errorMap = new HashMap[String, Integer]()
var expectedErrors = 0
dir.listFiles.filter(_.getName.endsWith(".scala")).foreach { file =>
Source.fromFile(file).getLines.zipWithIndex.foreach { case (line, lineNbr) =>
val errors = line.sliding("// error".length).count(_.mkString == "// error")
if (errors > 0)
errorMap.put(s"${file.getAbsolutePath}:${lineNbr}", errors)
val noposErrors = line.sliding("// nopos-error".length).count(_.mkString == "// nopos-error")
if (noposErrors > 0)
errorMap.put(file.getAbsolutePath, noposErrors)
expectedErrors += noposErrors + errors
}
}
val reporter = compile(sourceFiles, flags ++ Array("-d", dir.getAbsolutePath), true)
val actualErrors = reporter.errorCount
if (expectedErrors != actualErrors) {
System.err.println {
s"\nWrong number of errors encountered when compiling $dir, expected: $expectedErrors, actual: $actualErrors\n"
}
fail()
}
else if (
// Here we check that there is a correpsonding error reported for
// each annotation
!reporter.errors.forall { error =>
val fileName = error.pos.source.file.toString
val fileAndRow = s"$fileName:${error.pos.line}"
val rowErrors = errorMap.get(fileAndRow)
lazy val noposErrors = errorMap.get(fileName)
if (rowErrors ne null) {
if (rowErrors == 1) errorMap.remove(fileAndRow)
else errorMap.put(fileAndRow, rowErrors - 1)
true
}
else if (noposErrors ne null) {
if (noposErrors == 1) errorMap.remove(fileName)
else errorMap.put(fileName, noposErrors - 1)
true
}
else {
System.err.println {
s"Error reported in ${error.pos}, but no annotation found"
}
false
}
}
) {
System.err.println {
s"\nErrors found on incorrect row numbers when compiling $dir"
}
fail()
}
else if (!errorMap.isEmpty) {
System.err.println {
s"\nError annotation(s) have {<error position>=<unreported error>}: $errorMap"
}
fail()
}
completeCompilation(actualErrors)
}
catch {
case NonFatal(e) => {
System.err.println(s"\n${e.getMessage}\n")
completeCompilation(1)
throw e
}
}
}
}
private class DaftReporter(suppress: Boolean)
extends Reporter with UniqueMessagePositions with HideNonSensicalMessages
with MessageRendering {
private var _errors: List[MessageContainer] = Nil
def errors = _errors
override def doReport(m: MessageContainer)(implicit ctx: Context) = {
if (m.level == ERROR) {
_errors = m :: _errors
if (!suppress) System.err.println(messageAndPos(m.contained, m.pos, diagnosticLevel(m)))
}
}
}
private def compile(files0: Array[JFile], flags: Array[String], suppressErrors: Boolean): DaftReporter = {
def flattenFiles(f: JFile): Array[JFile] =
if (f.isDirectory) f.listFiles.flatMap(flattenFiles)
else Array(f)
val files: Array[JFile] = files0.flatMap(flattenFiles)
def findJarFromRuntime(partialName: String) = {
val urls = ClassLoader.getSystemClassLoader.asInstanceOf[java.net.URLClassLoader].getURLs.map(_.getFile.toString)
urls.find(_.contains(partialName)).getOrElse {
throw new java.io.FileNotFoundException(
s"""Unable to locate $partialName on classpath:\n${urls.toList.mkString("\n")}"""
)
}
}
def compileWithJavac(fs: Array[String]) = if (fs.nonEmpty) {
val scalaLib = findJarFromRuntime("scala-library")
val fullArgs = Array(
"javac",
"-classpath",
s".:$scalaLib"
) ++ flags.takeRight(2) ++ fs
assert(Runtime.getRuntime.exec(fullArgs).waitFor() == 0, s"java compilation failed for ${fs.mkString(", ")}")
}
compileWithJavac(files.filter(_.getName.endsWith(".java")).map(_.getAbsolutePath))
val reporter = new DaftReporter(suppress = suppressErrors)
val driver = new Driver { def newCompiler(implicit ctx: Context) = new Compiler }
driver.process(flags ++ files.map(_.getAbsolutePath), reporter = reporter)
reporter
}
class CompilationTest(targetDirs: List[JFile], fromDir: String, flags: Array[String]) {
def pos: Unit = {
val run = new PosCompileRun(targetDirs, fromDir, flags).execute()
assert(run.errors == 0, s"Expected no errors when compiling $fromDir")
}
def neg: Unit = assert(
!(new NegCompileRun(targetDirs, fromDir, flags).execute().didFail),
s"Wrong number of errors encountered when compiling $fromDir"
)
def run: Unit = assert(
!(new RunCompileRun(targetDirs, fromDir, flags).execute().didFail),
s"Run tests failed for test $fromDir"
)
}
private def toCompilerDirFromDir(d: JFile, sourceDir: JFile, outDir: String): JFile = {
val targetDir = new JFile(outDir + s"${sourceDir.getName}/${d.getName}")
// create if not exists
targetDir.mkdirs()
d.listFiles.foreach(copyToDir(targetDir, _))
targetDir
}
private def toCompilerDirFromFile(file: JFile, sourceDir: JFile, outDir: String): JFile = {
val uniqueSubdir = file.getName.substring(0, file.getName.lastIndexOf('.'))
val targetDir = new JFile(outDir + s"${sourceDir.getName}/$uniqueSubdir")
if (file.getName.endsWith(".java") || file.getName.endsWith(".scala")) {
// create if not exists
targetDir.mkdirs()
// copy file to dir:
copyToDir(targetDir, file)
// copy checkfile if it exists
val checkFile = new JFile(file.getAbsolutePath.substring(0, file.getAbsolutePath.lastIndexOf('.')) + ".check")
if (checkFile.exists) copyToDir(targetDir, checkFile)
}
targetDir
}
private def copyToDir(dir: JFile, file: JFile): Unit = {
val target = Paths.get(dir.getAbsolutePath, file.getName)
Files.copy(file.toPath, target, REPLACE_EXISTING).toFile
}
private def requirements(f: String, sourceDir: JFile, outDir: String): Unit = {
require(sourceDir.isDirectory && sourceDir.exists, "passed non-directory to `compileFilesInDir`")
require(outDir.last == '/', "please specify an `outDir` with a trailing slash")
}
private def compilationTargets(sourceDir: JFile): (List[JFile], List[JFile]) =
sourceDir.listFiles.foldLeft((List.empty[JFile], List.empty[JFile])) { case ((dirs, files), f) =>
if (f.isDirectory) (f :: dirs, files)
else if (f.getName.endsWith(".check")) (dirs, files)
else (dirs, f :: files)
}
def compileFile(f: String, flags: Array[String])(implicit outDirectory: String): CompilationTest = {
// each calling method gets its own unique output directory, in which we
// place the dir being compiled:
val callingMethod = Thread.currentThread.getStackTrace.apply(3).getMethodName
val outDir = outDirectory + callingMethod + "/"
val sourceFile = new JFile(f)
val parent = sourceFile.getParentFile
require(
sourceFile.exists && !sourceFile.isDirectory &&
(parent ne null) && parent.exists && parent.isDirectory,
s"Source file: $f, didn't exist"
)
new CompilationTest(toCompilerDirFromFile(sourceFile, parent, outDir) :: Nil, f, flags)
}
def compileFilesInDir(f: String, flags: Array[String])(implicit outDirectory: String): CompilationTest = {
// each calling method gets its own unique output directory, in which we
// place the dir being compiled:
val callingMethod = Thread.currentThread.getStackTrace.apply(3).getMethodName
val outDir = outDirectory + callingMethod + "/"
val sourceDir = new JFile(f)
requirements(f, sourceDir, outDir)
val (dirs, files) = compilationTargets(sourceDir)
// Directories in which to compile all containing files with `flags`:
val dirsToCompile =
files.map(toCompilerDirFromFile(_, sourceDir, outDir)) ++
dirs.map(toCompilerDirFromDir(_, sourceDir, outDir))
// Create a CompilationTest and let the user decide whether to execute a pos or a neg test
new CompilationTest(dirsToCompile, f, flags)
}
def compileShallowFilesInDir(f: String, flags: Array[String])(implicit outDirectory: String): CompilationTest = {
// each calling method gets its own unique output directory, in which we
// place the dir being compiled:
val callingMethod = Thread.currentThread.getStackTrace.apply(3).getMethodName
val outDir = outDirectory + callingMethod + "/"
val sourceDir = new JFile(f)
requirements(f, sourceDir, outDir)
val (_, files) = compilationTargets(sourceDir)
// Create a CompilationTest and let the user decide whether to execute a pos or a neg test
new CompilationTest(
files.map(toCompilerDirFromFile(_, sourceDir, outDir)),
f,
flags
)
}
}