Java 类org.gradle.api.internal.tasks.testing.TestClassRunInfo 实例源码

@Override
public void processTestClass(TestClassRunInfo testClass) {
    TestClassProcessor processor;
    if (processors.size() < maxProcessors) {
        processor = factory.create();
        Actor actor = actorFactory.createActor(processor);
        processor = actor.getProxy(TestClassProcessor.class);
        actors.add(actor);
        processors.add(processor);
        processor.startProcessing(resultProcessor);
    } else {
        processor = processors.get(pos);
        pos = (pos + 1) % processors.size();
    }
    processor.processTestClass(testClass);
}

@Override
public void processTestClass(TestClassRunInfo testClass) {
    int i = 0;
    RuntimeException exception = null;
    while (remoteProcessor == null && i < 10)
    {
        try
        {
            remoteProcessor = forkProcess();
            exception = null;
            break;
        }
        catch (RuntimeException e)
        {
            exception = e;
            i++;
        }
    }

    if (exception != null) throw exception;
    remoteProcessor.processTestClass(testClass);
}

@Override
public void processTestClass(TestClassRunInfo testClass) {
    if (processor == null) {
        processor = factory.create();
        processor.startProcessing(resultProcessor);
    }
    processor.processTestClass(testClass);
    testCount++;
    if (testCount == restartEvery) {
        endBatch();
    }
}

@Override
public void processTestClass(final TestClassRunInfo testClass) {
    Thread.currentThread().setName("Test worker");
    try {
        processor.processTestClass(testClass);
    } finally {
        // Clean the interrupted status
        Thread.interrupted();
    }
}

@Override
public void processTestClass(TestClassRunInfo testClass) {
    if (remoteProcessor == null) {
        workerCompletion = owner.operationStart();
        remoteProcessor = forkProcess();
    }

    remoteProcessor.processTestClass(testClass);
}

@Override
public void processTestClass(TestClassRunInfo testClass) {
    // TODO - do this inside some 'testng' suite, so that failures and logging are attached to 'testng' rather than some 'test worker'
    try {
        testClasses.add(applicationClassLoader.loadClass(testClass.getTestClassName()));
    } catch (Throwable e) {
        throw new GradleException(String.format("Could not load test class '%s'.", testClass.getTestClassName()), e);
    }
}

private void filenameScan() {
    candidateClassFiles.visit(new ClassFileVisitor() {
        public void visitClassFile(FileVisitDetails fileDetails) {
            String className = fileDetails.getRelativePath().getPathString().replaceAll("\\.class", "").replace('/', '.');
            TestClassRunInfo testClass = new DefaultTestClassRunInfo(className);
            testClassProcessor.processTestClass(testClass);
        }
    });
}

@Override
public void run() {
    this.candidateClassFiles.visit(new ClassFileVisitor() {

        @Override
        public void visitClassFile(FileVisitDetails fileDetails) {
            String className = fileDetails.getRelativePath().getPathString().replaceAll("\\.class", "").replace('/', '.');
            TestClassRunInfo testClass = new DefaultTestClassRunInfo(className);
            EclipsePluginTestClassScanner.this.testClassProcessor.processTestClass(testClass);
        }
    });
}

public void processTestClass(TestClassRunInfo testClass) {
    try {
        testClasses.add(applicationClassLoader.loadClass(testClass.getTestClassName()));
    } catch (Throwable e) {
        throw new GradleException(String.format("Could not load test class '%s'.", testClass.getTestClassName()), e);
    }
}

public void processTestClass(TestClassRunInfo testClass) {
    if (processor == null) {
        processor = factory.create();
        processor.startProcessing(resultProcessor);
    }
    processor.processTestClass(testClass);
    testCount++;
    if (testCount == restartEvery) {
        endBatch();
    }
}

public void processTestClass(TestClassRunInfo testClass) {
    TestClassProcessor processor;
    if (processors.size() < maxProcessors) {
        processor = factory.create();
        Actor actor = actorFactory.createActor(processor);
        processor = actor.getProxy(TestClassProcessor.class);
        actors.add(actor);
        processors.add(processor);
        processor.startProcessing(resultProcessor);
    } else {
        processor = processors.get(pos);
        pos = (pos + 1) % processors.size();
    }
    processor.processTestClass(testClass);
}

