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
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
/*
* Copyright 2013 akquinet tech@spree GmbH
*
* Licensed 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 de.akquinet.devops;
import java.net.InetAddress;
import java.net.ServerSocket;
import com.gitblit.GitBlitServer;
import com.gitblit.tests.GitBlitSuite;
/**
* This is a runnable implementation, that is used to run a gitblit server in a
* separate thread (e.g. alongside test cases)
*
* @author saheba
*
*/
public class GitblitRunnable implements Runnable {
private int httpPort, httpsPort, shutdownPort;
private String userPropertiesPath, gitblitPropertiesPath;
private boolean startFailed = false;
/**
* constructor with reduced set of start params
*
* @param httpPort
* @param httpsPort
* @param shutdownPort
* @param gitblitPropertiesPath
* @param userPropertiesPath
*/
public GitblitRunnable(int httpPort, int httpsPort, int shutdownPort,
String gitblitPropertiesPath, String userPropertiesPath) {
this.httpPort = httpPort;
this.httpsPort = httpsPort;
this.shutdownPort = shutdownPort;
this.userPropertiesPath = userPropertiesPath;
this.gitblitPropertiesPath = gitblitPropertiesPath;
}
/*
* (non-Javadoc)
*
* @see java.lang.Runnable#run()
*/
public void run() {
boolean portsFree = false;
long lastRun = -1;
while (!portsFree) {
long current = System.currentTimeMillis();
if (lastRun == -1 || lastRun + 100 < current) {
portsFree = areAllPortsFree(new int[] { httpPort, httpsPort,
shutdownPort }, "127.0.0.1");
}
lastRun = current;
}
try {
GitBlitServer4UITests.main("--httpPort", "" + httpPort, "--httpsPort", ""
+ httpsPort, "--shutdownPort", "" + shutdownPort,
"--repositoriesFolder",
"\"" + GitBlitSuite.REPOSITORIES.getAbsolutePath() + "\"",
"--userService", userPropertiesPath, "--settings",
gitblitPropertiesPath);
setStartFailed(false);
} catch (Exception iex) {
System.out.println("Gitblit server start failed");
setStartFailed(true);
}
}
/**
* Method used to ensure that all ports are free, if the runnable is used
* JUnit test classes. Be aware that JUnit's setUpClass and tearDownClass
* methods, which are executed before and after a test class (consisting of
* several test cases), may be executed parallely if they are part of a test
* suite consisting of several test classes. Therefore the run method of
* this class calls areAllPortsFree to check port availability before
* starting another gitblit instance.
*
* @param ports
* @param inetAddress
* @return
*/
public static boolean areAllPortsFree(int[] ports, String inetAddress) {
System.out
.println("\n"
+ System.currentTimeMillis()
+ " ----------------------------------- testing if all ports are free ...");
String blockedPorts = "";
for (int i = 0; i < ports.length; i++) {
ServerSocket s;
try {
s = new ServerSocket(ports[i], 1,
InetAddress.getByName(inetAddress));
s.close();
} catch (Exception e) {
if (!blockedPorts.equals("")) {
blockedPorts += ", ";
}
}
}
if (blockedPorts.equals("")) {
System.out
.println(" ----------------------------------- ... verified");
return true;
}
System.out.println(" ----------------------------------- ... "
+ blockedPorts + " are still blocked");
return false;
}
private void setStartFailed(boolean startFailed) {
this.startFailed = startFailed;
}
public boolean isStartFailed() {
return startFailed;
}
}
|
