- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,124 for reprocess (0.08 sec)
-
src/os/exec_unix.go
) const ( // Special values for Process.Pid. pidUnset = 0 pidReleased = -1 ) func (p *Process) wait() (ps *ProcessState, err error) { // Which type of Process do we have? switch p.mode { case modeHandle: // pidfd return p.pidfdWait() case modePID: // Regular PID return p.pidWait() default: panic("unreachable") } } func (p *Process) pidWait() (*ProcessState, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 4.1K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/streams/ForwardStdinStreamsHandler.java
this.input = input; } @Override public void connectStreams(Process process, String processName, Executor executor) { this.executor = executor; /* There's a potential problem here in that DisconnectableInputStream reads from input in the background. This won't automatically stop when the process is over. Therefore, if input is not closed then this thread
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jul 11 16:06:58 UTC 2023 - 2.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/ProcessFixture.groovy
import org.gradle.internal.os.OperatingSystem import org.gradle.process.internal.streams.SafeStreams import org.gradle.test.fixtures.ConcurrentTestUtil class ProcessFixture { final Long pid; ProcessFixture(Long pid) { this.pid = pid } /** * Forcefully kills this daemon. */ void kill(boolean killTree) { println "Killing process with pid: $pid" if (pid == null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 5.6K bytes - Viewed (0) -
platforms/software/version-control/src/testFixtures/groovy/org/gradle/vcs/fixtures/GitHttpRepository.java
byte[] bytes = requestContent.toByteArray(); process.getOutputStream().write(bytes); process.getOutputStream().flush(); IOUtils.copy(process.getInputStream(), httpExchange.getResponseBody()); int result = process.waitFor(); if (result != 0) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Oct 11 12:16:09 UTC 2023 - 5.5K bytes - Viewed (0) -
guava/src/com/google/common/hash/AbstractStreamingHasher.java
/** Number of bytes to be filled before process() invocation(s). */ private final int bufferSize; /** Number of bytes processed per process() invocation. */ private final int chunkSize; /** * Constructor for use by subclasses. This hasher instance will process chunks of the specified * size. * * @param chunkSize the number of bytes available per {@link #process(ByteBuffer)} invocation; * must be at least 4
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Jun 15 20:59:00 UTC 2022 - 7.1K bytes - Viewed (0) -
src/syscall/exec_unix_test.go
if cpid2 == ppid { t.Fatalf("Parent and child 2 have the same process ID") } if cpgrp2 == ppgrp { t.Fatalf("Parent and child 2 are in the same process group") } if cpid2 == cpgrp2 { t.Fatalf("Child 2's process group is its process ID") } if cpid1 == cpid2 { t.Fatalf("Child 1 and 2 have the same process ID") } if cpgrp1 != cpgrp2 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 22 04:41:27 UTC 2024 - 7.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/streams/OutputStreamsForwarder.java
@Override public void connectStreams(Process process, String processName, Executor executor) { this.executor = executor; standardOutputReader = new ExecOutputHandleRunner("read standard output of " + processName, process.getInputStream(), standardOutput, completed); if (readErrorStream) { standardErrorReader = new ExecOutputHandleRunner("read error output of " + processName, process.getErrorStream(), errorOutput, completed);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jul 11 16:06:58 UTC 2023 - 3.2K bytes - Viewed (0) -
src/syscall/exec_windows_test.go
} func TestChangingProcessParent(t *testing.T) { if os.Getenv("GO_WANT_HELPER_PROCESS") == "parent" { // in parent process // Parent does nothing. It is just used as a parent of a child process. time.Sleep(time.Minute) os.Exit(0) } if os.Getenv("GO_WANT_HELPER_PROCESS") == "child" { // in child process dumpPath := os.Getenv("GO_WANT_HELPER_PROCESS_FILE") if dumpPath == "" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 3.1K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/testing/internal/util/GradlewRunner.java
} })); forwardAsync(process.getInputStream(), System.out); forwardAsync(process.getErrorStream(), System.err); process.waitFor(); } catch (IOException e) { e.printStackTrace(); } catch (InterruptedException e) { e.printStackTrace(); process.destroy(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 12 10:33:12 UTC 2024 - 3.1K bytes - Viewed (0) -
platforms/software/antlr/src/main/java/org/gradle/api/plugins/antlr/internal/antlr2/MetadataExtracter.java
import java.io.FileNotFoundException; import java.io.FileReader; import java.io.IOException; import java.io.Reader; import java.util.Set; import java.util.regex.Matcher; import java.util.regex.Pattern; /** * Preprocess an Antlr grammar file so that dependencies between grammars can be properly determined such that they can * be processed for generation in proper order later. */ public class MetadataExtracter {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 14 14:52:10 UTC 2023 - 3.8K bytes - Viewed (0)