- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 194 for unpipe (0.45 sec)
-
src/internal/poll/splice_linux.go
// Splice cannot continue. // // If inPipe == 0 && err == nil, src is at EOF, and the // transfer is complete. handled = handled || (err != syscall.EINVAL) if err != nil || inPipe == 0 { break } p.data += inPipe n, err = splicePump(dst, p.rfd, inPipe) if n > 0 { written += int64(n) remain -= int64(n) p.data -= n } } if err != nil { return written, handled, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 7.6K bytes - Viewed (0) -
src/runtime/export_unix_test.go
// Make sure we can receive SIGUSR1. unblocksig(_SIGUSR1) waitForSigusr1.rdpipe = r waitForSigusr1.wrpipe = w mp := getg().m testSigusr1 = waitForSigusr1Callback ready(mp) // Wait for the signal. We use a pipe rather than a note // because write is always async-signal-safe. entersyscallblock() var b byte read(waitForSigusr1.rdpipe, noescape(unsafe.Pointer(&b)), 1) exitsyscall() gotM := waitForSigusr1.mID
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 20 21:27:51 UTC 2023 - 2.3K bytes - Viewed (0) -
src/runtime/signal_windows_test.go
cmd = exec.Command(exe) var stdout strings.Builder var stderr strings.Builder cmd.Stdout = &stdout cmd.Stderr = &stderr inPipe, err := cmd.StdinPipe() if err != nil { t.Fatalf("Failed to create stdin pipe: %v", err) } // keep inPipe alive until the end of the test defer inPipe.Close() // in a new command window const _CREATE_NEW_CONSOLE = 0x00000010 cmd.SysProcAttr = &syscall.SysProcAttr{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 05 08:26:52 UTC 2023 - 9K bytes - Viewed (0) -
pkg/kubelet/util/util_windows.go
limitations under the License. */ package util import ( "fmt" "path/filepath" "strings" "syscall" "time" ) const npipeProtocol = "npipe" // LocalEndpoint returns the full path to a named pipe at the given endpoint - unlike on unix, we can't use sockets. func LocalEndpoint(path, file string) (string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 3K bytes - Viewed (0) -
src/syscall/tables_wasip1.go
EOWNERDEAD: "Owner died", EPERM: "Operation not permitted", EPIPE: "Broken pipe", EPROTO: "Protocol error", EPROTONOSUPPORT: "Unknown protocol", EPROTOTYPE: "Protocol wrong type for socket", ERANGE: "Math result not representable", EROFS: "Read-only file system", ESPIPE: "Illegal seek", ESRCH: "No such process",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 20:58:35 UTC 2023 - 6.5K bytes - Viewed (0) -
src/io/pipe.go
a.Lock() defer a.Unlock() return a.err } // ErrClosedPipe is the error used for read or write operations on a closed pipe. var ErrClosedPipe = errors.New("io: read/write on closed pipe") // A pipe is the shared pipe structure underlying PipeReader and PipeWriter. type pipe struct { wrMu sync.Mutex // Serializes Write operations wrCh chan []byte rdCh chan int once sync.Once // Protects closing done
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 18 19:34:35 UTC 2023 - 5.1K bytes - Viewed (0) -
src/net/pipe.go
} return p1, p2 } func (*pipe) LocalAddr() Addr { return pipeAddr{} } func (*pipe) RemoteAddr() Addr { return pipeAddr{} } func (p *pipe) Read(b []byte) (int, error) { n, err := p.read(b) if err != nil && err != io.EOF && err != io.ErrClosedPipe { err = &OpError{Op: "read", Net: "pipe", Err: err} } return n, err } func (p *pipe) read(b []byte) (n int, err error) { switch {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.4K bytes - Viewed (0) -
cmd/kubeadm/app/constants/constants_windows.go
const ( // CRISocketContainerd is the containerd CRI endpoint CRISocketContainerd = "npipe:////./pipe/containerd-containerd" // CRISocketCRIO is the cri-o CRI endpoint // NOTE: this is a placeholder as CRI-O does not support Windows CRISocketCRIO = "npipe:////./pipe/cri-o" // CRISocketDocker is the cri-dockerd CRI endpoint CRISocketDocker = "npipe:////./pipe/cri-dockerd" // DefaultCRISocket defines the default CRI socket
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 12 15:15:45 UTC 2022 - 1.1K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/wait-on-pipe.go
import ( "log" "os" "runtime/trace" "syscall" "time" ) func main() { // Create a pipe to block on. var p [2]int if err := syscall.Pipe(p[:]); err != nil { log.Fatalf("failed to create pipe: %v", err) } rfd, wfd := p[0], p[1] // Create a goroutine that blocks on the pipe. done := make(chan struct{}) go func() { var data [1]byte _, err := syscall.Read(rfd, data[:])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.6K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/util_windows_test.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package cmd
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 09:45:16 UTC 2023 - 687 bytes - Viewed (0)