- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 63 for openPipe (0.16 sec)
-
src/test/java/jcifs/tests/ReadWriteTest.java
SmbNamedPipe t = new SmbNamedPipe(getFifoPipeUrl(), SmbPipeResource.PIPE_TYPE_RDONLY, withTestNTLMCredentials(getContext())) ) { try ( SmbPipeHandle sp = s.openPipe(); SmbPipeHandle tp = t.openPipe() ) { try ( OutputStream os = sp.getOutput() ) { writeRandom(1024, 1024, os); } try ( InputStream is = tp.getInput() ) {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 13.2K 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) -
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) -
pkg/volume/volume_linux_test.go
assertFunc func(path string) error }{ { description: "fsGroup=nil", fsGroup: nil, setupFunc: func(path string) error { filename := filepath.Join(path, "file.txt") file, err := os.OpenFile(filename, os.O_RDWR|os.O_CREATE, 0755) if err != nil { return err } file.Close() return nil }, assertFunc: func(path string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 03 19:34:37 UTC 2023 - 12.1K bytes - Viewed (0) -
src/cmd/covdata/metamerge.go
} defer inf.Close() fi, err := inf.Stat() if err != nil { fatal("accessing input meta-data file %s: %v", inpath, err) } outf, err := os.OpenFile(outpath, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, fi.Mode()) if err != nil { fatal("opening output meta-data file %s: %v", outpath, err) } _, err = io.Copy(outf, inf) outf.Close() if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 12 17:17:47 UTC 2024 - 12.1K bytes - Viewed (0) -
src/os/file_unix.go
type newFileKind int const ( // kindNewFile means that the descriptor was passed to us via NewFile. kindNewFile newFileKind = iota // kindOpenFile means that the descriptor was opened using // Open, Create, or OpenFile. kindOpenFile // kindPipe means that the descriptor was opened using Pipe. kindPipe // kindSock means that the descriptor is a network file descriptor
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 13:52:34 UTC 2024 - 14.9K bytes - Viewed (0) -
src/os/file.go
// be used for I/O; the associated file descriptor has mode O_RDWR. // If there is an error, it will be of type *PathError. func Create(name string) (*File, error) { return OpenFile(name, O_RDWR|O_CREATE|O_TRUNC, 0666) } // OpenFile is the generalized open call; most users will use Open // or Create instead. It opens the named file with specified flag // (O_RDONLY etc.). If the file does not exist, and the O_CREATE flag
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 23:07:37 UTC 2024 - 25.4K bytes - Viewed (0) -
pkg/volume/util/fsquota/project.go
} // We don't actually modify the original files; we create temporaries and // move them over the originals fProjects, err := os.OpenFile(projectsFile, os.O_RDONLY|os.O_CREATE, 0644) if err != nil { err = fmt.Errorf("unable to open %s: %v", projectsFile, err) return nil, nil, err } fProjid, err := os.OpenFile(projidFile, os.O_RDONLY|os.O_CREATE, 0644) if err == nil { // Check once more, to ensure nothing got changed out from under us
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 10.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/start.go
} else if fd.IsDir() { // local/debug exists and is a directory. Set stderr to a log file path // in local/debug. childLogPath := filepath.Join(telemetry.Default.DebugDir(), "sidecar.log") childLog, err := os.OpenFile(childLogPath, os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0600) if err != nil { log.Fatalf("opening sidecar log file for child: %v", err) } defer childLog.Close() cmd.Stderr = childLog }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 14:52:56 UTC 2024 - 10.8K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
// and check if that disk // appears in outDatedDisks. tamperedIndex = index filePath := pathJoin(erasureDisks[index].String(), bucket, object, fi.DataDir, "part.1") f, err := os.OpenFile(filePath, os.O_WRONLY|os.O_SYNC, 0) if err != nil { t.Fatalf("Failed to open %s: %s\n", filePath, err) } f.WriteString("oops") // Will cause bitrot error f.Close() break }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 23K bytes - Viewed (0)