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
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
|
import java.io.File;
import java.io.PrintStream;
import java.io.FileOutputStream;
import java.io.BufferedReader;
import java.io.FileReader;
import java.lang.reflect.Constructor;
import java.lang.reflect.Method;
import java.util.StringTokenizer;
public class JRIBootstrap {
//--- global constants ---
public static final int HKLM = 0; // HKEY_LOCAL_MACHINE
public static final int HKCU = 1; // HKEY_CURRENT_USER
//--- native methods ---
public static native String getenv(String var);
public static native void setenv(String var, String val);
public static native String regvalue(int root, String key, String value);
public static native String[] regsubkeys(int root, String key);
public static native String expand(String val);
public static native boolean hasreg();
public static native String arch();
//--- helper methods ---
static void fail(String msg) {
System.err.println("ERROR: "+msg);
System.exit(1);
}
public static String findInPath(String path, String fn, boolean mustBeFile) {
StringTokenizer st = new StringTokenizer(path, File.pathSeparator);
while (st.hasMoreTokens()) {
String dirname=st.nextToken();
try {
File f = new File(dirname+File.separator+fn);
System.out.println(" * "+f+" ("+f.exists()+", "+f.isFile()+")");
if (f.exists() && (!mustBeFile || f.isFile())) return f.getPath();
} catch (Exception fex) {}
}
return null;
}
// set ONLY after findR was run
public static boolean isWin32 = false;
public static boolean isMac = false;
static String findR(boolean findAllSettings) {
String ip = null;
try {
if (hasreg()) {
isWin32 = true;
int rroot = HKLM;
System.out.println("has registry, trying to find R");
ip = regvalue(HKLM, "SOFTWARE\\R-core\\R","InstallPath");
if (ip == null)
ip = regvalue(rroot=HKCU, "SOFTWARE\\R-core\\R","InstallPath");
if (ip == null) {
System.out.println(" - InstallPath not present (possibly uninstalled R)");
String[] vers = regsubkeys(rroot=HKLM, "SOFTWARE\\R-core\\R");
if (vers == null)
vers = regsubkeys(rroot=HKCU, "SOFTWARE\\R-core\\R");
if (vers!=null) {
String lvn = ""; // FIXME: we compare versions lexicographically which may fail if we really reach R 2.10
int i = 0; while (i<vers.length) {
if (vers[i] != null && lvn.compareTo(vers[i]) < 0)
lvn = vers[i];
i++;
}
if (!lvn.equals(""))
ip = regvalue(rroot, "SOFTWARE\\R-core\\R\\"+lvn, "InstallPath");
}
}
if (ip == null) {
ip = getenv("R_HOME");
if (ip==null || ip.length()<1) ip = getenv("RHOME");
if (ip==null || ip.length()<1) ip=null;
}
if (ip != null) rs_home = ip;
return ip;
}
isMac = System.getProperty("os.name").startsWith("Mac");
File f = null;
ip = getenv("R_HOME");
if (ip == null || ip.length()<1)
ip = getenv("RHOME");
if (ip == null || ip.length()<1) {
if (isMac) {
f=new File("/Library/Frameworks/R.framework/Resources/bin/R");
if (!f.exists())
f=new File(getenv("HOME")+"/Library/Frameworks/R.framework/Resources/bin/R");
if (!f.exists())
f=null;
}
if (f==null) {
String fn = findInPath(getenv("PATH"), "R", true);
if (fn == null)
fn = findInPath("/usr/bin:/usr/local/bin:/sw/bin:/opt/bin:/usr/lib/R/bin:/usr/local/lib/R/bin", "R", true);
if (fn != null) f = new File(fn);
}
if (!findAllSettings) {
String s = f.getAbsolutePath();
if (s.length()>6) ip = s.substring(0, s.length()-6);
}
}
if (findAllSettings) {
if (f==null && ip!=null) f=new File(u2w(ip+"/bin/R"));
if (f!=null) ip = getRSettings(f.getAbsolutePath());
}
} catch (Exception e) {
}
return ip;
}
public static String rs_home = "";
public static String rs_arch = "";
public static String rs_docdir = "";
public static String rs_incdir = "";
public static String rs_sharedir = "";
public static String rs_ldp = "";
public static String rs_dyldp = "";
public static String rs_unzip = "";
public static String rs_latex = "";
public static String rs_paper = "";
public static String rs_print = "";
public static String rs_libs = "";
public static void setREnv() {
if (rs_home!=null && rs_home.length()>0) setenv("R_HOME", rs_home);
if (rs_arch!=null && rs_arch.length()>0) setenv("R_ARCH", rs_arch);
if (rs_docdir!=null && rs_docdir.length()>0) setenv("R_DOC_DIR", rs_docdir);
if (rs_incdir!=null && rs_incdir.length()>0) setenv("R_INCLUDE_DIR", rs_incdir);
if (rs_sharedir!=null && rs_sharedir.length()>0) setenv("R_SHARE_DIR", rs_sharedir);
if (rs_ldp!=null && rs_ldp.length()>0) setenv("LD_LIBRARY_PATH", rs_ldp);
if (rs_dyldp!=null && rs_dyldp.length()>0) setenv("DYLD_LIBRARY_PATH", rs_dyldp);
if (rs_libs!=null && rs_libs.length()>0) setenv("R_LIBS", rs_libs);
}
public static int execR(String cmd) {
try {
String binR = u2w(rs_home+"/bin/R");
if (isWin32) {
binR+=".exe";
File fin = File.createTempFile("rboot",".R");
File fout = File.createTempFile("rboot",".tmp");
PrintStream p = new PrintStream(new FileOutputStream(fin));
p.println(cmd);
p.close();
Process rp = Runtime.getRuntime().exec(new String[] {
binR,"CMD","BATCH","--no-restore","--no-save","--slave",fin.getAbsolutePath(),
fout.getAbsolutePath()});
int i = rp.waitFor();
if (!fin.delete()) fin.deleteOnExit();
if (!fout.delete()) fout.deleteOnExit();
return i;
} else {
Process rp = Runtime.getRuntime().exec(new String[] {
"/bin/sh","-c","echo \""+cmd+"\" |"+binR+" --no-restore --no-save --slave >/dev/null 2>&1" });
return rp.waitFor();
}
} catch (Exception e) {
lastError = e.toString();
return -1;
}
}
public static String getRSettings(String binR) {
try {
File fin = File.createTempFile("rboot",".R");
File fout = File.createTempFile("rboot",".tmp");
PrintStream p = new PrintStream(new FileOutputStream(fin));
p.println("cat(unlist(lapply(c('R_HOME','R_ARCH','R_DOC_DIR','R_INCLUDE_DIR','R_SHARE_DIR','LD_LIBRARY_PATH','DYLD_LIBRARY_PATH','R_UNZIPCMD','R_LATEXCMD','R_PAPERSIZE','R_PRINTCMD'),Sys.getenv)),sep='\n')");
p.println("cat(paste(.libPaths(),collapse=.Platform$path.sep),'\n',sep='')");
p.close();
Process rp = Runtime.getRuntime().exec(new String[] {
"/bin/sh","-c",binR+" --no-restore --no-save --slave < \""+fin.getAbsolutePath()+"\" > \""+fout.getAbsolutePath()+"\"" });
int i = rp.waitFor();
System.out.println("getRSettings, i="+i);
BufferedReader r = new BufferedReader(new FileReader(fout));
rs_home = r.readLine();
rs_arch = r.readLine();
rs_docdir = r.readLine();
rs_incdir = r.readLine();
rs_sharedir = r.readLine();
rs_ldp = r.readLine();
rs_dyldp = r.readLine();
rs_unzip = r.readLine();
rs_latex = r.readLine();
rs_paper = r.readLine();
rs_print = r.readLine();
rs_libs = r.readLine();
r.close();
if (!fin.delete()) fin.deleteOnExit();
//if (!fout.delete()) fout.deleteOnExit();
System.out.println(" - retrieved R settings, home: "+rs_home+" (arch="+rs_arch+", libs="+rs_libs+")");
} catch (Exception e) {
System.err.println("Failed to get R settings: "+e);
}
return rs_home;
}
public static String u2w(String fn) {
return (java.io.File.separatorChar != '/')?fn.replace('/',java.io.File.separatorChar):fn;
}
public static Object bootRJavaLoader = null;
public static Object getBootRJavaLoader() {
System.out.println("JRIBootstrap.bootRJavaLoader="+bootRJavaLoader);
return bootRJavaLoader;
}
static void addClassPath(String s) {
if (bootRJavaLoader==null) return;
try {
Method m = bootRJavaLoader.getClass().getMethod("addClassPath", new Class[] { String.class });
m.invoke(bootRJavaLoader, new Object[] { s });
} catch (Exception e) {
System.err.println("FAILED: JRIBootstrap.addClassPath");
}
}
static String lastError = "";
static String findPackage(String name) {
String pd = null;
if (rs_libs!=null && rs_libs.length()>0)
pd = findInPath(rs_libs, name, false);
if (pd == null) {
pd = u2w(rs_home+"/library/"+name);
if (!(new File(pd)).exists()) pd = null;
}
return pd;
}
static Object createRJavaLoader(String rhome, String[] cp, boolean addJRI) {
String rJavaRoot = null;
if (rs_libs!=null && rs_libs.length()>0)
rJavaRoot = findInPath(rs_libs, "rJava", false);
if (rJavaRoot == null)
rJavaRoot = u2w(rhome+"/library/rJava");
if (!(new File(rJavaRoot)).exists()) {
lastError="Unable to find rJava";
return null;
}
File f = new File(u2w(rJavaRoot+"/java/boot"));
if (!f.exists()) {
// try harder ...
lastError = "rJava too old";
return null;
}
String rJavaHome = u2w(rJavaRoot);
File lf = null;
if (rs_arch!=null && rs_arch.length()>0) lf = new File(u2w(rJavaRoot+"/libs"+rs_arch));
if (lf == null || !lf.exists()) lf = new File(u2w(rJavaRoot+"/libs/"+arch()));
if (!lf.exists()) lf = new File(u2w(rJavaRoot+"/libs"));
String rJavaLibs = lf.toString();
JRIClassLoader mcl = JRIClassLoader.getMainLoader();
mcl.addClassPath(f.toString()); // add rJava boot to primary CP
try {
// force the use of the MCL even if the system loader could find it
Class rjlclass = mcl.findAndLinkClass("RJavaClassLoader");
Constructor c = rjlclass.getConstructor(new Class[] { String.class, String.class });
Object rjcl = c.newInstance(new Object[] { rJavaHome, rJavaLibs });
System.out.println("RJavaClassLoader: "+rjcl);
if (addJRI) {
if (cp==null || cp.length==0)
cp = new String[] { u2w(rJavaRoot+"/jri/JRI.jar") };
else {
String[] ncp = new String[cp.length+1];
System.arraycopy(cp, 0, ncp, 1, cp.length);
ncp[0] = u2w(rJavaRoot+"/jri/JRI.jar");
cp = ncp;
}
}
if (cp==null || cp.length==0)
cp = new String[] { u2w(rJavaRoot+"/java/boot") };
else {
String[] ncp = new String[cp.length+1];
System.arraycopy(cp, 0, ncp, 1, cp.length);
ncp[0] = u2w(rJavaRoot+"/java/boot");
cp = ncp;
}
if (cp != null) {
System.out.println(" - adding class paths");
Method m = rjlclass.getMethod("addClassPath", new Class[] { String[].class });
m.invoke(rjcl, new Object[] { cp });
}
return rjcl;
} catch (Exception rtx) {
System.err.println("ERROR: Unable to create new RJavaClassLoader in JRIBootstrap! ("+rtx+")");
rtx.printStackTrace();
System.exit(2);
}
return null;
}
//--- main bootstrap method ---
public static void bootstrap(String[] args) {
System.out.println("JRIBootstrap("+args+")");
try {
System.loadLibrary("boot");
} catch (Exception e) {
fail("Unable to load boot library!");
}
// just testing from now on
String rhome = findR(true);
if (rhome == null) fail("Unable to find R!");
if (isWin32) {
String path = getenv("PATH");
if (path==null || path.length()<1) path=rhome+"\\bin";
else path=rhome+"\\bin;"+path;
setenv("PATH",path);
}
setREnv();
System.out.println("PATH="+getenv("PATH")+"\nR_LIBS="+getenv("R_LIBS"));
if (!isMac && !isWin32) {
String stage = System.getProperty("stage");
if (stage==null || stage.length()<1) {
File jl = new File(u2w(System.getProperty("java.home")+"/bin/java"));
if (jl.exists()) {
try {
System.out.println(jl.toString()+" -cp "+System.getProperty("java.class.path")+" -Xmx512m -Dstage=2 Boot");
Process p = Runtime.getRuntime().exec(new String[] {
jl.toString(), "-cp", System.getProperty("java.class.path"),
"-Xmx512m", "-Dstage=2", "Boot" });
System.out.println("Started stage 2 ("+p+"), waiting for it to finish...");
System.exit(p.waitFor());
} catch (Exception re) {
}
}
}
}
String needPkg = null;
String rj = findPackage("rJava");
if (rj == null) {
System.err.println("**ERROR: rJava is not installed");
if (needPkg==null) needPkg="'rJava'"; else needPkg+=",'rJava'";
}
String ipl = findPackage("iplots");
if (ipl == null) {
System.err.println("**ERROR: iplots is not installed");
if (needPkg==null) needPkg="'iplots'"; else needPkg+=",'iplots'";
}
String jgr = findPackage("JGR");
if (jgr == null) {
System.err.println("**ERROR: JGR is not installed");
if (needPkg==null) needPkg="'JGR'"; else needPkg+=",'JGR'";
}
if (needPkg != null) {
if (!isWin32 && !isMac) {
System.err.println("*** Please run the following in R as root to install missing packages:\n install.packages(c("+needPkg+"),,'http://www.rforge.net/')");
System.exit(4);
}
if (execR("install.packages(c("+needPkg+"),,c('http://www.rforge.net/','http://cran.r-project.org'))")!=0) {
System.err.println("*** ERROR: failed to install necessary packages");
System.exit(4);
}
rj = findPackage("rJava");
ipl = findPackage("iplots");
jgr = findPackage("JGR");
if (rj==null || ipl==null || jgr==null) {
System.err.println("*** ERROR: failed to find installed packages");
System.exit(5);
}
}
Object o = bootRJavaLoader = createRJavaLoader(rhome, new String[] { "main" }, true);
addClassPath(u2w(jgr+"/cont/JGR.jar"));
addClassPath(u2w(ipl+"/cont/iplots.jar"));
String mainClass = "org.rosuda.JGR.JGR";
try {
Method m = o.getClass().getMethod("bootClass", new Class[] { String.class, String.class, String[].class });
m.invoke(o, new Object[] { mainClass, "main", args });
} catch(Exception ie) {
System.out.println("cannot boot the final class: "+ie);
ie.printStackTrace();
}
}
public static void main(String[] args) {
System.err.println("*** WARNING: JRIBootstrap.main should NOT be called directly, it is intended for debugging use ONLY. Use Boot wrapper instead.");
// just for testing
bootstrap(args);
}
}
|
