*/

package org.gradle.internal.cc.impl.inputs.process.instrument

/**
 * Test cases for triple-argument {@code Runtime.exec}:
 * <pre>
 *     Runtime.getRuntime().exec("echo 123", env, cwd)
 *     Runtime.getRuntime().exec(["echo", "123"], env, cwd)
 * </pre>
 */
class RuntimeExec3InstrumentationInDynamicGroovyWithoutIndyIntegrationTest extends RuntimeExec3InstrumentationInDynamicGroovyWithIndyIntegrationTest {

public class CrashingWorker implements RequestHandler<String, Object> {
    @Override
    public Object run(String request) {
        if (request.equals("halt-ok")) {
            Runtime.getRuntime().halt(0);
        } else if (request.equals("halt")) {
            Runtime.getRuntime().halt(12);
        } else {
            System.exit(12);
        }
        throw new UnsupportedOperationException();
    }

    protected String filterIndex = ".crawler.filter";

    protected int queueShards = Runtime.getRuntime().availableProcessors() * 2;

    protected int dataShards = Runtime.getRuntime().availableProcessors() * 2;

    protected int filterShards = Runtime.getRuntime().availableProcessors() * 2;

    protected int queueReplicas = 1;

    protected int dataReplicas = 1;

                    MessageUtils.doSystemUninstall();
                }
            });
            Runtime.getRuntime().addShutdownHook(shutdownHook);
        }
    }

    public static void systemUninstall() {
        doSystemUninstall();
        if (shutdownHook != null) {
            try {
                Runtime.getRuntime().removeShutdownHook(shutdownHook);
            } catch (IllegalStateException var3) {
                // ignore

    private static final Logger log = LoggerFactory.getLogger(AbstractCIFSContext.class);
    private boolean closed;


    /**
     * 
     */
    public AbstractCIFSContext () {
        Runtime.getRuntime().addShutdownHook(this);
    }


    /**
     * @param creds
     * @return a wrapped context with the given credentials
     */
    @Override
    public CIFSContext withCredentials ( Credentials creds ) {

public class DefaultJvmMemoryInfo implements JvmMemoryInfo {
    private final long totalMemory; //this does not change

    public DefaultJvmMemoryInfo() {
        this.totalMemory = Runtime.getRuntime().maxMemory();
    }

    /**
     * Max memory that this process can commit in bytes. Always returns the same value because maximum memory is determined at jvm start.
     */
    long getMaxMemory() {

        HOOKS.put(shutdownHook, thread);
        Runtime.getRuntime().addShutdownHook(thread);
    }

    public static void removeShutdownHook(Runnable shutdownHook) {
        try {
            Thread thread = HOOKS.remove(shutdownHook);
            if (thread != null) {
                Runtime.getRuntime().removeShutdownHook(thread);
            }
        } catch (IllegalStateException e) {

import java.util.Map;
import java.util.Objects;

public final class MemoryUtil {
    private MemoryUtil() {
    }

    public static String getMemoryUsageLog() {
        final Runtime runtime = Runtime.getRuntime();
        final long freeBytes = runtime.freeMemory();
        final long maxBytes = runtime.maxMemory();
        final long totalBytes = runtime.totalMemory();
        final long usedBytes = totalBytes - freeBytes;

// end::parallel-calculated[]
// end::fork-every[]
// end::disable-reports[]

// tag::parallel-4[]
    maxParallelForks = 4
// end::parallel-4[]

// tag::parallel-calculated[]
    maxParallelForks = (Runtime.getRuntime().availableProcessors() / 2).coerceAtLeast(1)
// end::parallel-calculated[]

// tag::fork-every[]
    forkEvery = 100
// end::fork-every[]

// tag::disable-reports[]
    reports.html.required = false

@Singleton
class Application @Inject() extends InjectedController {

  def index = Action {
    Ok(views.html.index("Your new application is ready."))
  }

  def shutdown = Action {
    Runtime.getRuntime().halt(0)
    Ok("shutdown")
  }