- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for SZ (0.07 sec)
-
cmd/bucket-stats.go
return bs.FailStats.SinceUptime.Count > 0 || bs.ReplicatedSize > 0 || bs.ReplicaSize > 0 } func (bs *BucketReplicationStat) updateXferRate(sz int64, duration time.Duration) { if sz > minLargeObjSize { bs.XferRateLrg.addSize(sz, duration) } else { bs.XferRateSml.addSize(sz, duration) } } // RMetricName - name of replication metric type RMetricName string const (
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 11:39:51 UTC 2024 - 13.4K bytes - Viewed (0) -
internal/grid/types.go
} // NewJSONPool returns a new JSONPool. func NewJSONPool[T any]() *JSONPool[T] { var t T sz := 128 if b, err := json.Marshal(t); err != nil { sz = len(b) } return &JSONPool[T]{ 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
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 15.5K bytes - Viewed (0) -
internal/bucket/lifecycle/filter.go
f.Tag = tag f.tagSet = true case "ObjectSizeLessThan": var sz int64 if err = d.DecodeElement(&sz, &se); err != nil { return err } f.ObjectSizeLessThan = sz case "ObjectSizeGreaterThan": var sz int64 if err = d.DecodeElement(&sz, &se); err != nil { return err } f.ObjectSizeGreaterThan = sz default: return errUnknownXMLTag } } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 04 17:01:26 UTC 2024 - 6.2K bytes - Viewed (0) -
cmd/global-heal.go
} } healEntrySuccess := func(sz uint64) healEntryResult { return healEntryResult{ bytes: sz, success: true, } } healEntryFailure := func(sz uint64) healEntryResult { return healEntryResult{ bytes: sz, } } healEntrySkipped := func(sz uint64) healEntryResult { return healEntryResult{ bytes: sz, skipped: true, } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.3K bytes - Viewed (0) -
cmd/ftp-server-driver.go
"source": source, }, } } func (m *ftpMetrics) log(s *ftp.Context, paths ...string) func(sz int64, err error) { startTime := time.Now() source := getSource(2) return func(sz int64, err error) { globalTrace.Publish(ftpTrace(s, startTime, source, strings.Join(paths, " "), err, sz)) } } // Stat implements ftpDriver
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 14K bytes - Viewed (0) -
compat/maven-artifact/src/main/java/org/apache/maven/artifact/versioning/DefaultArtifactVersion.java
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 6K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
ctx, done, err := p.TrackDiskHealth(ctx, storageMetricReadAll, volume, path) if err != nil { return nil, err } var sz int defer func() { sz = len(buf) done(int64(sz), &err) }() return xioutil.WithDeadline[[]byte](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (result []byte, err error) { return p.storage.ReadAll(ctx, volume, path)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:56:26 UTC 2024 - 34.5K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
func (r *ReplicationStats) incQ(bucket string, sz int64, isDeleteRepl bool, opType replication.Type) { r.qCache.Lock() defer r.qCache.Unlock() v, ok := r.qCache.bucketStats[bucket] if !ok { v = newInQueueStats(r.registry, bucket) } atomic.AddInt64(&v.nowBytes, sz) atomic.AddInt64(&v.nowCount, 1) r.qCache.bucketStats[bucket] = v atomic.AddInt64(&r.qCache.srQueueStats.nowBytes, sz)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 13.6K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
// of bucket metadata zipWriter := zip.NewWriter(w) defer zipWriter.Close() rawDataFn := func(r io.Reader, filename string, sz int) { header, zerr := zip.FileInfoHeader(dummyFileInfo{ name: filename, size: int64(sz), mode: 0o600, modTime: time.Now(), isDir: false, sys: nil, }) if zerr == nil { header.Method = zip.Deflate
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 33.2K bytes - Viewed (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/props/MavenProperties.java
if (str == null) { return null; } int sz = str.length(); StringBuilder out = new StringBuilder(sz); StringBuilder unicode = new StringBuilder(UNICODE_LEN); boolean hadSlash = false; boolean inUnicode = false; for (int i = 0; i < sz; i++) { char ch = str.charAt(i); if (inUnicode) {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 38.2K bytes - Viewed (0)