* limitations under the License.
 */

package org.gradle.process.internal.worker;

import org.gradle.internal.remote.ObjectConnection;
import org.gradle.internal.service.ServiceRegistry;

public interface WorkerProcessContext {
    /**
     * Returns the unique identifier for this worker process.
     */
    Object getWorkerId();

    /**
     * Returns a display name for this worker process.
     */

            stopReceived.countDown();
        }
    }

    public void execute(WorkerProcessContext workerProcessContext) {
        stopReceived = new CountDownLatch(1);
        workerProcessContext.getServerConnection().addIncoming(TestListenerInterface.class, this);
        workerProcessContext.getServerConnection().connect();
        try {
            stopReceived.await();

 */

package org.gradle.process.internal;

import org.gradle.api.Action;
import org.gradle.process.internal.worker.WorkerProcessContext;

import java.io.Serializable;

public class BrokenRemoteProcess implements Action<WorkerProcessContext>, Serializable {
    public void execute(WorkerProcessContext workerProcessContext) {
        throw new RuntimeException("broken");
    }

    private final Action<? super WorkerProcessContext> action;

    public ActionExecutionWorker(Action<? super WorkerProcessContext> action) {
        this.action = action;
    }

    @Override
    public void execute(final WorkerProcessContext workerContext) {
        LOGGER.debug("Starting {}.", workerContext.getDisplayName());

        ObjectConnection clientConnection = workerContext.getServerConnection();

        private final WorkerProcessContext workerProcessContext;

        public TestFrameworkServiceRegistry(WorkerProcessContext workerProcessContext) {
            this.workerProcessContext = workerProcessContext;
        }

        @Provides
        protected Clock createClock() {
            return workerProcessContext.getServiceRegistry().get(Clock.class);
        }

import org.gradle.api.Action;
import org.gradle.process.internal.worker.WorkerProcessContext;

import java.io.Serializable;
import java.util.concurrent.CountDownLatch;

public class MessageProducingProcess implements Action<WorkerProcessContext>, Serializable {
    public void execute(WorkerProcessContext workerProcessContext) {
        final CountDownLatch latch = new CountDownLatch(1);
        new Thread(new Runnable() {

import org.gradle.process.internal.worker.WorkerProcessContext;

import java.io.Serializable;

public class CrashingRemoteProcess implements Action<WorkerProcessContext>, Serializable {
    public void execute(WorkerProcessContext workerProcessContext) {
        TestListenerInterface sender = workerProcessContext.getServerConnection().addOutgoing(TestListenerInterface.class);
        workerProcessContext.getServerConnection().connect();

import org.gradle.api.Action;
import org.gradle.process.internal.worker.WorkerProcessContext;

import java.io.Serializable;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class NoCleanUpRemoteProcess implements Action<WorkerProcessContext>, Serializable {
    public void execute(WorkerProcessContext workerProcessContext) {
        final Lock lock = new ReentrantLock();
        lock.lock();

package org.gradle.process.internal;

import org.gradle.api.Action;
import org.gradle.process.internal.worker.WorkerProcessContext;

import java.io.Serializable;

public class OutputOnShutdownHookProcess implements Action<WorkerProcessContext>, Serializable {
    @Override
    public void execute(WorkerProcessContext workerProcessContext) {
        Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
            @Override

import org.gradle.process.internal.worker.WorkerProcessContext;

import java.io.Serializable;

public class OtherRemoteProcess implements Action<WorkerProcessContext>, Serializable {
    public void execute(WorkerProcessContext workerProcessContext) {
        TestListenerInterface sender = workerProcessContext.getServerConnection().addOutgoing(TestListenerInterface.class);
        workerProcessContext.getServerConnection().connect();