- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 592 for pipe1 (0.08 sec)
-
src/os/pipe_wasm.go
//go:build wasm package os import "syscall" // Pipe returns a connected pair of Files; reads from r return bytes written to w. // It returns the files and an error, if any. func Pipe() (r *File, w *File, err error) { // Neither GOOS=js nor GOOS=wasip1 have pipes. return nil, nil, NewSyscallError("pipe", syscall.ENOSYS)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 07 23:34:21 UTC 2023 - 488 bytes - Viewed (0) -
pkg/kubelet/util/util_windows.go
} // windows pipes are expected to use forward slashes: https://learn.microsoft.com/windows/win32/ipc/pipe-names // so using `url` like we do on unix gives us unclear benefits - see https://github.com/kubernetes/kubernetes/issues/78628 // So we just construct the path from scratch. // Format: \\ServerName\pipe\PipeName
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 3K bytes - Viewed (0) -
src/runtime/export_pipe2_test.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. //go:build dragonfly || freebsd || linux || netbsd || openbsd || solaris package runtime func Pipe() (r, w int32, errno int32) { return pipe2(0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 03 20:47:17 UTC 2022 - 310 bytes - Viewed (0) -
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/main/java/jcifs/smb1/smb1/TransactNamedPipeInputStream.java
private boolean dcePipe; Object lock; TransactNamedPipeInputStream( SmbNamedPipe pipe ) throws SmbException, MalformedURLException, UnknownHostException { super( pipe, ( pipe.pipeType & 0xFFFF00FF ) | SmbFile.O_EXCL ); this.dcePipe = ( pipe.pipeType & SmbNamedPipe.PIPE_TYPE_DCE_TRANSACT ) != SmbNamedPipe.PIPE_TYPE_DCE_TRANSACT; lock = new Object(); }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 4.6K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stress-start-stop.go
outerDone <- true }() var wg sync.WaitGroup done := make(chan bool) wg.Add(1) go func() { <-done wg.Done() }() rp, wp, err := os.Pipe() if err != nil { log.Fatalf("failed to create pipe: %v", err) return } defer func() { rp.Close() wp.Close() }() wg.Add(1) go func() { var tmp [1]byte rp.Read(tmp[:]) <-done wg.Done()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.7K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/tasks/CopySpecIntegrationSpec.groovy
@Issue("https://github.com/gradle/gradle/issues/2552") def "copying files to a directory with named pipes fails"() { def input = file("input.txt").createFile() def outputDirectory = file("output").createDir() def pipe = outputDirectory.file("testPipe").createNamedPipe() buildFile << """ task copy(type: Copy) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 21 12:45:30 UTC 2023 - 3.9K bytes - Viewed (0) -
src/syscall/syscall_dragonfly.go
} //sysnb pipe() (r int, w int, err error) func Pipe(p []int) (err error) { if len(p) != 2 { return EINVAL } r, w, err := pipe() if err == nil { p[0], p[1] = r, w } return err } //sysnb pipe2(p *[2]_C_int, flags int) (r int, w int, err error) func Pipe2(p []int, flags int) (err error) { if len(p) != 2 { return EINVAL
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 20 18:12:35 UTC 2023 - 8.5K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stress.go
// Create a goroutine blocked before tracing. wg.Add(1) go func() { <-done wg.Done() }() // Create a goroutine blocked in syscall before tracing. rp, wp, err := os.Pipe() if err != nil { log.Fatalf("failed to create pipe: %v", err) } defer func() { rp.Close() wp.Close() }() wg.Add(1) go func() { var tmp [1]byte rp.Read(tmp[:]) <-done wg.Done() }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.5K bytes - Viewed (0) -
src/internal/poll/splice_linux_test.go
} expiredTime := time.NewTimer(timeout) defer expiredTime.Stop() // Trigger garbage collection repeatedly, waiting for all pipes in sync.Pool // to either be deallocated and closed, or to time out. for { runtime.GC() time.Sleep(10 * time.Millisecond) // Detect whether all pipes are closed properly. var leakedFDs []int pendingFDs.Range(func(k, v any) bool { leakedFDs = append(leakedFDs, k.(int))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 2.8K bytes - Viewed (0)