blob: 70ec8983df702fdaf8f58f1dac10707b18d60a59 (
plain)
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
|
/*
* SonarQube Runner - Distribution
* Copyright (C) 2011 SonarSource
* dev@sonar.codehaus.org
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 3 of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this program; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02
*/
package org.sonar.runner;
class Shutdown {
static final int SUCCESS = 0;
static final int ERROR = 1;
private static final long DEFAULT_MAX_WAIT = 10_000;
private long maxWait;
ShutdownHook hook = new ShutdownHook();
private boolean isReady = false;
private boolean exiting = false;
private Object lock = new Object();
private Exit exit;
private Thread t;
Shutdown(Exit exit) {
this(exit, DEFAULT_MAX_WAIT);
}
Shutdown(Exit exit, long maxWait) {
this.maxWait = maxWait;
this.exit = exit;
Runtime.getRuntime().addShutdownHook(hook);
}
void exit(int status) {
synchronized (lock) {
signalReady(true);
}
exit.exit(status);
}
void signalReady(boolean ready) {
synchronized (lock) {
System.out.println("READY: " + ready);
this.isReady = ready;
lock.notifyAll();
}
}
boolean shouldExit() {
synchronized (lock) {
return exiting;
}
}
class ShutdownHook extends Thread {
private ShutdownHook() {
this.setName("shutdown-hook");
}
@Override
public void run() {
long startTime = System.currentTimeMillis();
synchronized (lock) {
exiting = true;
while (!isReady) {
long waitTime = startTime + maxWait - System.currentTimeMillis();
if (waitTime <= 0) {
break;
}
try {
lock.wait(waitTime);
} catch (InterruptedException e) {
// continue
}
}
}
}
}
}
|
