public abstract class oadd.org.apache.hadoop.util.Shell extends java.lang.Object { private static final java.util.Map CHILD_SHELLS; public static final org.slf4j.Logger LOG; private static final java.lang.String WINDOWS_PROBLEMS; static final java.lang.String WINUTILS_EXE; public static final java.lang.String SYSPROP_HADOOP_HOME_DIR; public static final java.lang.String ENV_HADOOP_HOME; private static final int JAVA_SPEC_VER; public static final int WINDOWS_MAX_SHELL_LENGTH; public static final int WINDOWS_MAX_SHELL_LENGHT; public static final java.lang.String USER_NAME_COMMAND; public static final java.lang.Object WindowsProcessLaunchLock; public static final oadd.org.apache.hadoop.util.Shell$OSType osType; public static final boolean WINDOWS; public static final boolean SOLARIS; public static final boolean MAC; public static final boolean FREEBSD; public static final boolean LINUX; public static final boolean OTHER; public static final boolean PPC_64; public static final java.lang.String ENV_NAME_REGEX; public static final java.lang.String SET_PERMISSION_COMMAND; public static final java.lang.String SET_OWNER_COMMAND; public static final java.lang.String SET_GROUP_COMMAND; public static final java.lang.String LINK_COMMAND; public static final java.lang.String READ_LINK_COMMAND; protected long timeOutInterval; private final java.util.concurrent.atomic.AtomicBoolean timedOut; protected boolean inheritParentEnv; static final java.lang.String E_DOES_NOT_EXIST; static final java.lang.String E_IS_RELATIVE; static final java.lang.String E_NOT_DIRECTORY; static final java.lang.String E_NO_EXECUTABLE; static final java.lang.String E_NOT_EXECUTABLE_FILE; static final java.lang.String E_HADOOP_PROPS_UNSET; static final java.lang.String E_HADOOP_PROPS_EMPTY; static final java.lang.String E_NOT_A_WINDOWS_SYSTEM; private static final java.io.File HADOOP_HOME_FILE; private static final java.io.IOException HADOOP_HOME_DIR_FAILURE_CAUSE; public static final java.lang.String WINUTILS; private static final java.lang.String WINUTILS_PATH; private static final java.io.File WINUTILS_FILE; private static final java.io.IOException WINUTILS_FAILURE; public static final boolean isSetsidAvailable; public static final java.lang.String TOKEN_SEPARATOR_REGEX; private long interval; private long lastTime; private final boolean redirectErrorStream; private java.util.Map environment; private java.io.File dir; private java.lang.Process process; private int exitCode; private java.lang.Thread waitingThread; private final java.util.concurrent.atomic.AtomicBoolean completed; public static boolean isJava7OrAbove() { return 1; } public static boolean isJavaVersionAtLeast(int) { int v, v; boolean v; v := @parameter: int; v = ; if v < v goto label; v = 1; goto label; label: v = 0; label: return v; } public static transient void checkWindowsCommandLineLength(java.lang.String[]) throws java.io.IOException { java.lang.Object[] v; java.io.IOException v; java.lang.String[] v; java.lang.Integer v, v; int v, v, v, v; java.lang.String v, v, v, v; v := @parameter: java.lang.String[]; v = 0; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); v = v + v; v = v + 1; goto label; label: if v <= 8191 goto label; v = new java.io.IOException; v = newarray (java.lang.Object)[3]; v = staticinvoke (v); v[0] = v; v = staticinvoke (8191); v[1] = v; v = staticinvoke ("", v); v = virtualinvoke v.(0, 100); v[2] = v; v = staticinvoke ("The command line has a length of %d exceeds maximum allowed length of %d. Command starts with: %s", v); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } static java.lang.String bashQuote(java.lang.String) { int v, v; java.lang.StringBuilder v; java.lang.String v, v, v; v := @parameter: java.lang.String; v = new java.lang.StringBuilder; v = virtualinvoke v.(); v = v + 2; specialinvoke v.(int)>(v); virtualinvoke v.(39); v = virtualinvoke v.("\'", "\'\\\'\'"); virtualinvoke v.(v); virtualinvoke v.(39); v = virtualinvoke v.(); return v; } private static oadd.org.apache.hadoop.util.Shell$OSType getOSType() { oadd.org.apache.hadoop.util.Shell$OSType v, v, v, v, v, v; java.lang.String v; boolean v, v, v, v, v, v; v = staticinvoke ("os.name"); v = virtualinvoke v.("Windows"); if v == 0 goto label; v = ; return v; label: v = virtualinvoke v.("SunOS"); if v != 0 goto label; v = virtualinvoke v.("Solaris"); if v == 0 goto label; label: v = ; return v; label: v = virtualinvoke v.("Mac"); if v == 0 goto label; v = ; return v; label: v = virtualinvoke v.("FreeBSD"); if v == 0 goto label; v = ; return v; label: v = virtualinvoke v.("Linux"); if v == 0 goto label; v = ; return v; label: v = ; return v; } public static java.lang.String[] getGroupsCommand() { java.lang.String[] v; boolean v; v = ; if v == 0 goto label; v = newarray (java.lang.String)[3]; v[0] = "cmd"; v[1] = "/c"; v[2] = "groups"; goto label; label: v = newarray (java.lang.String)[1]; v[0] = "groups"; label: return v; } public static java.lang.String[] getGroupsForUserCommand(java.lang.String) { java.lang.String[] v, v; java.lang.String v, v, v, v, v; boolean v; v := @parameter: java.lang.String; v = ; if v == 0 goto label; v = newarray (java.lang.String)[4]; v = staticinvoke (); v[0] = v; v[1] = "groups"; v[2] = "-F"; v = dynamicinvoke "makeConcatWithConstants" (v) ("\"\u0001\""); v[3] = v; return v; label: v = staticinvoke (v); v = newarray (java.lang.String)[3]; v[0] = "bash"; v[1] = "-c"; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("id -gn \u; id -Gn \u0001"); v[2] = v; return v; } public static java.lang.String[] getGroupsIDForUserCommand(java.lang.String) { java.lang.String[] v, v; java.lang.String v, v, v, v, v; boolean v; v := @parameter: java.lang.String; v = ; if v == 0 goto label; v = newarray (java.lang.String)[4]; v = staticinvoke (); v[0] = v; v[1] = "groups"; v[2] = "-F"; v = dynamicinvoke "makeConcatWithConstants" (v) ("\"\u0001\""); v[3] = v; return v; label: v = staticinvoke (v); v = newarray (java.lang.String)[3]; v[0] = "bash"; v[1] = "-c"; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("id -g \u; id -G \u0001"); v[2] = v; return v; } public static java.lang.String[] getUsersForNetgroupCommand(java.lang.String) { java.lang.String[] v; java.lang.String v; v := @parameter: java.lang.String; v = newarray (java.lang.String)[3]; v[0] = "getent"; v[1] = "netgroup"; v[2] = v; return v; } public static java.lang.String[] getGetPermissionCommand() { java.lang.String[] v; java.lang.String v; boolean v; v = ; if v == 0 goto label; v = newarray (java.lang.String)[3]; v = staticinvoke (); v[0] = v; v[1] = "ls"; v[2] = "-F"; goto label; label: v = newarray (java.lang.String)[2]; v[0] = "ls"; v[1] = "-ld"; label: return v; } public static java.lang.String[] getSetPermissionCommand(java.lang.String, boolean) { java.lang.String[] v, v; java.lang.String v, v, v; boolean v, v, v; v := @parameter: java.lang.String; v := @parameter: boolean; if v == 0 goto label; v = ; if v == 0 goto label; v = newarray (java.lang.String)[4]; v = staticinvoke (); v[0] = v; v[1] = "chmod"; v[2] = "-R"; v[3] = v; goto label; label: v = newarray (java.lang.String)[3]; v[0] = "chmod"; v[1] = "-R"; v[2] = v; label: return v; label: v = ; if v == 0 goto label; v = newarray (java.lang.String)[3]; v = staticinvoke (); v[0] = v; v[1] = "chmod"; v[2] = v; goto label; label: v = newarray (java.lang.String)[2]; v[0] = "chmod"; v[1] = v; label: return v; } public static java.lang.String[] getSetPermissionCommand(java.lang.String, boolean, java.lang.String) { java.lang.Object[] v; java.lang.String[] v; int v, v, v, v; java.lang.String v, v; boolean v; v := @parameter: java.lang.String; v := @parameter: boolean; v := @parameter: java.lang.String; v = staticinvoke (v, v); v = lengthof v; v = v + 1; v = staticinvoke (v, v); v = lengthof v; v = v - 1; v[v] = v; return v; } public static java.lang.String[] getSetOwnerCommand(java.lang.String) { java.lang.String[] v; java.lang.String v, v, v; boolean v; v := @parameter: java.lang.String; v = ; if v == 0 goto label; v = newarray (java.lang.String)[3]; v = staticinvoke (); v[0] = v; v[1] = "chown"; v = dynamicinvoke "makeConcatWithConstants" (v) ("\"\u0001\""); v[2] = v; goto label; label: v = newarray (java.lang.String)[2]; v[0] = "chown"; v[1] = v; label: return v; } public static java.lang.String[] getSymlinkCommand(java.lang.String, java.lang.String) { java.lang.String[] v; java.lang.String v, v, v; boolean v; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = ; if v == 0 goto label; v = newarray (java.lang.String)[4]; v = staticinvoke (); v[0] = v; v[1] = "symlink"; v[2] = v; v[3] = v; goto label; label: v = newarray (java.lang.String)[4]; v[0] = "ln"; v[1] = "-s"; v[2] = v; v[3] = v; label: return v; } public static java.lang.String[] getReadlinkCommand(java.lang.String) { java.lang.String[] v; java.lang.String v, v; boolean v; v := @parameter: java.lang.String; v = ; if v == 0 goto label; v = newarray (java.lang.String)[3]; v = staticinvoke (); v[0] = v; v[1] = "readlink"; v[2] = v; goto label; label: v = newarray (java.lang.String)[2]; v[0] = "readlink"; v[1] = v; label: return v; } public static java.lang.String[] getCheckProcessIsAliveCommand(java.lang.String) { java.lang.String[] v; java.lang.String v; v := @parameter: java.lang.String; v = staticinvoke (0, v); return v; } public static java.lang.String[] getSignalKillCommand(int, java.lang.String) { java.lang.String[] v, v, v, v; int v; java.lang.String v, v, v, v, v, v; boolean v, v; v := @parameter: int; v := @parameter: java.lang.String; v = ; if v == 0 goto label; if 0 != v goto label; v = newarray (java.lang.String)[4]; v = staticinvoke (); v[0] = v; v[1] = "task"; v[2] = "isAlive"; v[3] = v; return v; label: v = newarray (java.lang.String)[4]; v = staticinvoke (); v[0] = v; v[1] = "task"; v[2] = "kill"; v[3] = v; return v; label: v = staticinvoke (v); v = ; if v == 0 goto label; v = newarray (java.lang.String)[3]; v[0] = "bash"; v[1] = "-c"; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("kill -\u -- -\u0001"); v[2] = v; return v; label: v = newarray (java.lang.String)[3]; v[0] = "bash"; v[1] = "-c"; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("kill -\u \u0001"); v[2] = v; return v; } public static java.lang.String getEnvironmentVariableRegex() { java.lang.String v; boolean v; v = ; if v == 0 goto label; v = "%([A-Za-z_][A-Za-z0-9_]*?)%"; goto label; label: v = "\\$([A-Za-z_][A-Za-z0-9_]*)"; label: return v; } public static java.io.File appendScriptExtension(java.io.File, java.lang.String) { java.lang.String v, v; java.io.File v, v; v := @parameter: java.io.File; v := @parameter: java.lang.String; v = new java.io.File; v = staticinvoke (v); specialinvoke v.(java.io.File,java.lang.String)>(v, v); return v; } public static java.lang.String appendScriptExtension(java.lang.String) { java.lang.String v, v, v; boolean v; v := @parameter: java.lang.String; v = ; if v == 0 goto label; v = ".cmd"; goto label; label: v = ".sh"; label: v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001\u0001"); return v; } public static java.lang.String[] getRunScriptCommand(java.io.File) { java.lang.String[] v; java.lang.String v, v; java.io.File v; boolean v; v := @parameter: java.io.File; v = virtualinvoke v.(); v = ; if v == 0 goto label; v = newarray (java.lang.String)[3]; v[0] = "cmd"; v[1] = "/c"; v[2] = v; goto label; label: v = newarray (java.lang.String)[2]; v[0] = "bash"; v = staticinvoke (v); v[1] = v; label: return v; } private static java.io.File checkHadoopHome() throws java.io.FileNotFoundException { java.lang.String v; java.io.File v; v = staticinvoke ("hadoop.home.dir"); if v != null goto label; v = staticinvoke ("HADOOP_HOME"); label: v = staticinvoke (v); return v; } static java.io.File checkHadoopHomeInner(java.lang.String) throws java.io.FileNotFoundException { int v, v; java.lang.String v, v, v, v; boolean v, v, v, v, v, v; java.io.File v; java.io.FileNotFoundException v, v, v, v, v; v := @parameter: java.lang.String; if v != null goto label; v = new java.io.FileNotFoundException; specialinvoke v.(java.lang.String)>("HADOOP_HOME and hadoop.home.dir are unset."); throw v; label: v = virtualinvoke v.("\""); if v == 0 goto label; v = virtualinvoke v.(1); goto label; label: v = virtualinvoke v.("\""); if v == 0 goto label; v = virtualinvoke v.(); v = v - 1; v = virtualinvoke v.(0, v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = new java.io.FileNotFoundException; specialinvoke v.(java.lang.String)>("HADOOP_HOME or hadoop.home.dir set to an empty string"); throw v; label: v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); if v != 0 goto label; v = new java.io.FileNotFoundException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Hadoop home directory \u is not an absolute path."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v != 0 goto label; v = new java.io.FileNotFoundException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Hadoop home directory \u does not exist"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v != 0 goto label; v = new java.io.FileNotFoundException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Hadoop home directory \u is not a directory."); specialinvoke v.(java.lang.String)>(v); throw v; label: return v; } private static java.lang.String addOsText(java.lang.String) { java.lang.String v, v; boolean v; v := @parameter: java.lang.String; v = ; if v == 0 goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u -see https://wiki.apache.org/hadoop/WindowsProblems"); goto label; label: v = v; label: return v; } private static java.io.FileNotFoundException fileNotFoundException(java.lang.String, java.lang.Exception) { java.lang.Throwable v; java.lang.String v; java.io.FileNotFoundException v; java.lang.Exception v; v := @parameter: java.lang.String; v := @parameter: java.lang.Exception; v = new java.io.FileNotFoundException; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); return v; } public static java.lang.String getHadoopHome() throws java.io.IOException { java.lang.String v; java.io.File v; v = staticinvoke (); v = virtualinvoke v.(); return v; } private static java.io.File getHadoopHomeDir() throws java.io.FileNotFoundException { java.io.IOException v, v, v; java.lang.String v, v; java.io.File v; java.io.FileNotFoundException v; v = ; if v == null goto label; v = ; v = virtualinvoke v.(); v = staticinvoke (v); v = ; v = staticinvoke (v, v); throw v; label: v = ; return v; } public static java.io.File getQualifiedBin(java.lang.String) throws java.io.FileNotFoundException { java.lang.String v; java.io.File v, v; v := @parameter: java.lang.String; v = staticinvoke (); v = staticinvoke (v, v); return v; } static java.io.File getQualifiedBinInner(java.io.File, java.lang.String) throws java.io.FileNotFoundException { java.lang.String v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v; java.io.IOException v; java.io.File v, v, v, v; java.io.FileNotFoundException v, v, v, v, v; v := @parameter: java.io.File; v := @parameter: java.lang.String; v = new java.io.File; specialinvoke v.(java.io.File,java.lang.String)>(v, "bin"); v = virtualinvoke v.(); if v != 0 goto label; v = new java.io.FileNotFoundException; v = dynamicinvoke "makeConcatWithConstants" ("Hadoop bin directory ", v) ("\u0001does not exist: \u0001"); v = staticinvoke (v); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v != 0 goto label; v = new java.io.FileNotFoundException; v = dynamicinvoke "makeConcatWithConstants" ("Hadoop bin directory ", v) ("\u0001is not a directory.: \u0001"); v = staticinvoke (v); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new java.io.File; specialinvoke v.(java.io.File,java.lang.String)>(v, v); v = virtualinvoke v.(); if v != 0 goto label; v = new java.io.FileNotFoundException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not locate Hadoop executable: \u0001"); v = staticinvoke (v); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v != 0 goto label; v = new java.io.FileNotFoundException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Not an executable file: \u0001"); v = staticinvoke (v); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); label: return v; label: v := @caughtexception; v = virtualinvoke v.(); v = staticinvoke (v, v); throw v; catch java.io.IOException from label to label with label; } public static java.lang.String getQualifiedBinPath(java.lang.String) throws java.io.IOException { java.lang.String v, v; java.io.File v; v := @parameter: java.lang.String; v = staticinvoke (v); v = virtualinvoke v.(); return v; } public static boolean hasWinutilsPath() { java.lang.String v; boolean v; v = ; if v == null goto label; v = 1; goto label; label: v = 0; label: return v; } public static java.lang.String getWinUtilsPath() { java.io.IOException v, v, v; java.lang.RuntimeException v; java.lang.String v, v; v = ; if v != null goto label; v = ; return v; label: v = new java.lang.RuntimeException; v = ; v = virtualinvoke v.(); v = ; specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; } public static java.io.File getWinUtilsFile() throws java.io.FileNotFoundException { java.io.IOException v, v, v; java.lang.String v; java.io.File v; java.io.FileNotFoundException v; v = ; if v != null goto label; v = ; return v; label: v = ; v = virtualinvoke v.(); v = ; v = staticinvoke (v, v); throw v; } public static boolean checkIsBashSupported() throws java.io.InterruptedIOException { org.slf4j.Logger v, v, v; oadd.org.apache.hadoop.util.Shell$ShellCommandExecutor v; java.io.IOException v; java.lang.String[] v; java.io.InterruptedIOException v; java.lang.SecurityException v; boolean v, v; v = ; if v == 0 goto label; return 0; label: v = 1; label: v = newarray (java.lang.String)[3]; v[0] = "bash"; v[1] = "-c"; v[2] = "echo 1000"; v = new oadd.org.apache.hadoop.util.Shell$ShellCommandExecutor; specialinvoke v.(java.lang.String[])>(v); virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Interrupted, unable to determine if bash is supported", v); throw v; label: v := @caughtexception; v = ; interfaceinvoke v.("Bash is not supported by the OS", v); v = 0; goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Bash execution is not allowed by the JVM security manager.Considering it not supported."); v = 0; label: return v; catch java.io.InterruptedIOException from label to label with label; catch java.io.IOException from label to label with label; catch java.lang.SecurityException from label to label with label; } private static boolean isSetsidSupported() { java.lang.SecurityException v; boolean v, v, v, v, v, v, v, v, v, v; java.lang.Throwable v; java.lang.Error v; java.lang.String[] v; int v, v, v, v, v; java.lang.String v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.util.Shell$ShellCommandExecutor v, v; java.io.IOException v; java.lang.Comparable v, v, v, v, v; v = ; if v == 0 goto label; return 0; label: v = null; v = 1; label: v = newarray (java.lang.String)[4]; v[0] = "setsid"; v[1] = "bash"; v[2] = "-c"; v[3] = "echo $$"; v = new oadd.org.apache.hadoop.util.Shell$ShellCommandExecutor; specialinvoke v.(java.lang.String[])>(v); v = v; virtualinvoke v.(); label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("setsid exited with exit code \u0001"); interfaceinvoke v.(v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("setsid is not available on this machine. So not using it."); v = 0; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v); goto label; label: v = "(null executor)"; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("setsid exited with exit code \u0001"); interfaceinvoke v.(v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("setsid is not allowed to run by the JVM security manager. So not using it."); v = 0; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v); goto label; label: v = "(null executor)"; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("setsid exited with exit code \u0001"); interfaceinvoke v.(v); goto label; label: v := @caughtexception; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.("posix_spawn is not a supported process launch mechanism"); if v == 0 goto label; v = ; if v != 0 goto label; v = ; if v == 0 goto label; label: v = ; interfaceinvoke v.("Avoiding JDK-8047340 on BSD-based systems.", v); v = 0; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v); goto label; label: v = "(null executor)"; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("setsid exited with exit code \u0001"); interfaceinvoke v.(v); goto label; label: v := @caughtexception; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v); goto label; label: v = "(null executor)"; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("setsid exited with exit code \u0001"); interfaceinvoke v.(v); label: throw v; label: return v; catch java.io.IOException from label to label with label; catch java.lang.SecurityException from label to label with label; catch java.lang.Error from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } protected void () { oadd.org.apache.hadoop.util.Shell v; v := @this: oadd.org.apache.hadoop.util.Shell; specialinvoke v.(long)>(0L); return; } protected void (long) { long v; oadd.org.apache.hadoop.util.Shell v; v := @this: oadd.org.apache.hadoop.util.Shell; v := @parameter: long; specialinvoke v.(long,boolean)>(v, 0); return; } protected void (long, boolean) { byte v; java.util.concurrent.atomic.AtomicBoolean v, v; long v, v; boolean v; oadd.org.apache.hadoop.util.Shell v; v := @this: oadd.org.apache.hadoop.util.Shell; v := @parameter: long; v := @parameter: boolean; specialinvoke v.()>(); v. = 0L; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v. = 1; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v. = v; v = v cmp 0L; if v >= 0 goto label; v = 0L; goto label; label: v = neg v; label: v. = v; v. = v; return; } protected void setEnvironment(java.util.Map) { java.util.Map v; oadd.org.apache.hadoop.util.Shell v; v := @this: oadd.org.apache.hadoop.util.Shell; v := @parameter: java.util.Map; v. = v; return; } protected void setWorkingDirectory(java.io.File) { java.io.File v; oadd.org.apache.hadoop.util.Shell v; v := @this: oadd.org.apache.hadoop.util.Shell; v := @parameter: java.io.File; v. = v; return; } protected void run() throws java.io.IOException { byte v; long v, v, v, v; boolean v; oadd.org.apache.hadoop.util.Shell v; v := @this: oadd.org.apache.hadoop.util.Shell; v = v.; v = v.; v = v + v; v = staticinvoke (); v = v cmp v; if v <= 0 goto label; return; label: v. = 0; v = ; if v == 0 goto label; staticinvoke ("jdk.lang.Process.launchMechanism", "POSIX_SPAWN"); label: specialinvoke v.(); return; } private void runCommand() throws java.io.IOException { byte v; java.lang.Thread v; java.util.Map v, v, v, v, v, v, v; oadd.org.apache.hadoop.util.Shell$1 v; java.lang.Throwable v, v; long v, v, v, v; java.io.InterruptedIOException v; java.lang.StringBuffer v; java.lang.String v, v, v, v; java.io.InputStreamReader v, v; java.io.File v, v; java.io.BufferedReader v, v; java.lang.OutOfMemoryError v; java.lang.IllegalStateException v; oadd.org.apache.hadoop.util.Shell$ShellTimeoutTimerTask v; java.util.Timer v, v; oadd.org.apache.hadoop.util.Shell$ExitCodeException v; boolean v, v, v, v, v; oadd.org.apache.hadoop.util.Shell v; java.lang.Process v, v, v, v, v, v, v; java.util.concurrent.atomic.AtomicBoolean v, v, v, v, v; java.lang.String[] v; java.nio.charset.Charset v, v; int v, v, v; java.lang.ProcessBuilder v; org.slf4j.Logger v; java.lang.InterruptedException v; java.lang.Object v; java.io.InputStream v, v; v := @this: oadd.org.apache.hadoop.util.Shell; v = new java.lang.ProcessBuilder; v = virtualinvoke v.(); specialinvoke v.(java.lang.String[])>(v); v = null; v = v.; virtualinvoke v.(0); v = v.; virtualinvoke v.(0); v = v.; if v != 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(); label: v = v.; if v == null goto label; v = virtualinvoke v.(); v = v.; interfaceinvoke v.(v); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: v = v.; virtualinvoke v.(v); v = ; if v == 0 goto label; v = ; entermonitor v; label: v = virtualinvoke v.(); v. = v; exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = virtualinvoke v.(); v. = v; label: v = staticinvoke (); v. = v; v = ; interfaceinvoke v.(v, null); v = v.; v = v cmp 0L; if v <= 0 goto label; v = new java.util.Timer; specialinvoke v.(java.lang.String)>("Shell command timeout"); v = v; v = new oadd.org.apache.hadoop.util.Shell$ShellTimeoutTimerTask; specialinvoke v.(oadd.org.apache.hadoop.util.Shell)>(v); v = v.; virtualinvoke v.(v, v); label: v = new java.io.BufferedReader; v = new java.io.InputStreamReader; v = v.; v = virtualinvoke v.(); v = staticinvoke (); specialinvoke v.(java.io.InputStream,java.nio.charset.Charset)>(v, v); specialinvoke v.(java.io.Reader)>(v); v = new java.io.BufferedReader; v = new java.io.InputStreamReader; v = v.; v = virtualinvoke v.(); v = staticinvoke (); specialinvoke v.(java.io.InputStream,java.nio.charset.Charset)>(v, v); specialinvoke v.(java.io.Reader)>(v); v = new java.lang.StringBuffer; specialinvoke v.()>(); v = new oadd.org.apache.hadoop.util.Shell$1; specialinvoke v.(oadd.org.apache.hadoop.util.Shell,java.io.BufferedReader,java.lang.StringBuffer)>(v, v, v); label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Caught \u. One possible reason is that ulimit setting of \'max user processes\' is too low. If so, do \'ulimit -u \' and try again."); interfaceinvoke v.(v); throw v; label: virtualinvoke v.(v); v = virtualinvoke v.(); label: if v == null goto label; v = virtualinvoke v.(); goto label; label: v = v.; v = virtualinvoke v.(); v. = v; staticinvoke (v); v = v.; virtualinvoke v.(1); v = v.; if v == 0 goto label; v = new oadd.org.apache.hadoop.util.Shell$ExitCodeException; v = v.; v = virtualinvoke v.(); specialinvoke v.(int,java.lang.String)>(v, v); throw v; label: if v == null goto label; virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(); staticinvoke (v); label: v = v.; virtualinvoke v.(); v. = null; v = ; interfaceinvoke v.(v); v = staticinvoke (); v. = v; goto label; label: v := @caughtexception; v = new java.io.InterruptedIOException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); throw v; label: v := @caughtexception; if v == null goto label; virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(); staticinvoke (v); label: v = v.; virtualinvoke v.(); v. = null; v = ; interfaceinvoke v.(v); v = staticinvoke (); v. = v; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.IllegalStateException from label to label with label; catch java.lang.OutOfMemoryError from label to label with label; catch java.lang.InterruptedException from label to label with label; catch java.lang.Throwable from label to label with label; } private static void joinThread(java.lang.Thread) { org.slf4j.Logger v, v; java.lang.InterruptedException v; java.lang.Thread v; java.lang.String v; boolean v, v; v := @parameter: java.lang.Thread; label: v = virtualinvoke v.(); if v == 0 goto label; label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Interrupted while joining on: \u0001"); interfaceinvoke v.(v, v); label: virtualinvoke v.(); goto label; label: return; catch java.lang.InterruptedException from label to label with label; } protected abstract java.lang.String[] getExecString(); protected abstract void parseExecResult(java.io.BufferedReader) throws java.io.IOException; public java.lang.String getEnvironment(java.lang.String) { java.util.Map v; java.lang.Object v; java.lang.String v; oadd.org.apache.hadoop.util.Shell v; v := @this: oadd.org.apache.hadoop.util.Shell; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(v); return v; } public java.lang.Process getProcess() { java.lang.Process v; oadd.org.apache.hadoop.util.Shell v; v := @this: oadd.org.apache.hadoop.util.Shell; v = v.; return v; } public int getExitCode() { int v; oadd.org.apache.hadoop.util.Shell v; v := @this: oadd.org.apache.hadoop.util.Shell; v = v.; return v; } public java.lang.Thread getWaitingThread() { java.lang.Thread v; oadd.org.apache.hadoop.util.Shell v; v := @this: oadd.org.apache.hadoop.util.Shell; v = v.; return v; } public boolean isTimedOut() { java.util.concurrent.atomic.AtomicBoolean v; boolean v; oadd.org.apache.hadoop.util.Shell v; v := @this: oadd.org.apache.hadoop.util.Shell; v = v.; v = virtualinvoke v.(); return v; } private void setTimedOut() { java.util.concurrent.atomic.AtomicBoolean v; oadd.org.apache.hadoop.util.Shell v; v := @this: oadd.org.apache.hadoop.util.Shell; v = v.; virtualinvoke v.(1); return; } public static transient java.lang.String execCommand(java.lang.String[]) throws java.io.IOException { java.lang.String[] v; java.lang.String v; v := @parameter: java.lang.String[]; v = staticinvoke (null, v, 0L); return v; } public static java.lang.String execCommand(java.util.Map, java.lang.String[], long) throws java.io.IOException { java.util.Map v; oadd.org.apache.hadoop.util.Shell$ShellCommandExecutor v; java.lang.String[] v; long v; java.lang.String v; v := @parameter: java.util.Map; v := @parameter: java.lang.String[]; v := @parameter: long; v = new oadd.org.apache.hadoop.util.Shell$ShellCommandExecutor; specialinvoke v.(java.lang.String[],java.io.File,java.util.Map,long)>(v, null, v, v); virtualinvoke v.(); v = virtualinvoke v.(); return v; } public static transient java.lang.String execCommand(java.util.Map, java.lang.String[]) throws java.io.IOException { java.lang.String[] v; java.lang.String v; java.util.Map v; v := @parameter: java.util.Map; v := @parameter: java.lang.String[]; v = staticinvoke (v, v, 0L); return v; } public static void destroyAllShellProcesses() { java.lang.Throwable v; java.lang.Process v, v; java.util.Iterator v; java.util.Set v; java.util.Map v, v, v; java.lang.Object v; boolean v; v = ; entermonitor v; label: v = ; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v = ; interfaceinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } public static java.util.Set getAllShells() { java.lang.Throwable v; java.util.HashSet v; java.util.Map v, v; java.util.Set v; v = ; entermonitor v; label: v = new java.util.HashSet; v = ; v = interfaceinvoke v.(); specialinvoke v.(java.util.Collection)>(v); exitmonitor v; label: return v; label: v := @caughtexception; exitmonitor v; throw v; catch java.lang.Throwable from label to label with label; } public static java.lang.Long getMemlockLimit(java.lang.Long) { java.lang.Long v, v; long v, v; boolean v; v := @parameter: java.lang.Long; v = ; if v == 0 goto label; v = virtualinvoke v.(); v = staticinvoke (2147483647L, v); v = staticinvoke (v); return v; label: return v; } static void () { java.util.Map v; boolean v, v, v, v, v, v, v, v, v, v, v; java.io.FileNotFoundException v; java.lang.String[] v; int v, v; java.lang.String v, v, v, v, v; java.util.WeakHashMap v; java.util.Properties v; org.slf4j.Logger v, v, v, v, v; java.io.IOException v, v, v, v; java.io.File v, v; oadd.org.apache.hadoop.util.Shell$OSType v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Object v; v = new java.util.WeakHashMap; specialinvoke v.()>(); v = staticinvoke (v); = v; v = staticinvoke (class "Loadd/org/apache/hadoop/util/Shell;"); = v; v = staticinvoke ("java.specification.version"); v = virtualinvoke v.("\\."); v = v[0]; v = staticinvoke (v); v = staticinvoke (8, v); = v; v = new java.lang.Object; specialinvoke v.()>(); = v; v = staticinvoke (); = v; v = ; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: = v; v = ; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: = v; v = ; v =