- Sort Score
- Num 10 results
- Language All
Results 71 - 80 of 362 for disks (0.21 seconds)
-
cmd/xl-storage-format-v1.go
VersionID: m.VersionID, DataDir: m.DataDir, XLV1: true, NumVersions: 1, } return fi, nil } // Signature will return a signature that is expected to be the same across all disks. func (m *xlMetaV1Object) Signature() [4]byte { // Shallow copy c := *m // Zero unimportant fields c.Erasure.Index = 0 c.Minio.Release = "" crc := hashDeterministicString(c.Meta) c.Meta = nil
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Oct 22 15:30:50 GMT 2024 - 8.4K bytes - Click Count (0) -
cmd/storage-rest-client.go
return errInvalidArgument } // MakeVol - create a volume on a remote disk. func (client *storageRESTClient) MakeVol(ctx context.Context, volume string) (err error) { return errInvalidArgument } // ListVols - List all volumes on a remote disk. func (client *storageRESTClient) ListVols(ctx context.Context) (vols []VolInfo, err error) { return nil, errInvalidArgument }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 08 02:38:41 GMT 2025 - 30.4K bytes - Click Count (0) -
cmd/data-scanner-metric.go
} // currentPathUpdater provides a lightweight update function for keeping track of // current objects for each disk. // Returns a function that can be used to update the current object // and a function to call to when processing finished. func (p *scannerMetrics) currentPathUpdater(disk, initial string) (update func(path string), done func()) { initialPtr := unsafe.Pointer(&initial) tracker := ¤tPathTracker{
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Oct 01 06:06:01 GMT 2025 - 9.4K bytes - Click Count (0) -
cmd/xl-storage-format-v2.go
delete(j.MetaUser, xhttp.AmzRestoreRequestDate) } // Signature will return a signature that is expected to be the same across all disks. func (j *xlMetaV2Object) Signature() [4]byte { // Shallow copy c := *j // Zero fields that will vary across disks c.ErasureIndex = 0 // Nil 0 size allownil, so we don't differentiate between nil and 0 len. allEmpty := true for _, tag := range c.PartETags {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 65.6K bytes - Click Count (1) -
cmd/format-erasure_test.go
} func BenchmarkInitStorageDisksMax(b *testing.B) { benchmarkInitStorageDisksN(b, 32*204) } func benchmarkInitStorageDisksN(b *testing.B, nDisks int) { b.ResetTimer() b.ReportAllocs() fsDirs, err := getRandomDisks(nDisks) if err != nil { b.Fatal(err) } endpoints := mustGetNewEndpoints(0, 16, fsDirs...) b.RunParallel(func(pb *testing.PB) { endpoints := endpoints
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12.7K bytes - Click Count (0) -
cmd/object-handlers_test.go
const ( None Fault = iota MissingContentLength TooBigObject TooBigDecodedLength BadSignature BadMD5 MissingUploadID ) // Wrapper for calling HeadObject API handler tests for both Erasure multiple disks and FS single drive setup. func TestAPIHeadObjectHandler(t *testing.T) { ExecObjectLayerAPITest(ExecObjectLayerAPITestArgs{t: t, objAPITest: testAPIHeadObjectHandler, endpoints: []string{"HeadObject"}}) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 163.1K bytes - Click Count (0) -
cmd/globals.go
// Maximum size of default bucket encryption configuration allowed maxBucketSSEConfigSize = 1 * humanize.MiByte // diskFillFraction is the fraction of a disk we allow to be filled. diskFillFraction = 0.99 // diskReserveFraction is the fraction of a disk where we will fill other server pools first. // If all pools reach this, we will use all pools with regular placement. diskReserveFraction = 0.15
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Sep 03 18:23:41 GMT 2024 - 16.2K bytes - Click Count (1) -
cmd/erasure-decode.go
missingPartsHeal := int32(0) // Atomic bool flag. readerIndex := 0 var wg sync.WaitGroup // if readTrigger is true, it implies next disk.ReadAt() should be tried // if readTrigger is false, it implies previous disk.ReadAt() was successful and there is no need // to try reading the next disk. for readTrigger := range readTriggerCh { newBufLK.RLock() canDecode := p.canDecode(newBuf) newBufLK.RUnlock() if canDecode {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 29 01:40:52 GMT 2024 - 9.5K bytes - Click Count (0) -
cmd/notification.go
} } return reply } // Construct a list of offline disks information for a given node. // If offlineHost is empty, do it for the local disks. func getOfflineDisks(offlineHost string, endpoints EndpointServerPools) []madmin.Disk { var offlineDisks []madmin.Disk for _, pool := range endpoints { for _, ep := range pool.Endpoints {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 46K bytes - Click Count (0) -
cmd/metacache-walk.go
ForwardTo string // Limit the number of returned objects if > 0. Limit int // DiskID contains the disk ID of the disk. // Leave empty to not check disk ID. DiskID string } // supported FS for Nlink optimization in readdir. const ( xfs = "XFS" ext4 = "EXT4" ) // WalkDir will traverse a directory and return all entries found. // On success a sorted meta cache stream will be returned.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon May 26 07:06:43 GMT 2025 - 12.6K bytes - Click Count (0)