- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 133 for Read (0.14 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 May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 09 18:17:51 GMT 2023 - 2.3K bytes - Viewed (0) -
cmd/tier-journal.go
return nil } return errors.New("no local drive found") } // rotate rotates the journal. If a read-only journal already exists it does // nothing. Otherwise renames the active journal to a read-only journal and // opens a new active journal. func (jd *tierDiskJournal) rotate() error { // Do nothing if a read-only journal file already exists. if _, err := os.Stat(jd.ReadOnlyPath()); err == nil { return nil }
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
type diskHealthWrapper struct { tracker *healthDiskCtxValue r io.Reader w io.Writer } func (d *diskHealthWrapper) Read(p []byte) (int, error) { if d.r == nil { return 0, fmt.Errorf("diskHealthWrapper: Read with no reader") } n, err := d.r.Read(p) if err == nil || err == io.EOF && n > 0 { d.tracker.logSuccess() } return n, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/erasure-common.go
} ignoredErrs := []error{ errFileNotFound, errVolumeNotFound, errFileVersionNotFound, io.ErrUnexpectedEOF, // some times we would read without locks, ignore these errors io.EOF, // some times we would read without locks, ignore these errors context.DeadlineExceeded, context.Canceled, } ignoredErrs = append(ignoredErrs, objectOpIgnoredErrs...) errs := g.Wait()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/erasure-object.go
ctx = lkctx.Context() // Release lock when the metadata is verified, and reader // is ready to be read. // // This is possible to be lock free because // - xl.meta for inlined objects has already read the data // into memory, any mutation on xl.meta subsequently is // inconsequential to the overall read operation. // - xl.meta metadata is still verified for quorum under lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
internal/hash/checksum.go
h.Write(data) raw := h.Sum(nil) c := Checksum{Type: t, Encoded: base64.StdEncoding.EncodeToString(raw), Raw: raw} if !c.Valid() { return nil } return &c } // ReadCheckSums will read checksums from b and return them. func ReadCheckSums(b []byte, part int) map[string]string { res := make(map[string]string, 1) for len(b) > 0 { t, n := binary.Uvarint(b) if n < 0 { break }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.9K bytes - Viewed (0) -
cmd/untar.go
// the upstream reader after close has been called. type disconnectReader struct { r io.Reader mu sync.Mutex } func (d *disconnectReader) Read(p []byte) (n int, err error) { d.mu.Lock() defer d.mu.Unlock() if d.r != nil { return d.r.Read(p) } return 0, errors.New("reader closed") } func (d *disconnectReader) Close() error { d.mu.Lock() d.r = nil d.mu.Unlock() return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
return nil, err } case 1, 2: v, b, err := msgp.ReadBytesZC(b) if err != nil { return nil, err } if _, nbuf, err := msgp.ReadUint32Bytes(b); err == nil { // Read metadata CRC (added in v2, ignore if not found) b = nbuf } _, err = msgp.CopyToJSON(buf, bytes.NewReader(v)) if err != nil { return nil, err } data = b case 3:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1) -
cmd/erasure-server-pool.go
derrs := make([]error, len(poolIndices)) dobjects := make([]ObjectInfo, len(poolIndices)) // Delete concurrently in all server pools that reported no error or read quorum error // where the read quorum issue is from metadata inconsistency. var wg sync.WaitGroup for idx, pe := range poolIndices { if v, ok := pe.Err.(InsufficientReadQuorum); ok && v.Type != RQInconsistentMeta {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/metrics-v2.go
return MetricDescription{ Namespace: nodeMetricNamespace, Subsystem: ioSubsystem, Name: readBytes, Help: "Total bytes read by the process from the underlying storage system, /proc/[pid]/io read_bytes", Type: counterMetric, } } func getMinioProcessIOWriteCachedBytesMD() MetricDescription { return MetricDescription{ Namespace: nodeMetricNamespace,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0)