- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 52 for reorder (0.29 sec)
-
.dockerignore
docs/debugging/s3-check-md5/s3-check-md5 docs/debugging/hash-set/hash-set docs/debugging/healing-bin/healing-bin docs/debugging/inspect/inspect docs/debugging/pprofgoparser/pprofgoparser
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 18 20:47:03 GMT 2023 - 384 bytes - Viewed (0) -
.gitignore
docs/debugging/s3-check-md5/s3-check-md5 docs/debugging/hash-set/hash-set docs/debugging/healing-bin/healing-bin docs/debugging/inspect/inspect docs/debugging/pprofgoparser/pprofgoparser docs/debugging/reorder-disks/reorder-disks docs/debugging/populate-hard-links/populate-hardlinks
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Dec 29 23:52:41 GMT 2023 - 707 bytes - Viewed (0) -
cmd/erasure-object.go
// Reorder online disks based on erasure distribution order. // Reorder parts metadata based on erasure distribution order. onlineDisks, metaArr = shuffleDisksAndPartsMetadataByIndex(onlineDisks, metaArr, fi) // For negative length read everything. if length < 0 {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 76.3K bytes - Viewed (2) -
cmd/erasure-healing.go
nfi.Erasure.Checksums = nil } return nfi } // We write at temporary location and then rename to final location. tmpID := mustGetUUID() migrateDataDir := mustGetUUID() // Reorder so that we have data disks first and parity disks next. if !latestMeta.Deleted && len(latestMeta.Erasure.Distribution) != len(availableDisks) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 08 09:26:14 GMT 2024 - 33.1K bytes - Viewed (0) -
internal/s3select/parquet/reader.go
"github.com/minio/minio/internal/s3select/sql" ) // Reader implements reading records from parquet input. type Reader struct { io.Closer r *parquetgo.FileReader } // NewParquetReader creates a Reader2 from a io.ReadSeekCloser. func NewParquetReader(rsc io.ReadSeekCloser, _ *ReaderArgs) (r *Reader, err error) { fr, err := parquetgo.NewFileReader(rsc) if err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 14 13:54:47 GMT 2022 - 4.5K bytes - Viewed (0) -
internal/hash/reader_test.go
} } // Tests hash reader checksum verification. func TestHashReaderVerification(t *testing.T) { testCases := []struct { desc string src io.Reader size int64 actualSize int64 md5hex, sha256hex string err error }{ 0: {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 18 17:00:54 GMT 2023 - 10.3K bytes - Viewed (0) -
internal/s3select/json/reader_test.go
Klaus Post <******@****.***> 1663610716 +0200
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 2.5K bytes - Viewed (0) -
internal/etag/reader.go
// // // Now, we need an io.Reader that can access // // the ETag computed over the content. // reader := etag.Wrap(encryptedContent, content) func Wrap(wrapped, content io.Reader) io.Reader { if t, ok := content.(Tagger); ok { return wrapReader{ Reader: wrapped, Tagger: t, } } return wrapReader{ Reader: wrapped, } } // A Reader wraps an io.Reader and computes the
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.8K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
} // NewElementReader - creates new JSON reader using readCloser. func NewElementReader(ch chan simdjson.Object, err *error, args *json.ReaderArgs) *Reader { return &Reader{ args: args, decoded: ch, err: err, readCloser: nil, } } // safeCloser will wrap a Reader as a ReadCloser. // It is safe to call Close while the reader is being used. type safeCloser struct { closed uint32
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0) -
cmd/last-minute.go
} // Add a new duration data func (l *lastMinuteLatency) addAll(sec int64, a AccElem) { l.forwardTo(sec) winIdx := sec % 60 l.Totals[winIdx].merge(a) l.LastSec = sec } // Merge all recorded latencies of last minute into one func (l *lastMinuteLatency) getTotal() AccElem { var res AccElem sec := time.Now().Unix() l.forwardTo(sec) for _, elem := range l.Totals[:] { res.merge(elem) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Jul 05 17:40:45 GMT 2023 - 4.8K bytes - Viewed (0)