Laboratoire ICAR » Plateforme TXM

		try {

			Log.fine(RCoreMessages.bind(RCoreMessages.info_connectingToRAt, host, port));

			connection = new RConnection(host, port);

			return isConnected();

		}

		catch (RserveException x) {

			Log.fine(TXMCoreMessages.bind(RCoreMessages.info_connectingToRAtWithUser, new Object[] { host, port, user }));

			connection = new RConnection(host, port);

			connection.login(user, password);

			return isConnected();

		}

			// TODO: this method uses the right directory ?

			// Bundle bundle = FrameworkUtil.getBundle(RWorkspace.class);

			// File userdir = new File(bundle.getLocation());

			// System.out.println("BUNDLE LOCATION OF '" + bundle.getSymbolicName() + "': " + userDir);

			workspace = new RWorkspace(userDir);

		}

	 * @throws StatException the stat exception

	 */

	public File plot(File file, String expr) throws REXPMismatchException, StatException, RserveException {

	}

	/**

			String path;

			if (OSDetector.isFamilyWindows()) {

			}

			else {

				path = file.getAbsolutePath();

			}

			// FIXME : test for window dimensions so the large plots can be entirely displayed. Need to pass width and height to RWorkspace.plot() so

			// RChartsEngine will be able to dynamically compute the width from the number of bars in a barplot for example.

		}

		catch (RserveException e) {

			RWorkspace.printLastSafeEvalExpr();

		}

		catch (Exception e) {

			throw new RException(e.getMessage()+ "; " +exp.trim(), e); //$NON-NLS-1$

	public void initializeRWorkspaceConnectionConfiguration(SystemProxyDetector conf) throws RserveException {

		// reduce time out

		this.getConnection().eval("options(timeout = 3);"); //$NON-NLS-1$

		// configure the HTTP proxy

		if (conf.isSystemProxyDetected()) {

			String proxyUrl = conf.getHttpProxyUrl();

			this.getConnection().eval("Sys.setenv(http_proxy=\"" + proxyUrl + "\")"); //$NON-NLS-1$ //$NON-NLS-2$

		}

	}

				System.out.println("TXM R workspace directory not found: " + userdir);

			}

			else {

				connection.eval("setwd(\"" + userdir.getAbsolutePath().replace("\\", "/") + "\")"); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ //$NON-NLS-4$

			}

			// set the libraries directory to install new R packages

			RLibrariesWorkspaceDirectory.mkdir();

			if (!RLibrariesWorkspaceDirectory.exists()) {

				System.out.println("TXM R libraries workspace directory not found: " + RLibrariesWorkspaceDirectory);

			}

			else {

				connection.eval(".libPaths(c(\"" + RLibrariesWorkspaceDirectory.getAbsolutePath().replace("\\", "/") + "\",.libPaths()))");//$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$ //$NON-NLS-4$

			}

			// set the default R repository

			String repos = RPreferences.getInstance().getString(RPreferences.DEFAULT_REPOS);

			if (repos.length() > 0) {

				connection.eval("options(repos=\"" + repos + "\")");//$NON-NLS-1$ //$NON-NLS-2$

			}

		}

		lastSafeevalExpr = expr;

		if (isLoggingEvalCommandLines()) {

			// TODO SJ: for debuggin puprose

			throw e;//new RException(expr, e.getMessage());

		}

		finally {

				throw new RException(expr, r.asString());

			}

		}

			if (ret instanceof org.rosuda.REngine.REXPString) {

				if (ret.isVector()) {

				}

				else {

				}

			}

			else if (ret instanceof org.rosuda.REngine.REXPDouble) {

				if (ret.isVector()) {

				}

				else {

				}

			}

			else if (ret instanceof org.rosuda.REngine.REXPInteger) {

				if (ret.isVector()) {

				}

				else {

				}

			}

			else if (ret instanceof org.rosuda.REngine.REXPNull) {

			}

			else {

			}

		}

	 */

	public static final String SHOW_EVAL_LOGS = "show_eval_logs"; //$NON-NLS-1$

	/**

		Preferences preferences = this.getDefaultPreferencesNode();

		String saved = this.getString(RPreferences.VERSION);

		Version currentVersion = BundleUtils.getBundleVersion(RFRAGMENT); // the RFRAGMENT plugin contains the right version

		String os = ""; //$NON-NLS-1$

		String ext = ""; //$NON-NLS-1$

		String osName = System.getProperty("os.name").toLowerCase(); //$NON-NLS-1$

		if (osName.contains("windows")) { //$NON-NLS-1$

			os = "win32"; //$NON-NLS-1$

			ext = ".exe"; //$NON-NLS-1$

		}

		else if (osName.contains("mac")) { //$NON-NLS-1$

		File rRootDir = new File(rpluginDir, os);

		File execFile = new File(rRootDir, "bin/" + extraSubPath + "R" + ext); //$NON-NLS-1$ //$NON-NLS-2$

		File execFile2 = new File(rRootDir, "bin/exec/" + extraSubPath + "R" + ext); //$NON-NLS-1$ //$NON-NLS-2$

			execFile2 = new File(rRootDir, "bin/x64/" + extraSubPath + "R" + ext); //$NON-NLS-1$ //$NON-NLS-2$

		}

		if (!execFile.canExecute() && !execFile.setExecutable(true)) { // first test if file is executable then try setting it executable

			return;

		}

		preferences.put(PATH_TO_EXECUTABLE, execFile.getAbsolutePath());

		preferences.putBoolean(IS_MANDATORY, false);

		preferences.putBoolean(REMOTE, false);

		preferences.putBoolean(DISABLE, false);

		preferences.putBoolean(DEBUG, false);

		preferences.putBoolean(FILE_TRANSFERT, false);

		preferences.putBoolean(SHOW_EVAL_LOGS, false);

		if (saved != null && saved.length() > 0) {

		try {

			// // cut nlines

			if (before != after) {

			}

			else {

			}

			// getRowNames().cut(before, after);

			// this.nrow = nlines;

						values[i-1] = 0;

					}

				}

			}

			rw.addVectorToWorkspace("tmprownames", rownames.toArray(new String[rownames.size()])); //$NON-NLS-1$

			rw.voidEval(symbol + "<- tmpmat;"); //$NON-NLS-1$

			//rw.voidEval("rm(tmpmat);"); //$NON-NLS-1$

				Log.finer(TXMCoreMessages.bind("Registering R transformer: {0}...", transformer));

			}

			catch (Exception e) {

				e.printStackTrace();

			}

		}

			try {

				if (StartRserve.rProcess != null) {

					StartRserve.rProcess.destroy();

				}

			}

					File f = new File(execName);

					// only use taskkill if the process is running

					//String cmd = "cmd /c FOR /F \"tokens=5 delims= \" %P IN ('netstat -ano ^| findstr :6330 ^| findstr LISTENING') DO taskkill /F /PID %P"; //$NON-NLS-1$

					Process p = Runtime.getRuntime().exec(cmd);

					// consumes streams

					StreamHog errStream = new StreamHog(p.getErrorStream(), true);

					StreamHog inStream = new StreamHog(p.getInputStream(), true);

					p.waitFor();

					started = false;

					try {

						String cmd = NLS.bind("cmd /c FOR /F \"tokens=5 delims= \" %P IN (''netstat -ano ^| findstr :{0} ^| findstr LISTENING'') DO tskill %P", RPreferences.getInstance().getInt(RPreferences.PORT)); //$NON-NLS-1$

						Process p = Runtime.getRuntime().exec(

								//"tskill Rserve.exe"); //$NON-NLS-1$

	@Override

	public String getName() {

	}

}