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
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
|
package org.eclipse.team.tests.ccvs.core;
/*
* (c) Copyright IBM Corp. 2000, 2002.
* All Rights Reserved.
*/
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.PrintStream;
import junit.extensions.TestSetup;
import junit.framework.Test;
import org.eclipse.core.runtime.NullProgressMonitor;
import org.eclipse.team.internal.ccvs.core.CVSException;
import org.eclipse.team.internal.ccvs.core.CVSProvider;
import org.eclipse.team.internal.ccvs.core.ICVSRepositoryLocation;
import org.eclipse.team.internal.ccvs.core.connection.CVSRepositoryLocation;
public class CVSTestSetup extends TestSetup {
public static final String REPOSITORY_LOCATION;
public static final boolean INITIALIZE_REPO;
public static final boolean DEBUG;
public static final boolean LOCAL_REPO;
public static final String RSH;
public static final int WAIT_FACTOR;
public static CVSRepositoryLocation repository;
// Static initializer for constants
static {
loadProperties();
REPOSITORY_LOCATION = System.getProperty("eclipse.cvs.repository");
INITIALIZE_REPO = Boolean.valueOf(System.getProperty("eclipse.cvs.initrepo", "false")).booleanValue();
DEBUG = Boolean.valueOf(System.getProperty("eclipse.cvs.debug", "false")).booleanValue();
RSH = System.getProperty("eclipse.cvs.rsh", "rsh");
LOCAL_REPO = Boolean.valueOf(System.getProperty("eclipse.cvs.localRepo", "false")).booleanValue();
WAIT_FACTOR = Integer.parseInt(System.getProperty("eclipse.cvs.waitFactor", "1"));
}
public static void loadProperties() {
String propertiesFile = System.getProperty("eclipse.cvs.properties");
if (propertiesFile == null) return;
File file = new File(propertiesFile);
if (file.isDirectory()) file = new File(file, "repository.properties");
try {
BufferedReader reader = new BufferedReader(new FileReader(file));
try {
for (String line; (line = reader.readLine()) != null; ) {
int sep = line.indexOf("=");
String property = line.substring(0, sep).trim();
String value = line.substring(sep + 1).trim();
System.setProperty("eclipse.cvs." + property, value);
}
} finally {
reader.close();
}
} catch (Exception e) {
System.err.println("Could not read repository properties file: " + file.getAbsolutePath());
}
}
/**
* Constructor for CVSTestSetup.
*/
public CVSTestSetup(Test test) {
super(test);
}
public static void executeRemoteCommand(ICVSRepositoryLocation repository, String commandLine) {
if (! LOCAL_REPO) {
commandLine = RSH + " " + repository.getHost() + " -l " + repository.getUsername() + " " + commandLine;
}
int returnCode = executeCommand(commandLine, null, null);
if (returnCode != -1 && returnCode != 0) {
System.err.println("Remote command returned " + returnCode + ": " + commandLine);
}
}
/**
* Executes a command.
* Returns the command's return code, or -1 on failure.
*
* @param commandLine the local command line to run
* @param environment the new environment variables, or null to inherit from parent process
* @param workingDirectory the new workingDirectory, or null to inherit from parent process
*/
public static int executeCommand(String commandLine, String[] environment, File workingDirectory) {
PrintStream debugStream = CVSTestSetup.DEBUG ? System.out : null;
try {
if (debugStream != null) {
// while debugging, dump CVS command line client results to stdout
// prefix distinguishes between message source stream
debugStream.println();
printPrefixedLine(debugStream, "CMD> ", commandLine);
if (workingDirectory != null) printPrefixedLine(debugStream, "DIR> ", workingDirectory.toString());
}
Process cvsProcess = Runtime.getRuntime().exec(commandLine, environment, workingDirectory);
// stream output must be dumped to avoid blocking the process or causing a deadlock
startBackgroundPipeThread(cvsProcess.getErrorStream(), debugStream, "ERR> ");
startBackgroundPipeThread(cvsProcess.getInputStream(), debugStream, "MSG> ");
int returnCode = cvsProcess.waitFor();
if (debugStream != null) debugStream.println("RESULT> " + returnCode);
return returnCode;
} catch (IOException e) {
printPrefixedLine(System.err, "Unable to execute command: ", commandLine);
e.printStackTrace(System.err);
} catch (InterruptedException e) {
printPrefixedLine(System.err, "Unable to execute command: ", commandLine);
e.printStackTrace(System.err);
}
return -1;
}
private static void startBackgroundPipeThread(final InputStream is, final PrintStream os,
final String prefix) {
new Thread() {
public void run() {
BufferedReader reader = null;
try {
try {
reader = new BufferedReader(new InputStreamReader(is));
for (;;) {
String line = reader.readLine();
if (line == null) break;
if (os != null) printPrefixedLine(os, prefix, line);
}
} finally {
if (reader != null) reader.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}.start();
}
private static void printPrefixedLine(PrintStream os, String prefix, String line) {
os.print(prefix);
os.println(line.substring(0, Math.min(line.length(), 256))); // trim long lines
}
/*
* Use rsh to delete any contents of the repository and initialize it again
*/
private static void initializeRepository(CVSRepositoryLocation repository) {
String repoRoot = repository.getRootDirectory();
executeRemoteCommand(repository, "rm -rf " + repoRoot);
executeRemoteCommand(repository, "cvs -d " + repoRoot + " init");
}
public void setUp() throws CVSException {
if (repository == null)
repository = setupRepository(REPOSITORY_LOCATION);
}
protected CVSRepositoryLocation setupRepository(String location) throws CVSException {
// Give some info about which repository the tests are running with
System.out.println("Connecting to: " + location);
// Validate that we can connect, also creates and caches the repository location. This
// is important for the UI tests.
CVSRepositoryLocation repository = (CVSRepositoryLocation)CVSProvider.getInstance().getRepository(location);
//CVSRepositoryLocation repository = CVSRepositoryLocation.fromString(location);
try {
repository.validateConnection(new NullProgressMonitor());
} catch (CVSException e) {
System.out.println("Unable to connect to remote repository: " + repository.getLocation());
throw e;
}
// Initialize the repo if requested (requires rsh access)
if( INITIALIZE_REPO ) {
initializeRepository(repository);
}
return repository;
}
public void tearDown() throws CVSException {
// Nothing to do here
}
}
|
