- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 247 for Read (0.21 sec)
-
internal/ioutil/read_file.go
) // ReadFileWithFileInfo reads the named file and returns the contents. // A successful call returns err == nil, not err == EOF. // Because ReadFile reads the whole file, it does not treat an EOF from Read // as an error to be reported. func ReadFileWithFileInfo(name string) ([]byte, fs.FileInfo, error) { f, err := OsOpenFile(name, readMode, 0o666) if err != nil { return nil, nil, err } defer f.Close()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 09 18:17:51 GMT 2023 - 2.3K bytes - Viewed (0) -
internal/ioutil/read_file_noatime_supported.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 937 bytes - Viewed (0) -
internal/ioutil/read_file_noatime_notsupported.go
Harshavardhana <******@****.***> 1629336922 -0700
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 893 bytes - Viewed (0) -
src/bufio/bufio.go
return n - remain, b.readErr() } } } // Read reads data into p. // It returns the number of bytes read into p. // The bytes are taken from at most one Read on the underlying [Reader], // hence n may be less than len(p). // To read exactly len(p) bytes, use io.ReadFull(b, p). // If the underlying [Reader] can return a non-zero count with io.EOF, // then this Read method can do so as well; see the [io.Reader] docs.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Oct 12 14:39:08 GMT 2023 - 21.8K bytes - Viewed (0) -
src/archive/tar/reader.go
// - Exactly 0 bytes are read and EOF is hit. // - Exactly 1 block of zeros is read and EOF is hit. // - At least 2 blocks of zeros are read. func (tr *Reader) readHeader() (*Header, *block, error) { // Two blocks of zero bytes marks the end of the archive. if _, err := io.ReadFull(tr.r, tr.blk[:]); err != nil { return nil, nil, err // EOF is okay here; exactly 0 bytes read }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0) -
cmd/metrics-v3-system-process.go
processIORCharBytesMD = NewCounterMD(processIORCharBytes, "Total bytes read by the process from the underlying storage system including cache, /proc/[pid]/io rchar") processIOReadBytesMD = NewCounterMD(processIOReadBytes, "Total bytes read by the process from the underlying storage system, /proc/[pid]/io read_bytes")
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 16:07:23 GMT 2024 - 6.4K bytes - Viewed (0) -
internal/etag/reader.go
} } return &Reader{ src: r, md5: md5.New(), checksum: etag, } } // Read reads up to len(p) bytes from the underlying // io.Reader as specified by the io.Reader interface. func (r *Reader) Read(p []byte) (int, error) { n, err := r.src.Read(p) r.readN += int64(n) r.md5.Write(p[:n]) if err == io.EOF && len(r.checksum) != 0 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.8K bytes - Viewed (0) -
src/bufio/scan_test.go
// reads in Scanner.Scan. type slowReader struct { max int buf io.Reader } func (sr *slowReader) Read(p []byte) (n int, err error) { if len(p) > sr.max { p = p[0:sr.max] } return sr.buf.Read(p) } // genLine writes to buf a predictable but non-trivial line of text of length // n, including the terminal newline and an occasional carriage return.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Sep 22 16:22:42 GMT 2023 - 14.3K bytes - Viewed (0) -
cmd/perf-tests.go
} type firstByteRecorder struct { t *time.Time r io.Reader } func (f *firstByteRecorder) Read(p []byte) (n int, err error) { if f.t != nil || len(p) == 0 { return f.r.Read(p) } // Read a single byte. n, err = f.r.Read(p[:1]) if n > 0 { t := time.Now() f.t = &t } return n, err } // Runs the speedtest on local MinIO process.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
setupLogging() ctx, cancel := context.WithCancel(context.Background()) defer cancel() fixture := connect(ctx) ztunClient := fixture.ztunClient uid := fixture.uid // read initial pod add readRequest(t, ztunClient) sendAck(ztunClient) // read snapshot sent m, fds := readRequest(t, ztunClient) assert.Equal(t, len(fds), 0) sent := m.Payload.(*zdsapi.WorkloadRequest_SnapshotSent).SnapshotSent if sent == nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0)