1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
/*
Derby - Class org.apache.derbyTesting.functionTests.harness.TimedProcess
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.
*/
package org.apache.derbyTesting.functionTests.harness;
/**
* This class is a wrapper of Process to provide a waitFor() method
* that forcibly terminates the process if it does not
* complete within the specified time.
*
*
*/
public class TimedProcess
{
private Process process;
public TimedProcess(Process process)
{
this.process = process;
}
public int waitFor(int sec)
{
int exitValue = -1;
// Create a thread to wait for the process to die
WaitForProcess t = new WaitForProcess(process);
t.start();
// Give the process sec seconds to terminate
try
{
t.join(sec * 1000);
// Otherwise, interrupt the thread...
if (t.isAlive())
{
t.interrupt();
System.err.println("Server Process did not complete in time. Destroying...");
// ...and destroy the process with gusto
process.destroy();
}
else
{
// process shut down, so it is right to get the exit value from it
exitValue = t.getProcessExitValue();
}
}
catch (InterruptedException e)
{
e.printStackTrace();
}
return exitValue;
}
} // public class TimedProcess
class WaitForProcess
extends Thread
{
private Process process;
private int processExitValue;
public WaitForProcess(Process process)
{
this.process = process;
}
public int getProcessExitValue()
{
return processExitValue;
}
public void run()
{
// Our whole goal in life here is to waitFor() the process.
// However, we're actually going to catch the InterruptedException for it!
try
{
processExitValue = process.waitFor();
}
catch (InterruptedException e)
{
// Don't do anything here; the thread will die of natural causes
}
}
} // class WaitForProcess
|
