- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 151 for npipe (0.07 sec)
-
cmd/kubelet/app/options/options.go
fs.StringVar(&c.ImageServiceEndpoint, "image-service-endpoint", c.ImageServiceEndpoint, "The endpoint of container image service. If not specified, it will be the same with --container-runtime-endpoint by default. Unix Domain Socket are supported on Linux, while npipe and tcp endpoints are supported on Windows. Examples...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:05 UTC 2024 - 41.6K bytes - Viewed (0) -
pkg/kubelet/apis/config/types.go
// +optional LocalStorageCapacityIsolation bool // ContainerRuntimeEndpoint is the endpoint of container runtime. // unix domain sockets supported on Linux while npipes and tcp endpoints are supported for windows. // Examples:'unix:///path/to/runtime.sock', 'npipe:////./pipe/runtime' ContainerRuntimeEndpoint string // ImageServiceEndpoint is the endpoint of container image service.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 21:10:42 UTC 2024 - 35.1K bytes - Viewed (0) -
src/os/pipe_test.go
r, w, err := os.Pipe() if err != nil { t.Fatal(err) } if err := r.Close(); err != nil { t.Fatal(err) } expect := syscall.EPIPE if runtime.GOOS == "windows" { // 232 is Windows error code ERROR_NO_DATA, "The pipe is being closed". expect = syscall.Errno(232) } // Every time we write to the pipe we should get an EPIPE. for i := 0; i < 20; i++ { _, err = w.Write([]byte("hi")) if err == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 12.4K bytes - Viewed (0) -
src/text/template/parse/lex_test.go
}}, // Fixed bugs // Many elements in an action blew the lookahead until // we made lexInsideAction not loop. {"long pipeline deadlock", "{{|||||}}", []item{ tLeft, tPipe, tPipe, tPipe, tPipe, tPipe, tRight, tEOF, }}, {"text with bad comment", "hello-{{/*/}}-world", []item{ mkItem(itemText, "hello-"), mkItem(itemError, `unclosed comment`), }},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 23 15:03:43 UTC 2022 - 13.9K bytes - Viewed (0) -
src/os/signal/doc.go
# SIGPIPE When a Go program writes to a broken pipe, the kernel will raise a SIGPIPE signal. If the program has not called Notify to receive SIGPIPE signals, then the behavior depends on the file descriptor number. A write to a broken pipe on file descriptors 1 or 2 (standard output or standard error) will cause the program to exit with a SIGPIPE signal. A write to a broken pipe on some other file descriptor will take no action on
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:11:00 UTC 2024 - 11K bytes - Viewed (0) -
src/os/file_unix.go
return f } func sigpipe() // implemented in package runtime // epipecheck raises SIGPIPE if we get an EPIPE error on standard // output or standard error. See the SIGPIPE docs in os/signal, and // issue 11845. func epipecheck(file *File, e error) { if e == syscall.EPIPE && file.stdoutOrErr { sigpipe() } } // DevNull is the name of the operating system's “null device.”
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 13:52:34 UTC 2024 - 14.9K bytes - Viewed (0) -
src/text/template/parse/parse.go
pipe.IsAssign = next.typ == itemAssign t.nextNonSpace() pipe.Decl = append(pipe.Decl, t.newVariable(v.pos, v.val)) t.vars = append(t.vars, v.val) case next.typ == itemChar && next.val == ",": t.nextNonSpace() pipe.Decl = append(pipe.Decl, t.newVariable(v.pos, v.val)) t.vars = append(t.vars, v.val) if context == "range" && len(pipe.Decl) < 2 { switch t.peekNonSpace().typ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 20:57:51 UTC 2024 - 21.3K bytes - Viewed (0) -
src/net/http/httputil/persist.go
func (sc *ServerConn) Read() (*http.Request, error) { var req *http.Request var err error // Ensure ordered execution of Reads and Writes id := sc.pipe.Next() sc.pipe.StartRequest(id) defer func() { sc.pipe.EndRequest(id) if req == nil { sc.pipe.StartResponse(id) sc.pipe.EndResponse(id) } else { // Remember the pipeline id of this request sc.mu.Lock() sc.pipereq[req] = id sc.mu.Unlock() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.1K bytes - Viewed (0) -
src/text/template/parse/node.go
NodeType Pos tr *Tree Line int // The line number in the input. Deprecated: Kept for compatibility. Pipe *PipeNode // The pipeline in the action. } func (t *Tree) newAction(pos Pos, line int, pipe *PipeNode) *ActionNode { return &ActionNode{tr: t, NodeType: NodeAction, Pos: pos, Line: line, Pipe: pipe} } func (a *ActionNode) String() string { var sb strings.Builder a.writeTo(&sb) return sb.String()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 20:57:51 UTC 2024 - 24.2K bytes - Viewed (0) -
src/syscall/exec_plan9.go
// so that pass 2 won't stomp on an fd it needs later. if pipe < nextfd { r1, _, _ = RawSyscall(SYS_DUP, uintptr(pipe), uintptr(nextfd), 0) if int32(r1) == -1 { 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: Mon Feb 26 21:03:59 UTC 2024 - 13.3K bytes - Viewed (0)