- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for cursor (0.21 sec)
-
internal/logger/console.go
// message itself contains some colored text, we needed // to use some ANSI control escapes to cursor color state // and freely move in the screen. for _, line := range strings.Split(errMsg, "\n") { if len(line) == 0 { // No more text to print, just quit. break } for { // Save the attributes of the current cursor helps // us save the text color of the passed error message ansiSaveAttributes()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/site-replication-metrics.go
metric.TotalDowntime = epHealth.offlineDuration metric.LastOnline = epHealth.lastOnline metric.Online = epHealth.Online metric.Latency = madmin.LatencyStat{ Curr: epHealth.latency.curr, Avg: epHealth.latency.avg, Max: epHealth.latency.peak, } } m[dID] = metric } return m } func (srs *SRStatus) updateXferRate(sz int64, duration time.Duration) {
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) -
src/archive/tar/writer.go
/* // Write the sparse map and setup the sparse writer if necessary. if len(spd) > 0 { // Use tw.curr since the sparse map is accounted for in hdr.Size. if _, err := tw.curr.Write(spb); err != nil { return err } tw.curr = &sparseFileWriter{tw.curr, spd, 0} } */ return nil } func (tw *Writer) writeGNUHeader(hdr *Header) error {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 19.6K bytes - Viewed (0) -
cmd/bucket-targets.go
} type latencyStat struct { lastmin lastMinuteLatency curr time.Duration avg time.Duration peak time.Duration N int64 } func (l *latencyStat) update(d time.Duration) { l.lastmin.add(d) l.N++ if d > l.peak { l.peak = d } l.curr = l.lastmin.getTotal().avg() l.avg = time.Duration((int64(l.avg)*(l.N-1) + int64(l.curr)) / l.N) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/metrics-v2.go
if qs.QStats.Avg.Count > 0 || qs.QStats.Curr.Count > 0 { qt := qs.QStats currInQueueBytes.Value = qt.Curr.Bytes currInQueueCount.Value = qt.Curr.Count avgQueueBytes.Value = qt.Avg.Bytes avgQueueCount.Value = qt.Avg.Count maxQueueBytes.Value = qt.Max.Bytes maxQueueCount.Value = qt.Max.Count } activeWorkersCount.Value = float64(qs.ActiveWorkers.Curr)
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/bucket-replication-metrics.go
sma *SMA `json:"-"` } // Clone returns a copy of XferStats func (rx *XferStats) Clone() *XferStats { curr := rx.curr() peak := rx.Peak if curr > peak { peak = curr } return &XferStats{ Curr: curr, Avg: rx.Avg, Peak: peak, N: rx.N, measure: rx.measure, } } func newXferStats() *XferStats { return &XferStats{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/bucket-replication-metrics_gen.go
err = msgp.WrapError(err, "Curr") return } for zb0002 > 0 { zb0002-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err, "Curr") return } switch msgp.UnsafeString(field) { case "Count": z.Curr.Count, err = dc.ReadFloat64() if err != nil { err = msgp.WrapError(err, "Curr", "Count") return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 33.3K bytes - Viewed (0) -
src/archive/tar/reader.go
if isHeaderOnlyType(hdr.Typeflag) { nb = 0 } if nb < 0 { return ErrHeader } tr.pad = blockPadding(nb) tr.curr = ®FileReader{r: tr.r, nb: nb} return nil } // handleSparseFile checks if the current file is a sparse format of any type // and sets the curr reader appropriately. func (tr *Reader) handleSparseFile(hdr *Header, rawHdr *block) error { var spd sparseDatas var err error
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
r.RUnlock() } // ActiveWorkers returns worker stats func (r *ReplicationStats) ActiveWorkers() ActiveWorkerStat { r.wlock.RLock() defer r.wlock.RUnlock() w := r.workers.get() return ActiveWorkerStat{ Curr: w.Curr, Max: w.Max, Avg: w.Avg, } } func (r *ReplicationStats) collectWorkerMetrics(ctx context.Context) { if r == nil { return } for { select { case <-ctx.Done():
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
cmd/site-replication.go
sm.ActiveWorkers.Curr += peer.ActiveWorkers.Curr if peer.ActiveWorkers.Max > sm.ActiveWorkers.Max { sm.ActiveWorkers.Max += peer.ActiveWorkers.Max } sm.Queued.Avg.Bytes += peer.Queued.Avg.Bytes sm.Queued.Avg.Count += peer.Queued.Avg.Count sm.Queued.Curr.Bytes += peer.Queued.Curr.Bytes sm.Queued.Curr.Count += peer.Queued.Curr.Count if peer.Queued.Max.Count > sm.Queued.Max.Count {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1)