- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 120 for openPipe (0.21 sec)
-
cmd/os-instrumented.go
return RenameSys(src, dst) } // OpenFile captures time taken to call os.OpenFile func OpenFile(name string, flag int, perm os.FileMode) (f *os.File, err error) { switch flag & writeMode { case writeMode: defer updateOSMetrics(osMetricOpenFileW, name)(err) default: defer updateOSMetrics(osMetricOpenFileR, name)(err) } return os.OpenFile(name, flag, perm) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 15 01:09:38 UTC 2024 - 6.3K bytes - Viewed (0) -
src/os/fifo_test.go
if err := syscall.Mkfifo(name, 0o600); err != nil { t.Fatal(err) } // The problem only occurs if we use O_NONBLOCK here. rd, err := os.OpenFile(name, os.O_RDONLY|syscall.O_NONBLOCK, 0o600) if err != nil { t.Fatal(err) } wr, err := os.OpenFile(name, os.O_WRONLY|syscall.O_NONBLOCK, 0o600) if err != nil { t.Fatal(err) } const msg = "message"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 19 11:47:23 UTC 2024 - 6.1K bytes - Viewed (0) -
src/os/exec/lp_unix_test.go
"testing" ) func TestLookPathUnixEmptyPath(t *testing.T) { // Not parallel: uses Chdir and Setenv. tmp := t.TempDir() chdir(t, tmp) f, err := os.OpenFile("exec_me", os.O_CREATE|os.O_EXCL, 0700) if err != nil { t.Fatal("OpenFile failed: ", err) } err = f.Close() if err != nil { t.Fatal("Close failed: ", err) } t.Setenv("PATH", "") path, err := exec.LookPath("exec_me")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 13 18:19:21 UTC 2023 - 762 bytes - Viewed (0) -
src/embed/embed.go
} ofile, ok := file.(*openFile) if !ok { return nil, &fs.PathError{Op: "read", Path: name, Err: errors.New("is a directory")} } return []byte(ofile.f.data), nil } // An openFile is a regular file open for reading. type openFile struct { f *file // the file itself offset int64 // current read offset } var ( _ io.Seeker = (*openFile)(nil) _ io.ReaderAt = (*openFile)(nil)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 19:42:51 UTC 2024 - 13.5K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/postupgrade_test.go
certPath := filepath.Join(tmpdir, constants.APIServerCertName) certFile, err := os.OpenFile(certPath, os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0666) if err != nil { t.Fatalf("Failed to create cert file %s: %v", certPath, err) } certFile.Close() keyPath := filepath.Join(tmpdir, constants.APIServerKeyName) keyFile, err := os.OpenFile(keyPath, os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0666) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 11:40:04 UTC 2024 - 7.2K bytes - Viewed (0) -
internal/disk/directio_unsupported.go
// see this ZFS-on-Linux commit message: // https://github.com/openzfs/zfs/commit/a584ef26053065f486d46a7335bea222cb03eeea // OpenFileDirectIO wrapper around os.OpenFile nothing special func OpenFileDirectIO(filePath string, flag int, perm os.FileMode) (*os.File, error) { return os.OpenFile(filePath, flag, perm) } // DisableDirectIO is a no-op func DisableDirectIO(f *os.File) error { return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Oct 18 18:08:15 UTC 2023 - 2.6K bytes - Viewed (0) -
src/net/ipsock_plan9.go
n, err := listen.Read(buf[:]) if err != nil { listen.Close() return nil, err } name := string(buf[:n]) ctl, err := os.OpenFile(netdir+"/"+fd.net+"/"+name+"/ctl", os.O_RDWR, 0) if err != nil { listen.Close() return nil, err } data, err := os.OpenFile(netdir+"/"+fd.net+"/"+name+"/data", os.O_RDWR, 0) if err != nil { listen.Close() ctl.Close() return nil, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 29 20:38:53 UTC 2023 - 7.5K bytes - Viewed (0) -
src/runtime/internal/wasitest/nonblock_test.go
if target != "wasip1/wasm" { t.Skip() } switch os.Getenv("GOWASIRUNTIME") { case "wasmer": t.Skip("wasmer does not support non-blocking I/O") } for _, mode := range []string{"os.OpenFile", "os.NewFile"} { t.Run(mode, func(t *testing.T) { args := []string{"run", "./testdata/nonblock.go", mode} fifos := make([]*fifo, 8) for i := range fifos {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 29 15:35:27 UTC 2023 - 2.4K bytes - Viewed (0) -
src/runtime/testdata/testsuid/main.go
package main import ( "fmt" "log" "os" ) func main() { if os.Geteuid() == os.Getuid() { os.Exit(99) } fmt.Fprintf(os.Stdout, "GOTRACEBACK=%s\n", os.Getenv("GOTRACEBACK")) f, err := os.OpenFile(os.Getenv("TEST_OUTPUT"), os.O_CREATE|os.O_RDWR, 0600) if err != nil { log.Fatalf("os.Open failed: %s", err) } defer f.Close() fmt.Fprintf(os.Stderr, "hello\n")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 06 18:49:01 UTC 2023 - 534 bytes - Viewed (0) -
src/os/error_test.go
if err != nil { t.Fatalf("open ErrPathNUL tempfile: %s", err) } defer os.Remove(f.Name()) defer f.Close() f2, err := os.OpenFile(f.Name(), os.O_RDWR, 0600) if err != nil { t.Fatalf("open ErrPathNUL: %s", err) } f2.Close() f2, err = os.OpenFile(f.Name()+"\x00", os.O_RDWR, 0600) if err == nil { f2.Close() t.Fatal("Open should have failed") } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 19 00:41:52 UTC 2023 - 4.9K bytes - Viewed (0)