mirror of
https://github.com/minio/minio.git
synced 2024-12-24 06:05:55 -05:00
use bucket in path in distribution hash (#11634)
Use bucket in erasure distribution hash. For the rare cases where objects with the same names are uploaded to many buckets.
This commit is contained in:
parent
a8e4f64ff3
commit
85620dfe93
@ -283,7 +283,7 @@ func (er erasureObjects) newMultipartUpload(ctx context.Context, bucket string,
|
|||||||
}
|
}
|
||||||
|
|
||||||
dataBlocks := len(onlineDisks) - parityBlocks
|
dataBlocks := len(onlineDisks) - parityBlocks
|
||||||
fi := newFileInfo(object, dataBlocks, parityBlocks)
|
fi := newFileInfo(pathJoin(bucket, object), dataBlocks, parityBlocks)
|
||||||
|
|
||||||
// we now know the number of blocks this object needs for data and parity.
|
// we now know the number of blocks this object needs for data and parity.
|
||||||
// establish the writeQuorum using this data
|
// establish the writeQuorum using this data
|
||||||
|
@ -654,7 +654,7 @@ func (er erasureObjects) putObject(ctx context.Context, bucket string, object st
|
|||||||
// Initialize parts metadata
|
// Initialize parts metadata
|
||||||
partsMetadata := make([]FileInfo, len(storageDisks))
|
partsMetadata := make([]FileInfo, len(storageDisks))
|
||||||
|
|
||||||
fi := newFileInfo(object, dataDrives, parityDrives)
|
fi := newFileInfo(pathJoin(bucket, object), dataDrives, parityDrives)
|
||||||
|
|
||||||
if opts.Versioned {
|
if opts.Versioned {
|
||||||
fi.VersionID = opts.VersionID
|
fi.VersionID = opts.VersionID
|
||||||
|
Loading…
Reference in New Issue
Block a user