maven-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tibordig...@apache.org
Subject maven-surefire git commit: [SUREFIRE-1302] Surefire does not wait long enough for the forked VM and assumes it to be dead
Date Sat, 10 Jun 2017 08:17:57 GMT
Repository: maven-surefire
Updated Branches:
  refs/heads/SUREFIRE-1302_2 [created] 8b6c3e0b0


[SUREFIRE-1302] Surefire does not wait long enough for the forked VM and assumes it to be
dead


Project: http://git-wip-us.apache.org/repos/asf/maven-surefire/repo
Commit: http://git-wip-us.apache.org/repos/asf/maven-surefire/commit/8b6c3e0b
Tree: http://git-wip-us.apache.org/repos/asf/maven-surefire/tree/8b6c3e0b
Diff: http://git-wip-us.apache.org/repos/asf/maven-surefire/diff/8b6c3e0b

Branch: refs/heads/SUREFIRE-1302_2
Commit: 8b6c3e0b0fe671686b2bdd64181c564811b62a91
Parents: dd518d2
Author: Tibor17 <tibordigana@apache.org>
Authored: Sat Jun 10 10:17:39 2017 +0200
Committer: Tibor17 <tibordigana@apache.org>
Committed: Sat Jun 10 10:17:39 2017 +0200

----------------------------------------------------------------------
 .../maven/surefire/booter/PpidChecker.java      | 178 +++++++++++++++++++
 1 file changed, 178 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/maven-surefire/blob/8b6c3e0b/surefire-booter/src/main/java/org/apache/maven/surefire/booter/PpidChecker.java
----------------------------------------------------------------------
diff --git a/surefire-booter/src/main/java/org/apache/maven/surefire/booter/PpidChecker.java
b/surefire-booter/src/main/java/org/apache/maven/surefire/booter/PpidChecker.java
new file mode 100644
index 0000000..ac291e1
--- /dev/null
+++ b/surefire-booter/src/main/java/org/apache/maven/surefire/booter/PpidChecker.java
@@ -0,0 +1,178 @@
+package org.apache.maven.surefire.booter;
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.lang.management.ManagementFactory;
+import java.util.Locale;
+import java.util.StringTokenizer;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ * Recognizes PPID.
+ *
+ * @since 2.20.1
+ */
+final class PpidChecker
+{
+    private static final String WMIC_PPID = "ParentProcessId";
+
+    private static final String WMIC_CREATION_DATE = "CreationDate";
+
+    private static final String WINDOWS_CMD =
+            "wmic process where (ProcessId=%d) get " + WMIC_CREATION_DATE + ", " + WMIC_PPID;
+
+    private static final String UNIX_CMD = "ps -o etime -p %s";
+
+    private static final Pattern UNIX_CMD_OUT_PATTERN =
+            Pattern.compile( "^((([\\d]+)-)?([\\d]{2}))?[:]?([\\d]{2}):([\\d]{2})$" );
+
+    private static long fromDays( Matcher matcher ) {
+        String s = matcher.group( 3 );
+        return s == null ? 0L : 24L * 60L * 60L * Byte.parseByte( s );
+    }
+
+    private static long fromHours( Matcher matcher ) {
+        String s = matcher.group( 4 );
+        return s == null ? 0L : 60L * 60L * Byte.parseByte( s );
+    }
+
+    private static long fromMinutes( Matcher matcher ) {
+        String s = matcher.group( 5 );
+        return s == null ? 0L : 60L * Byte.parseByte( s );
+    }
+
+    private static long fromSeconds( Matcher matcher ) {
+        String s = matcher.group( 6 );
+        return s == null ? 0L : Byte.parseByte( s );
+    }
+
+    // http://manpages.ubuntu.com/manpages/precise/en/man1/ps.1.html
+    // https://www.freebsd.org/cgi/man.cgi?query=ps&manpath=SuSE+Linux/i386+11.3
+
+    // http://manpages.ubuntu.com/manpages/xenial/man1/ps.1.html
+    // etime       ELAPSED   elapsed time since the process was started, in
+    //             the form [[DD-]hh:]mm:ss.
+
+    static void unix() throws IOException, InterruptedException
+    {
+        String ppid = System.getProperty( "surefire.ppid" );
+        String[] cmd = { "/bin/sh", "-c", String.format( Locale.ROOT, UNIX_CMD, ppid ) };
+        ProcessBuilder probuilder = new ProcessBuilder( cmd );
+        Process p = probuilder.start();
+        BufferedReader reader = new BufferedReader( new InputStreamReader( p.getInputStream()
) );
+        for ( String line = reader.readLine(); line != null; line = reader.readLine() )
+        {
+            System.out.println(line);
+            line = line.trim();
+            if ( !line.isEmpty() )
+            {
+                Matcher matcher = UNIX_CMD_OUT_PATTERN.matcher( line );
+                if (matcher.matches()) {
+                    long pidUptime = (long) Math.floor( ManagementFactory.getRuntimeMXBean().getUptime()
/ 1000d );
+                    long ppidUptime = fromDays( matcher )
+                                              + fromHours( matcher )
+                                              + fromMinutes( matcher )
+                                              + fromSeconds( matcher );
+                    System.out.printf( "%d %d\n", pidUptime, ppidUptime);
+                    break;
+                }
+            }
+        }
+        reader.close();
+        p.waitFor();
+        p.destroy();
+    }
+
+    static void windows() throws IOException, InterruptedException
+    {
+        final long pid;
+        String processName = ManagementFactory.getRuntimeMXBean().getName();
+        if ( processName != null && processName.contains( "@" ) )
+        {
+            try
+            {
+                pid = Long.parseLong( processName.substring( 0, processName.indexOf( '@'
) ) );
+            }
+            catch ( NumberFormatException e )
+            {
+                return;
+            }
+        }
+        else
+        {
+            return;
+        }
+
+        String[] cmd = { "CMD", "/A/C", String.format( Locale.ROOT, WINDOWS_CMD, pid ) };
+        ProcessBuilder probuilder = new ProcessBuilder( cmd );
+        Process p = probuilder.start();
+        BufferedReader reader = new BufferedReader( new InputStreamReader( p.getInputStream()
) );
+        boolean hasHeader = false;
+        boolean isStartTimestampFirst = false;
+        String startTimestamp = null;
+        long ppid = 0;
+        for ( String line = reader.readLine(); line != null; line = reader.readLine() )
+        {
+            line = line.trim();
+
+            if ( line.isEmpty() )
+            {
+                continue;
+            }
+
+            if ( hasHeader )
+            {
+                StringTokenizer args = new StringTokenizer( line );
+                if ( args.countTokens() == 2 )
+                {
+                    if ( isStartTimestampFirst )
+                    {
+                        startTimestamp = args.nextToken();
+                        ppid = Long.parseLong( args.nextToken() );
+                    }
+                    else
+                    {
+                        startTimestamp = args.nextToken();
+                        ppid = Long.parseLong( args.nextToken() );
+                    }
+                }
+            }
+            else
+            {
+                StringTokenizer args = new StringTokenizer( line );
+                if ( args.countTokens() == 2 )
+                {
+                    String arg0 = args.nextToken();
+                    String arg1 = args.nextToken();
+                    isStartTimestampFirst = WMIC_CREATION_DATE.equals( arg0 );
+                    hasHeader = isStartTimestampFirst || WMIC_PPID.equals( arg0 );
+                    hasHeader &= WMIC_CREATION_DATE.equals( arg1 ) || WMIC_PPID.equals(
arg1 );
+                }
+            }
+        }
+        reader.close();
+        p.waitFor();
+        p.destroy();
+    }
+}


Mime
View raw message