- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 215 for cout (0.18 sec)
-
cmd/metacache-entries.go
// If the context is canceled the function will return the error, // otherwise the function will return nil. func mergeEntryChannels(ctx context.Context, in []chan metaCacheEntry, out chan<- metaCacheEntry, readQuorum int) error { defer xioutil.SafeClose(out) top := make([]*metaCacheEntry, len(in)) nDone := 0 ctxDone := ctx.Done() // Use simpler forwarder. if len(in) == 1 { for { select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/object-api-utils.go
for _, disk := range di { if disk == nil || disk.Total == 0 { continue } if !globalIsErasureSD && disk.FreeInodes < diskMinInodes && disk.UsedInodes > 0 { // We have an inode count, but not enough inodes. return false, nil } if int64(disk.Free) <= perDisk { return false, nil } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
cmd/format-erasure.go
for _, format := range formats { if format == nil { continue } formatCountMap[format.Drives()]++ } maxDrives := 0 maxCount := 0 for drives, count := range formatCountMap { if count > maxCount { maxCount = count maxDrives = drives } } if maxDrives == 0 { return nil, errErasureReadQuorum } if maxCount < len(formats)/2 { return nil, errErasureReadQuorum
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/metrics-v3-cluster-health.go
import "context" const ( healthDrivesOfflineCount = "drives_offline_count" healthDrivesOnlineCount = "drives_online_count" healthDrivesCount = "drives_count" ) var ( healthDrivesOfflineCountMD = NewGaugeMD(healthDrivesOfflineCount, "Count of offline drives in the cluster") healthDrivesOnlineCountMD = NewGaugeMD(healthDrivesOnlineCount, "Count of online drives in the cluster")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 3.9K bytes - Viewed (0) -
tests/associations_has_many_test.go
CheckPet(t, pets[0], *user.Pets[0]) if count := DB.Model(&user).Where("name = ?", user.Pets[1].Name).Association("Pets").Count(); count != 1 { t.Fatalf("should only find one pets, but got %v", count) } if count := DB.Model(&user).Where("name = ?", "not found").Association("Pets").Count(); count != 0 { t.Fatalf("should only find no pet with invalid conditions, but got %v", count) } // Count AssertAssociationCount(t, user, "Pets", 2, "")
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Dec 15 08:36:08 GMT 2023 - 15.6K bytes - Viewed (0) -
cmd/site-replication-metrics.go
LastMinute ReplicationLastMinute // Error counts ErrCounts map[string]int `json:"errCounts"` // Count of credential errors } func (rt *RTimedMetrics) String() string { s := rt.toMetric() return fmt.Sprintf("Errors in LastMinute: %v, LastHour: %v, SinceUptime: %v", s.LastMinute.Count, s.LastHour.Count, s.Totals.Count) } func (rt *RTimedMetrics) toMetric() madmin.TimedErrStats { if rt == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
cmd/storage-rest-server.go
func (s *storageRESTServer) ListDirHandler(ctx context.Context, params *grid.MSS, out chan<- *ListDirResult) *grid.RemoteErr { if !s.checkID(params.Get(storageRESTDiskID)) { return grid.NewRemoteErr(errDiskNotFound) } volume := params.Get(storageRESTVolume) dirPath := params.Get(storageRESTDirPath) origvolume := params.Get(storageRESTOrigVolume) count, err := strconv.Atoi(params.Get(storageRESTCount)) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/os_unix.go
nameTmp := direntNamePool.Get().(*[]byte) defer direntNamePool.Put(nameTmp) tmp := *nameTmp boff := 0 // starting read position in buf nbuf := 0 // end valid data in buf count := opts.count for count != 0 { if boff >= nbuf { boff = 0 stop := globalOSMetrics.time(osMetricReadDirent) nbuf, err = syscall.ReadDirent(fd, buf) stop() if err != nil { if isSysErrNotDir(err) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.3K bytes - Viewed (0) -
src/bytes/bytes.go
// overflows. func Repeat(b []byte, count int) []byte { if count == 0 { return []byte{} } // Since we cannot return an error on overflow, // we should panic if the repeat will generate an overflow. // See golang.org/issue/16237. if count < 0 { panic("bytes: negative Repeat count") } if len(b) >= maxInt/count { panic("bytes: Repeat output length overflow") }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Feb 19 19:51:15 GMT 2024 - 33.8K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
pd.QueuedBuckets = append(pd.QueuedBuckets[:i], pd.QueuedBuckets[i+1:]...) // Clear tracker info. if pd.Bucket == bucket { pd.Bucket = "" // empty this out for next bucket pd.Prefix = "" // empty this out for the next bucket pd.Object = "" // empty this out for next object } return true } } return false } func (pd *PoolDecommissionInfo) isBucketDecommissioned(bucket string) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1)