private void filenameScan() {
    candidateClassFiles.visit(new ClassFileVisitor() {
        public void visitClassFile(FileVisitDetails fileDetails) {
            String className = fileDetails.getRelativePath().getPathString().replaceAll("\\.class", "").replace('/', '.');
            TestClassRunInfo testClass = new DefaultTestClassRunInfo(className);
            testClassProcessor.processTestClass(testClass);
        }
    });
}

public void processTestClass(final TestClassRunInfo testClass) {
    Thread.currentThread().setName("Test worker");
    try {
        processor.processTestClass(testClass);
    } finally {
        // Clean the interrupted status
        Thread.interrupted();
    }
}

public void processTestClass(TestClassRunInfo testClass) {
    if (remoteProcessor == null) {
        remoteProcessor = forkProcess();
    }

    remoteProcessor.processTestClass(testClass);
}

public void processTestClass(TestClassRunInfo testClass) {
    try {
        testClasses.add(applicationClassLoader.loadClass(testClass.getTestClassName()));
    } catch (Throwable e) {
        throw new GradleException(String.format("Could not load test class '%s'.", testClass.getTestClassName()), e);
    }
}

public void processTestClass(TestClassRunInfo testClass) {
    if (processor == null) {
        processor = factory.create();
        processor.startProcessing(resultProcessor);
    }
    processor.processTestClass(testClass);
    testCount++;
    if (testCount == restartEvery) {
        endBatch();
    }
}

public void processTestClass(TestClassRunInfo testClass) {
    TestClassProcessor processor;
    if (processors.size() < maxProcessors) {
        processor = factory.create();
        Actor actor = actorFactory.createActor(processor);
        processor = actor.getProxy(TestClassProcessor.class);
        actors.add(actor);
        processors.add(processor);
        processor.startProcessing(resultProcessor);
    } else {
        processor = processors.get(pos);
        pos = (pos + 1) % processors.size();
    }
    processor.processTestClass(testClass);
}

private void filenameScan() {
    candidateClassFiles.visit(new ClassFileVisitor() {
        public void visitClassFile(FileVisitDetails fileDetails) {
            String className = fileDetails.getRelativePath().getPathString().replaceAll("\\.class", "").replace('/', '.');
            TestClassRunInfo testClass = new DefaultTestClassRunInfo(className);
            testClassProcessor.processTestClass(testClass);
        }
    });
}

public void processTestClass(final TestClassRunInfo testClass) {
    Thread.currentThread().setName("Test worker");
    try {
        processor.processTestClass(testClass);
    } finally {
        // Clean the interrupted status
        Thread.interrupted();
    }
}

public void processTestClass(TestClassRunInfo testClass) {
    if (remoteProcessor == null) {
        remoteProcessor = forkProcess();
    }

    remoteProcessor.processTestClass(testClass);
}

@Override
public void processTestClass(TestClassRunInfo testClass) {
    LOGGER.debug("Executing test class {}", testClass.getTestClassName());
    executer.execute(testClass.getTestClassName());
}

@Override
public void processTestClass(TestClassRunInfo testClassRunInfo) {
    this.classNames.add(testClassRunInfo.getTestClassName());
}

public void processTestClass(TestClassRunInfo testClass) {
    LOGGER.debug("Executing test class {}", testClass.getTestClassName());
    executer.execute(testClass.getTestClassName());
}

public void processTestClass(TestClassRunInfo testClass) {
    LOGGER.debug("Executing test class {}", testClass.getTestClassName());
    executer.execute(testClass.getTestClassName());
}

/**
 * Does not block.
 */
void processTestClass(TestClassRunInfo testClass);

/**
 * Does not block.
 */
void processTestClass(TestClassRunInfo testClass);

/**
 * Does not block.
 */
void processTestClass(TestClassRunInfo testClass);