Searched refs:executor (Results 1 - 25 of 26) sorted by relevance

12

/opengrok-jel/src/org/opensolaris/opengrok/history/
H A DSCCSget.java46 Executor executor = new Executor(argv);
47 if (executor.exec() == 0) {
48 ret = executor.getOutputStream();
H A DPerforceRepository.java90 Executor executor = new Executor(cmd, file.getParentFile());
91 executor.exec();
93 BufferedReader reader = new BufferedReader(executor.getOutputReader());
130 Executor executor = new Executor(cmd, new File(parent));
131 executor.exec();
132 return new ByteArrayInputStream(executor.getOutputString().getBytes());
146 Executor executor = new Executor(cmd, directory);
147 if (executor.exec() != 0) {
148 throw new IOException(executor.getErrorString());
186 Executor executor
[all...]
H A DAccuRevRepository.java112 Executor executor = new Executor(cmd, file.getParentFile());
113 executor.exec();
114 BufferedReader reader = new BufferedReader(executor.getOutputReader());
139 * Get an executor to be used for retrieving the history log for the given
188 Executor executor = new Executor(cmd, directory);
189 executor.exec();
191 BufferedReader info = new BufferedReader(executor.getOutputReader());
209 executor = new Executor(cmd, directory);
210 executor.exec();
212 inputStream = new ByteArrayInputStream(executor
[all...]
H A DMonotoneRepository.java119 * Get an executor to be used for retrieving the history log for the given
173 Executor executor = new Executor(cmd, directory);
174 if (executor.exec() != 0) {
175 throw new IOException(executor.getErrorString());
181 in = new BufferedReader(executor.getOutputReader());
223 Executor executor = new Executor(cmd, directory);
224 if (executor.exec() != 0) {
225 throw new IOException(executor.getErrorString());
232 executor = new Executor(cmd, directory);
233 if (executor
[all...]
H A DRepoRepository.java77 Executor executor = new Executor(cmd, directory);
78 if (executor.exec() != 0) {
79 throw new IOException(executor.getErrorString());
H A DAccuRevHistoryParser.java73 Executor executor = repository.getHistoryLogExecutor(file);
74 executor.exec(true, this);
77 executor = repository.getHistoryLogExecutor(file);
78 executor.exec(true, this);
H A DBazaarRepository.java64 * Get an executor to be used for retrieving the history log for the
229 Executor executor = new Executor(cmd, directory);
230 if (executor.exec() != 0) {
231 throw new IOException(executor.getErrorString());
234 if (executor.getOutputString().indexOf("parent branch:") != -1) {
238 executor = new Executor(cmd, directory);
239 if (executor.exec() != 0) {
240 throw new IOException(executor.getErrorString());
H A DPerforceHistoryParser.java81 Executor executor = new Executor(cmd, file.getCanonicalFile());
82 executor.exec();
83 return parseChanges(executor.getOutputReader());
92 Executor executor =
94 executor.exec();
96 return parseFileLog(executor.getOutputReader());
H A DSubversionRepository.java126 Executor executor = new Executor(cmd, directory);
127 if (executor.exec() == 0) {
132 Document document = builder.parse(executor.getOutputStream());
174 * Get an executor to be used for retrieving the history log for the
238 Executor executor = new Executor(cmd, directory);
239 if (executor.exec() == 0) {
240 ret = executor.getOutputStream();
415 Executor executor = new Executor(cmd, directory);
416 if (executor.exec() != 0) {
417 throw new IOException(executor
[all...]
H A DClearCaseHistoryParser.java48 Executor executor = repository.getHistoryLogExecutor(file);
49 int status = executor.exec(true, this);
H A DMercurialRepository.java234 * Get an executor to be used for retrieving the history log for the
240 * @param changeset the oldest changeset to return from the executor,
468 Executor executor = new Executor(cmd, directory);
469 if (executor.exec() != 0) {
470 throw new IOException(executor.getErrorString());
473 if (executor.getOutputString().indexOf("paths.default=") != -1) {
478 executor = new Executor(cmd, directory);
479 if (executor.exec() != 0) {
480 throw new IOException(executor.getErrorString());
H A DBazaarHistoryParser.java60 Executor executor = repository.getHistoryLogExecutor(file, sinceRevision);
61 int status = executor.exec(true, this);
H A DCVSHistoryParser.java134 Executor executor = repository.getHistoryLogExecutor(file);
135 int status = executor.exec(true, this);
H A DMonotoneHistoryParser.java75 Executor executor = repository.getHistoryLogExecutor(file, changeset);
76 int status = executor.exec(true, this);
H A DCVSRepository.java114 Executor executor = new Executor(cmd, directory);
115 if (executor.exec() != 0) {
116 throw new IOException(executor.getErrorString());
123 * Get an executor to be used for retrieving the history log for the
H A DGitRepository.java259 * Get an executor to be used for retrieving the history log for the
504 Executor executor = new Executor(cmd, directory);
505 if (executor.exec() != 0) {
506 throw new IOException(executor.getErrorString());
509 if (executor.getOutputString().indexOf("remote.origin.url=") != -1) {
515 if (executor.exec() != 0) {
516 throw new IOException(executor.getErrorString());
H A DMercurialHistoryParser.java76 Executor executor = repository.getHistoryLogExecutor(file, changeset);
77 int status = executor.exec(true, this);
H A DSubversionHistoryParser.java159 Executor executor = repos.getHistoryLogExecutor(file, sinceRevision);
160 int status = executor.exec(true, this);
H A DGitHistoryParser.java209 Executor executor =
211 int status = executor.exec(true, this);
H A DHistoryGuru.java598 ExecutorService executor = Executors.newFixedThreadPool(num);
610 executor.submit(new Runnable() {
618 executor.shutdown();
619 while (!executor.isTerminated()) {
622 executor.awaitTermination(999, TimeUnit.DAYS);
624 logger.warning("Received interrupt while waiting for executor to finish: "
/opengrok-jel/src/org/opensolaris/opengrok/web/
H A DSearchHelper.java125 private ExecutorService executor = null; field in class:SearchHelper
192 executor= Executors.newFixedThreadPool(noThreads);
195 ? new IndexSearcher(searchables,executor)
424 if (executor != null) {
426 executor.shutdown();
/opengrok-jel/test/org/opensolaris/opengrok/index/
H A DIndexerTest.java315 Executor executor;
317 executor = new Executor(new String[] { "mkdir", "-p",
319 executor.exec(true);
321 executor = new Executor(new String[] { "mkfifo",
323 executor.exec(true);
/opengrok-jel/src/org/opensolaris/opengrok/configuration/
H A DRuntimeEnvironment.java129 Executor executor = new Executor(new String[] {
132 executor.exec(false);
133 String output = executor.getOutputString();
/opengrok-jel/src/org/opensolaris/opengrok/index/
H A DIndexDatabase.java129 * @param executor An executor to run the job
132 public static void updateAll(ExecutorService executor) throws IOException { argument
133 updateAll(executor, null);
138 * @param executor An executor to run the job
142 static void updateAll(ExecutorService executor, IndexChangedListener listener) argument
162 executor.submit(new Runnable() {
179 * @param executor An executor t
183 update(ExecutorService executor, IndexChangedListener listener, List<String> paths) argument
427 optimizeAll(ExecutorService executor) argument
[all...]
H A DIndexer.java766 ExecutorService executor = Executors.newFixedThreadPool(noThreads);
770 IndexDatabase.updateAll(executor, progress);
772 IndexDatabase.optimizeAll(executor);
806 executor.submit(new Runnable() {
827 executor.shutdown();
828 while (!executor.isTerminated()) {
831 executor.awaitTermination(999,TimeUnit.DAYS);
833 log.warning("Received interrupt while waiting for executor to finish: "

Completed in 33 milliseconds

12