- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 63 for ErasureN (0.12 sec)
-
cmd/erasure-coding.go
"github.com/minio/minio/internal/logger" ) // Erasure - erasure encoding details. type Erasure struct { encoder func() reedsolomon.Encoder dataBlocks, parityBlocks int blockSize int64 } // NewErasure creates a new ErasureStorage. func NewErasure(ctx context.Context, dataBlocks, parityBlocks int, blockSize int64) (e Erasure, err error) { // Check the parameters for sanity now.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 8.6K bytes - Viewed (0) -
cmd/erasure-heal_test.go
writers := make([]io.Writer, len(disks)) for i, disk := range disks { writers[i] = newBitrotWriter(disk, "", "testbucket", "testobject", erasure.ShardFileSize(test.size), test.algorithm, erasure.ShardSize()) } _, err = erasure.Encode(context.Background(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1) closeBitrotWriters(writers) if err != nil { t.Fatalf("Test %d: failed to create random test data: %v", i, err) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 7.9K bytes - Viewed (0) -
cmd/erasure-sets_test.go
if err != errInvalidArgument { t.Fatalf("Expecting error, got %s", err) } // Initializes all erasure disks storageDisks, format, err := waitForFormatErasure(true, endpoints, 1, 1, 16, "") if err != nil { t.Fatalf("Unable to format drives for erasure, %s", err) } ep := PoolEndpoints{Endpoints: endpoints} parity, err := ecDrivesNoConfig(16) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 12 07:21:56 UTC 2024 - 6.9K bytes - Viewed (0) -
cmd/erasure-encode.go
return fmt.Errorf("%w (offline-disks=%d/%d)", writeErr, countErrs(p.errs, errDiskNotFound), len(p.writers)) } // Encode reads from the reader, erasure-encodes the data and writes to the writers. func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) { writer := &multiWriter{ writers: writers, writeQuorum: quorum,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.9K bytes - Viewed (0) -
cmd/erasure-decode.go
shardSize int64 shardFileSize int64 buf [][]byte readerToBuf []int stashBuffer []byte } // newParallelReader returns parallelReader. func newParallelReader(readers []io.ReaderAt, e Erasure, offset, totalLength int64) *parallelReader { r2b := make([]int, len(readers)) for i := range r2b { r2b[i] = i } bufs := make([][]byte, len(readers)) // Fill buffers b := globalBytePoolCap.Load().Get()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 21 14:36:21 UTC 2024 - 9.4K bytes - Viewed (0) -
cmd/metrics-v3-cluster-erasure-set.go
erasureSetReadQuorumMD = NewGaugeMD(erasureSetReadQuorum, "Read quorum for the erasure set in a pool", poolIDL, setIDL) erasureSetWriteQuorumMD = NewGaugeMD(erasureSetWriteQuorum, "Write quorum for the erasure set in a pool", poolIDL, setIDL) erasureSetOnlineDrivesCountMD = NewGaugeMD(erasureSetOnlineDrivesCount, "Count of online drives in the erasure set in a pool", poolIDL, setIDL)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 14 07:25:56 UTC 2024 - 4.4K bytes - Viewed (0) -
buildscripts/verify-healing-empty-erasure-set.sh
chmod +x /tmp/mc fi } function perform_test() { start_minio_3_node $2 echo "Testing Distributed Erasure setup healing of drives" echo "Remove the contents of the disks belonging to '${1}' erasure set" rm -rf ${WORK_DIR}/${1}/*/ set -x start_minio_3_node $2 } function main() { # use same ports for all tests
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 31 14:48:50 UTC 2024 - 3.9K bytes - Viewed (0) -
cmd/erasure-server-pool-decom_test.go
meta := objLayer1.(*erasureServerPools).poolMeta pools := objLayer1.(*erasureServerPools).serverPools objLayer2, fsDirs, err := prepareErasurePools() if err != nil { t.Fatalf("Initialization of object layer failed for Erasure setup: %s", err) } defer removeRoots(fsDirs) newPools := objLayer2.(*erasureServerPools).serverPools reducedPools := pools[1:] orderChangePools := []*erasureSets{ pools[1], pools[0], }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jul 03 16:47:40 UTC 2023 - 4.8K bytes - Viewed (0) -
cmd/erasure-utils.go
Harshavardhana <******@****.***> 1706667105 -0800
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 3.1K bytes - Viewed (0) -
.github/workflows/mint/minio-erasure.yaml
Harshavardhana <******@****.***> 1699046298 -0700
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Nov 03 21:18:18 UTC 2023 - 1.2K bytes - Viewed (0)