- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 592 for pipe1 (0.34 sec)
-
src/syscall/forkpipe2.go
//go:build dragonfly || freebsd || linux || netbsd || openbsd || solaris package syscall import "sync" // forkExecPipe atomically opens a pipe with O_CLOEXEC set on both file // descriptors. func forkExecPipe(p []int) error { return Pipe2(p, O_CLOEXEC) } var ( // Guard the forking variable. forkingLock sync.Mutex // Number of goroutines currently forking, and thus the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jul 10 19:19:59 UTC 2023 - 2.6K bytes - Viewed (0) -
src/syscall/exec_unix.go
// inherit are not the ones that can take an arbitrarily long time // to create: pipe returns instantly, and the net package uses // non-blocking I/O to accept on a listening socket. // The rules for which file descriptor-creating operations use the // ForkLock are as follows: // // - [Pipe]. Use pipe2 if available. Otherwise, does not block, // so use ForkLock.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:03:59 UTC 2024 - 8.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/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 } //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: Tue Oct 10 16:32:44 UTC 2023 - 11.2K bytes - Viewed (0) -
src/os/pipe_test.go
// (We expect a write to a closed pipe can fail, but a concurrent fork of a // child process can cause the pipe to unexpectedly remain open.) limit := 1 if !read { // Get the amount we have to write to overload a pipe // with no reader. limit = 131073 if b, err := os.ReadFile("/proc/sys/fs/pipe-max-size"); 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) -
ci/official/utilities/setup.sh
# exec". # Important: "tfrun foo | bar" is "( tfrun foo ) | bar", not "tfrun (foo | bar)". # Therefore, "tfrun" commands cannot include pipes -- which is # probably for the better. If a pipe is necessary for something, it is probably # complex. Write a well-documented script under utilities/ to encapsulate the # functionality instead. tfrun() { "$@"; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jan 26 00:33:34 UTC 2024 - 5.2K bytes - Viewed (0) -
src/syscall/syscall_netbsd.go
return readInt(buf, unsafe.Offsetof(Dirent{}.Namlen), unsafe.Sizeof(Dirent{}.Namlen)) } func Pipe(p []int) (err error) { return Pipe2(p, 0) } //sysnb pipe2(p *[2]_C_int, flags int) (err error) func Pipe2(p []int, flags int) error { if len(p) != 2 { return EINVAL } var pp [2]_C_int err := pipe2(&pp, flags) if err == nil { p[0] = int(pp[0]) p[1] = int(pp[1]) } return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 20 18:12:35 UTC 2023 - 7.8K bytes - Viewed (0) -
src/syscall/syscall_openbsd.go
return readInt(buf, unsafe.Offsetof(Dirent{}.Namlen), unsafe.Sizeof(Dirent{}.Namlen)) } func Pipe(p []int) error { return Pipe2(p, 0) } //sysnb pipe2(p *[2]_C_int, flags int) (err error) func Pipe2(p []int, flags int) error { if len(p) != 2 { return EINVAL } var pp [2]_C_int err := pipe2(&pp, flags) if err == nil { p[0] = int(pp[0]) p[1] = int(pp[1]) } return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 02 10:34:00 UTC 2023 - 7K bytes - Viewed (0) -
platforms/core-runtime/files/src/testFixtures/groovy/org/gradle/internal/file/AbstractFileMetadataAccessorTest.groovy
stat.length == 0 assertSameAccessType(stat, VIA_SYMLINK) } @Requires(UnitTestPreconditions.UnixDerivative) def "stats named pipes"() { def pipe = tmpDir.file("testPipe").createNamedPipe() when: accessor.stat(pipe) then: thrown(UncheckedIOException) } @Requires(UnitTestPreconditions.FilePermissions)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:50:56 UTC 2024 - 6.9K bytes - Viewed (0) -
src/net/sendfile_test.go
} } // Test that sendfile doesn't put a pipe into blocking mode. func TestSendfilePipe(t *testing.T) { switch runtime.GOOS { case "plan9", "windows", "js", "wasip1": // These systems don't support deadlines on pipes. t.Skipf("skipping on %s", runtime.GOOS) } t.Parallel() ln := newLocalListener(t, "tcp") defer ln.Close() r, w, err := os.Pipe() if err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 12.1K bytes - Viewed (0) -
src/syscall/syscall_freebsd.go
return readInt(buf, unsafe.Offsetof(Dirent{}.Namlen), unsafe.Sizeof(Dirent{}.Namlen)) } func Pipe(p []int) error { return Pipe2(p, 0) } //sysnb pipe2(p *[2]_C_int, flags int) (err error) func Pipe2(p []int, flags int) error { if len(p) != 2 { return EINVAL } var pp [2]_C_int err := pipe2(&pp, flags) if err == nil { p[0] = int(pp[0]) p[1] = int(pp[1]) } return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 20 18:12:35 UTC 2023 - 8.7K bytes - Viewed (0)