Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 85 for openPipe (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. src/net/file_plan9.go

    		}
    		name = string(buf[:n])
    	default:
    		if len(comp) < 4 {
    			return nil, errors.New("could not find control file for connection")
    		}
    		dir := netdir + "/" + comp[1] + "/" + name
    		ctl, err = os.OpenFile(dir+"/ctl", os.O_RDWR, 0)
    		if err != nil {
    			return nil, err
    		}
    		defer close(int(ctl.Fd()))
    	}
    	dir := netdir + "/" + comp[1] + "/" + name
    	laddr, err := readPlan9Addr(comp[1], dir+"/local")
    	if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  9. src/cmd/go/internal/fsys/fsys.go

    	Trace("Open", path)
    	return openFile(path, os.O_RDONLY, 0)
    }
    
    func openFile(path string, flag int, perm os.FileMode) (*os.File, error) {
    	cpath := canonicalize(path)
    	if node, ok := overlay[cpath]; ok {
    		// Opening a file in the overlay.
    		if node.isDir() {
    			return nil, &fs.PathError{Op: "OpenFile", Path: path, Err: errors.New("fsys.OpenFile doesn't support opening directories yet")}
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 18:35:34 UTC 2024
    - 22.7K bytes
    - Viewed (0)
  10. cmd/kubeadm/app/util/copy.go

    	if err != nil {
    		return err
    	}
    
    	sourceFile, err := os.Open(src)
    	if err != nil {
    		return err
    	}
    	defer func() {
    		_ = sourceFile.Close()
    	}()
    
    	destFile, err := os.OpenFile(dest, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, sourceFileInfo.Mode())
    	if err != nil {
    		return err
    	}
    	defer func() {
    		_ = destFile.Close()
    	}()
    
    	_, err = io.Copy(destFile, sourceFile)
    
    	return err
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 01:42:57 UTC 2024
    - 1.9K bytes
    - Viewed (0)
Back to top