- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for SZ (0.02 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) -
cmd/sftp-server-driver.go
"param": s.Filepath, "source": source, }, } } func (m *sftpMetrics) log(s *sftp.Request, user string) func(sz int64, err error) { startTime := time.Now() source := getSource(2) return func(sz int64, err error) { globalTrace.Publish(sftpTrace(s, startTime, source, user, err, sz)) } } // NewSFTPDriver initializes sftp.Handlers implementation of following interfaces // // - sftp.Fileread
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 11.1K 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) -
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) -
cmd/bucket-replication-utils.go
Targets []replicatedTargetInfo } func (ri replicatedInfos) CompletedSize() (sz int64) { for _, t := range ri.Targets { if t.Empty() { continue } if t.ReplicationStatus == replication.Completed && t.PrevReplicationStatus != replication.Completed { sz += t.Size } } return sz }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 26.3K 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) -
src/cmd/asm/internal/asm/asm.go
return } p.dataAddr[name] = nameAddr.Offset + int64(sz) switch valueAddr.Type { case obj.TYPE_CONST: switch sz { case 1, 2, 4, 8: nameAddr.Sym.WriteInt(p.ctxt, nameAddr.Offset, int(sz), valueAddr.Offset) default: p.errorf("bad int size for DATA argument: %d", sz) } case obj.TYPE_FCONST: switch sz { case 4:
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Oct 21 14:11:44 UTC 2024 - 25.5K 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) -
cmd/metacache-stream.go
} r.err = err return err } // Read name without allocating more than 1 buffer. sz, err := r.mr.ReadStringHeader() if err != nil { r.err = err return err } if cap(tmp) < int(sz) { tmp = make([]byte, 0, sz+256) } tmp = tmp[:sz] _, err = r.mr.R.ReadFull(tmp) if err != nil { r.err = err return err } if string(tmp) >= s {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 19.5K bytes - Viewed (0)