- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for uint64_t (0.17 sec)
-
cmd/erasure-server-pool-rebalance.go
Object string `json:"object" msg:"ob"` // Last rebalanced object NumObjects uint64 `json:"numObjects" msg:"no"` // Number of objects rebalanced NumVersions uint64 `json:"numVersions" msg:"nv"` // Number of versions rebalanced Bytes uint64 `json:"bytes" msg:"bs"` // Number of bytes rebalanced
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
totalWrites atomic.Uint64 totalDeletes atomic.Uint64 totalErrsAvailability atomic.Uint64 // Captures all data availability errors such as faulty disk, timeout errors. totalErrsTimeout atomic.Uint64 // Captures all timeout only errors // apiCalls should be placed first so alignment is guaranteed for atomic operations. apiCalls [storageMetricLast]uint64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
internal/event/name.go
} return res default: return []Name{name} } } // Mask returns the type as mask. // Compound "All" types are expanded. func (name Name) Mask() uint64 { if name < objectSingleTypesEnd { return 1 << (name - 1) } var mask uint64 for _, n := range name.Expand() { mask |= 1 << (n - 1) } return mask } // String - returns string representation of event type.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 10.4K bytes - Viewed (0) -
cmd/erasure-server-pool.go
type poolAvailableSpace struct { Index int Available uint64 // in bytes MaxUsedPct int // Used disk percentage of most filled disk, rounded down. } // TotalAvailable - total available space func (p serverPoolsAvailableSpace) TotalAvailable() uint64 { total := uint64(0) for _, z := range p { total += z.Available } return total }
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/endpoint-ellipses.go
setIndexes [][]uint64 // All the sets. } // Supported set sizes this is used to find the optimal // single set size. var setSizes = []uint64{2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16} // getDivisibleSize - returns a greatest common divisor of // all the ellipses sizes. func getDivisibleSize(totalSizes []uint64) (result uint64) { gcd := func(x, y uint64) uint64 { for y != 0 { x, y = y, x%y }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 14.7K bytes - Viewed (0) -
internal/grid/grid_test.go
runtime.Gosched() stats := c.Stats() if stats.IncomingStreams != 0 { if i > 0 { time.Sleep(100 * time.Millisecond) continue } var found []uint64 c.inStream.Range(func(key uint64, value *muxServer) bool { found = append(found, key) return true }) t.Errorf("expected no active streams, got %d incoming: %v", stats.IncomingStreams, found) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/xl-storage.go
return dataUsageInfo, nil } func (s *xlStorage) getDeleteAttribute() uint64 { attr := "user.total_deletes" buf, err := xattr.LGet(s.formatFile, attr) if err != nil { // We start off with '0' if we can read the attributes return 0 } return binary.LittleEndian.Uint64(buf[:8]) } func (s *xlStorage) getWriteAttribute() uint64 { attr := "user.total_writes" buf, err := xattr.LGet(s.formatFile, attr)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/common-main.go
globalBatchJobsMetrics = batchJobMetrics{metrics: make(map[string]*batchJobInfo)} go globalBatchJobsMetrics.purgeJobMetrics() t, _ := minioVersionToReleaseTime(Version) if !t.IsZero() { globalVersionUnix = uint64(t.Unix()) } globalIsCICD = env.Get("MINIO_CI_CD", "") != "" || env.Get("CI", "") != "" console.SetColor("Debug", fcolor.New()) gob.Register(StorageErr("")) gob.Register(madmin.TimeInfo{})
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 35.8K bytes - Viewed (2) -
cmd/bucket-replication.go
h := xxh3.HashString(bucket + object) p.mu.RLock() defer p.mu.RUnlock() if len(p.workers) == 0 { return nil } return p.workers[h%uint64(len(p.workers))] } func (p *ReplicationPool) queueReplicaTask(ri ReplicateObjectInfo) { if p == nil { return } // if object is large, queue it to a static set of large workers
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/metacache-set.go
deletes := make([]uint64, len(infos)) writes := make([]uint64, len(infos)) for index, di := range infos { deletes[index] = di.Metrics.TotalDeletes writes[index] = di.Metrics.TotalWrites } filter := func(list []uint64) (commonCount uint64) { max := 0 signatureMap := map[uint64]int{} for _, v := range list { signatureMap[v]++ }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0)