- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 90 for tozero (0.24 sec)
-
cmd/tier-last-day-stats.go
nowIdx := now.Hour() l.Bins[nowIdx] = l.Bins[nowIdx].add(ts) } // forwardTo moves time to t, clearing entries between last update and t. func (l *lastDayTierStats) forwardTo(t time.Time) { if t.IsZero() { t = time.Now() } since := t.Sub(l.UpdatedAt).Hours() // within the hour since l.UpdatedAt if since < 1 { return } idx, lastIdx := t.Hour(), l.UpdatedAt.Hour()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/erasure-object.go
// in all other cases mtime is latest. fi.VersionID = versionID // set any new versionID we might have created fi.ModTime = modTime // set modTime for the new versionID if !dstOpts.MTime.IsZero() { modTime = dstOpts.MTime fi.ModTime = dstOpts.MTime } // check inline before overwriting metadata. inlineData := fi.InlineData() fi.Metadata = srcInfo.UserDefined
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/metrics.go
bgSeq, exists := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID) if !exists { return } var dur time.Duration if !bgSeq.lastHealActivity.IsZero() { dur = time.Since(bgSeq.lastHealActivity) } ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(healMetricsNamespace, "time", "since_last_activity"),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
defer z.rebalMu.RUnlock() if r := z.rebalMeta; r != nil { if r.StoppedAt.IsZero() { return true } } return false } func (z *erasureServerPools) IsPoolRebalancing(poolIndex int) bool { z.rebalMu.RLock() defer z.rebalMu.RUnlock() if r := z.rebalMeta; r != nil { if !r.StoppedAt.IsZero() { return false } ps := z.rebalMeta.PoolStats[poolIndex]
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) -
internal/grid/types.go
pool: sync.Pool{ New: func() interface{} { var t T return &t }, }, emptySz: sz, } } func (p *JSONPool[T]) new() *T { var zero T t := p.pool.Get().(*T) *t = zero return t } // JSON is a wrapper around a T object that can be serialized. // There is an internal value type JSON[T any] struct { p *JSONPool[T] val *T }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
docs/debugging/s3-check-md5/main.go
for object := range s3Client.ListObjects(context.Background(), bucket, opts) { if object.Err != nil { log.Println("FAILED: LIST with error:", object.Err) continue } if !minModTime.IsZero() && object.LastModified.Before(minModTime) { continue } if object.IsDeleteMarker { log.Println("SKIPPED: DELETE marker object:", objFullPath(object)) continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Feb 17 01:15:57 GMT 2024 - 6.3K bytes - Viewed (0) -
docs/debugging/xattr/main.go
flag.BoolVar(&set, "set", false, "this is a set attribute operation") flag.Parse() if set && value == 0 { log.Fatalln("setting an attribute requires a non-zero value") } if !set && value > 0 { log.Fatalln("to set a value please specify --set along with --value") } table := tablewriter.NewWriter(os.Stdout) table.SetHeader([]string{"Name", "Value"})
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 29 23:52:41 GMT 2023 - 3.2K bytes - Viewed (0) -
cmd/data-usage_test.go
if err != nil { t.Fatal(err) } t.Log("serialized size:", buf.Len(), "bytes") var got dataUsageCache err = got.deserialize(&buf) if err != nil { t.Fatal(err) } if got.Info.LastUpdate.IsZero() { t.Error("lastupdate not set") } if !want.Info.LastUpdate.Equal(got.Info.LastUpdate) { t.Fatalf("deserialize LastUpdate mismatch\nwant: %+v\ngot: %+v", want, got) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 14.1K bytes - Viewed (0) -
cmd/metrics-v2.go
} if startTime > 0 { metrics = append(metrics, MetricV2{ Description: getMinIOProcessStartTimeMD(), Value: startTime, }) } if !globalBootTime.IsZero() { metrics = append(metrics, MetricV2{ Description: getMinIOProcessUptimeMD(), Value: time.Since(globalBootTime).Seconds(), }) } if stat.ResidentMemory() > 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
cmd/untar.go
return } asyncErrMu.Lock() if asyncErr == nil { asyncErr = err } asyncErrMu.Unlock() } }(name, header.FileInfo(), b) continue } // If zero or earlier modtime, set to current. // Otherwise the resulting objects will be invalid. if header.ModTime.UnixNano() <= 0 { header.ModTime = time.Now() } // Sync upload.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0)