- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for pipe1 (0.09 sec)
-
src/os/exec/exec.go
} // StdinPipe returns a pipe that will be connected to the command's // standard input when the command starts. // The pipe will be closed automatically after [Cmd.Wait] sees the command exit. // A caller need only call Close to force the pipe to close sooner. // For example, if the command being run will not exit until standard input // is closed, the caller must close the pipe.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 41.4K bytes - Viewed (0) -
src/os/exec/exec_test.go
// stderr pipe is closed. if ee := new(*exec.ExitError); !errors.As(err, ee) { t.Errorf("Wait error = %v; want %T", err, *ee) } }) // If the process exits with status 0 but leaves a child behind writing // to its output pipes, Wait should only wait for WaitDelay before // closing the pipes and returning. Wait should return ErrWaitDelay
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 48.4K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/start.go
log.Fatalf("opening sidecar log file for child: %v", err) } defer childLog.Close() cmd.Stderr = childLog } if reportCrashes { pipe, err := cmd.StdinPipe() if err != nil { log.Fatalf("StdinPipe: %v", err) } crashmonitor.Parent(pipe.(*os.File)) // (this conversion is safe) } if err := cmd.Start(); err != nil { log.Fatalf("can't start telemetry child process: %v", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 14:52:56 UTC 2024 - 10.8K bytes - Viewed (0) -
src/text/template/exec.go
val, _ := indirect(s.evalPipeline(dot, r.Pipe)) // mark top of stack before any variables in the body are pushed. mark := s.mark() oneIteration := func(index, elem reflect.Value) { if len(r.Pipe.Decl) > 0 { if r.Pipe.IsAssign { // With two variables, index comes first. // With one, we use the element. if len(r.Pipe.Decl) > 1 { s.setVar(r.Pipe.Decl[0].Ident[0], index) } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 21:22:24 UTC 2024 - 32K bytes - Viewed (0) -
src/syscall/exec_linux.go
// so that pass 2 won't stomp on an fd it needs later. if pipe < nextfd { _, _, err1 = RawSyscall(SYS_DUP3, uintptr(pipe), uintptr(nextfd), O_CLOEXEC) if err1 != 0 { goto childerror } pipe = nextfd nextfd++ } for i = 0; i < len(fd); i++ { if fd[i] >= 0 && fd[i] < i { if nextfd == pipe { // don't stomp on pipe nextfd++ }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 07:45:37 UTC 2024 - 23K bytes - Viewed (0) -
cmd/sftp-server-driver.go
switch { case len(w.buffer) > 0: err = errors.New("some file segments were not flushed from the queue") _ = w.w.CloseWithError(err) case w.err != nil: // No need to close here since both pipes were // closing inside TransferError() err = w.err default: err = w.w.Close() } for i := range w.buffer { delete(w.buffer, i) } w.wg.Wait() return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/bootstrap/testdata/tracing_opencensusagent_golden.json
"load_assignment": { "cluster_name": "sds-grpc", "endpoints": [{ "lb_endpoints": [{ "endpoint": { "address":{ "pipe": { "path": "./var/run/secrets/workload-spiffe-uds/socket" } } } }] }] } }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 17:05:28 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/bootstrap/testdata/deferred_cluster_creation_golden.json
"load_assignment": { "cluster_name": "sds-grpc", "endpoints": [{ "lb_endpoints": [{ "endpoint": { "address":{ "pipe": { "path": "./var/run/secrets/workload-spiffe-uds/socket" } } } }] }] } }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/volume/util/util_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.7K bytes - Viewed (0) -
src/internal/trace/trace_test.go
}) } func TestTraceStress(t *testing.T) { switch runtime.GOOS { case "js", "wasip1": t.Skip("no os.Pipe on " + runtime.GOOS) } testTraceProg(t, "stress.go", nil) } func TestTraceStressStartStop(t *testing.T) { switch runtime.GOOS { case "js", "wasip1": t.Skip("no os.Pipe on " + runtime.GOOS) } testTraceProg(t, "stress-start-stop.go", nil) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 18.5K bytes - Viewed (0)