- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 87 for subprocess (0.14 sec)
-
src/main/java/org/codelibs/fess/job/PythonJob.java
if (logger.isInfoEnabled()) { logger.info("Python: \nDirectory={}\nOptions={}", baseDir, cmdList); } final JobProcess jobProcess = processHelper.startProcess(sessionId, cmdList, pb -> { pb.directory(baseDir); pb.redirectErrorStream(true); final Map<String, String> environment = pb.environment();
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 5.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java
} final JobProcess jobProcess = processHelper.startProcess(sessionId, cmdList, pb -> { pb.directory(baseDir); pb.redirectErrorStream(true); }); final InputStreamThread it = jobProcess.getInputStreamThread(); it.start(); final Process currentProcess = jobProcess.getProcess(); currentProcess.waitFor();
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 10.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/SuggestJob.java
} final JobProcess jobProcess = processHelper.startProcess(sessionId, cmdList, pb -> { pb.directory(baseDir); pb.redirectErrorStream(true); }); final InputStreamThread it = jobProcess.getInputStreamThread(); it.start(); final Process currentProcess = jobProcess.getProcess(); currentProcess.waitFor();
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.9K bytes - Viewed (0) -
src/runtime/runtime-lldb_test.go
if process: print "Process launched" listener = debugger.GetListener() process.broadcaster.AddListener(listener, lldb.SBProcess.eBroadcastBitStateChanged) while True: event = lldb.SBEvent() if listener.WaitForEvent(TIMEOUT_SECS, event): if lldb.SBProcess.GetRestartedFromEvent(event): continue state = process.GetState()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 21 22:16:54 UTC 2024 - 4.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/CrawlJob.java
} final JobProcess jobProcess = processHelper.startProcess(sessionId, cmdList, pb -> { pb.directory(baseDir); pb.redirectErrorStream(true); }); final InputStreamThread it = jobProcess.getInputStreamThread(); it.start(); final Process currentProcess = jobProcess.getProcess(); currentProcess.waitFor();
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 15K bytes - Viewed (0) -
pilot/cmd/pilot-agent/app/fds.go
// // Go already sets this (https://github.com/golang/go/issues/46279). // However, it will restore the original limit for subprocesses (Envoy): // https://github.com/golang/go/blob/f0d1195e13e06acdf8999188decc63306f9903f5/src/syscall/rlimit.go#L14. // By explicitly doing it ourselves, we get the limit passed through to Envoy. //
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 22:16:26 UTC 2024 - 1.3K bytes - Viewed (0) -
src/cmd/go/internal/vcweb/svn.go
// stdin and stdout streams as if invoked by the Unix "inetd" service. // We aren't using inetd, but we are implementing essentially the same // approach: using a host process to listen for connections and spawn // subprocesses to serve them. cmd := exec.Command(h.svnservePath, "--read-only", "--root="+h.svnRoot, "--inetd") cmd.Stdin = c cmd.Stdout = c stderr := new(strings.Builder) cmd.Stderr = stderr err := cmd.Run()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 25 13:44:48 UTC 2022 - 5K bytes - Viewed (0) -
src/cmd/pprof/pprof_test.go
// GO_PPROFTEST_IS_PPROF is set, and runs the tests otherwise. func TestMain(m *testing.M) { if os.Getenv("GO_PPROFTEST_IS_PPROF") != "" { main() os.Exit(0) } os.Setenv("GO_PPROFTEST_IS_PPROF", "1") // Set for subprocesses to inherit. os.Exit(m.Run()) } // pprofPath returns the path to the "pprof" binary to run. func pprofPath(t testing.TB) string { t.Helper() testenv.MustHaveExec(t) pprofPathOnce.Do(func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 03 16:07:59 UTC 2023 - 3.4K bytes - Viewed (0) -
src/cmd/go/internal/cache/default.go
func DefaultDir() (string, bool) { // Save the result of the first call to DefaultDir for later use in // initDefaultCache. cmd/go/main.go explicitly sets GOCACHE so that // subprocesses will inherit it, but that means initDefaultCache can't // otherwise distinguish between an explicit "off" and a UserCacheDir error. defaultDirOnce.Do(func() { defaultDir = cfg.Getenv("GOCACHE") if defaultDir != "" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 14:34:32 UTC 2024 - 3K bytes - Viewed (0) -
src/cmd/go/go_unix_test.go
// SIGINT (as would be sent by pressing ^C on a console), // it should return quickly, not deadlock. func TestTestInterrupt(t *testing.T) { if testing.Short() { t.Skipf("skipping in short mode: test executes many subprocesses") } // Don't run this test in parallel, for the same reason. tg := testgo(t) defer tg.cleanup() tg.setenv("GOROOT", testGOROOT) ctx, cancel := context.WithCancel(context.Background())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 19 16:17:55 UTC 2023 - 3.5K bytes - Viewed (0)