waitFor - Code Search

src/test/java/org/codelibs/fess/job/PythonJobTest.java

        private final int exitValue;

        public TestProcess(int exitValue) {
            this.exitValue = exitValue;
        }

        @Override
        public int waitFor() throws InterruptedException {
            return exitValue;
        }

        @Override
        public int exitValue() {
            return exitValue;
        }

        @Override

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Mar 13 23:01:26 GMT 2026

- 22.2K bytes

- Click Count (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/job/SuggestJobTest.java

        private final int exitValue;

        public MockProcess(int exitValue) {
            this.exitValue = exitValue;
        }

        @Override
        public int waitFor() {
            return exitValue;
        }

        @Override
        public int exitValue() {
            return exitValue;
        }

        @Override
        public void destroy() {

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Mar 13 23:01:26 GMT 2026

- 31.6K bytes

- Click Count (0)

github.com/gradle/gradle

.teamcity/scripts/CheckWrapper.java

        Process p = pb.start();
        Future<String> outFuture = readStreamAsync(p.getInputStream());
        Future<String> errFuture = readStreamAsync(p.getErrorStream());
        int code = p.waitFor();
        String out = outFuture.get();
        String err = errFuture.get();
        return new ExecResult(code, out, err);
    }

    private static Future<String> readStreamAsync(InputStream inputStream) {

Created: Wed Apr 01 11:36:16 GMT 2026

- Last Modified: Tue Jan 20 03:53:25 GMT 2026

- 6.4K bytes

- Click Count (0)

github.com/gradle/gradle

.teamcity/scripts/FindCommits.java

        ProcessBuilder pb = new ProcessBuilder(cmd);
        Process p = pb.start();
        String out = readFully(p.getInputStream());
        String err = readFully(p.getErrorStream());
        int code = p.waitFor();
        return new ExecResult(code, out, err);
    }

    private static String readFully(InputStream in) throws IOException {

Created: Wed Apr 01 11:36:16 GMT 2026

- Last Modified: Tue Jan 20 03:53:25 GMT 2026

- 5.5K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/job/PythonJob.java

            });

            final InputStreamThread it = jobProcess.getInputStreamThread();
            it.start();

            final Process currentProcess = jobProcess.getProcess();
            currentProcess.waitFor();
            it.join(5000);

            final int exitValue = currentProcess.exitValue();

            if (logger.isInfoEnabled()) {

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Thu Jul 17 08:28:31 GMT 2025

- 8.2K bytes

- Click Count (0)

github.com/elastic/elasticsearch

build-tools-internal/src/main/groovy/org/elasticsearch/gradle/internal/test/AntFixture.groovy

            realArgs.each { arg(value: it) }
        }

        String failedProp = "failed${name}"
        // first wait for resources, or the failure marker from the wrapper script
        ant.waitfor(maxwait: maxWaitInSeconds, maxwaitunit: 'second', checkevery: '500', checkeveryunit: 'millisecond', timeoutproperty: failedProp) {
            or {
                resourceexists {

Created: Wed Apr 08 16:19:15 GMT 2026

- Last Modified: Tue Jun 01 09:19:30 GMT 2021

- 10.1K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/job/SuggestJob.java

            });

            final InputStreamThread it = jobProcess.getInputStreamThread();
            it.start();

            final Process currentProcess = jobProcess.getProcess();
            currentProcess.waitFor();
            it.join(5000);

            final int exitValue = currentProcess.exitValue();

            if (logger.isInfoEnabled()) {

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Nov 28 16:29:12 GMT 2025

- 10.5K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

            });

            final InputStreamThread it = jobProcess.getInputStreamThread();
            it.start();

            final Process currentProcess = jobProcess.getProcess();
            currentProcess.waitFor();
            it.join(5000);

            final int exitValue = currentProcess.exitValue();

            if (logger.isInfoEnabled()) {

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Nov 28 16:29:12 GMT 2025

- 11.7K bytes

- Click Count (0)

github.com/gradle/gradle

build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java

            ByteArrayOutputStream stdout = connectStream(process.getInputStream(), latch);
            ByteArrayOutputStream stderr = connectStream(process.getErrorStream(), latch);

            process.waitFor(1, TimeUnit.MINUTES);
            latch.await(1, TimeUnit.MINUTES);
            return new ExecResult(args, process.exitValue(), stdout.toString(UTF_8), stderr.toString(UTF_8));
        } catch (Exception e) {

Created: Wed Apr 01 11:36:16 GMT 2026

- Last Modified: Tue Sep 23 13:49:45 GMT 2025

- 12K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/auth/chain/CommandChain.java

            mt.start();

            final InputStreamThread it = new InputStreamThread(currentProcess.getInputStream(), commandOutputEncoding, maxOutputLine);
            it.start();

            currentProcess.waitFor();
            it.join(5000);

            if (mt.isTeminated()) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Command execution timeout for user: username={}", username);

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Nov 28 16:29:12 GMT 2025

- 14.4K bytes

- Click Count (0)

Search Options