Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getCycle (0.04 sec)

  1. cmd/data-scanner-metric.go

    		return AccElem{}
    	}
    	val := p.actionsLatency[a].total()
    	return val
    }
    
    // setCycle updates the current cycle metrics.
    func (p *scannerMetrics) setCycle(c *currentScannerCycle) {
    	if c != nil {
    		c2 := c.clone()
    		c = &c2
    	}
    	p.cycleInfoMu.Lock()
    	p.cycleInfo = c
    	p.cycleInfoMu.Unlock()
    }
    
    // getCycle returns the current cycle metrics.
    // If not nil, the returned value can safely be modified.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    		buf = buf[8:]
    		_, err := cycleInfo.UnmarshalMsg(buf)
    		bugLogIf(ctx, err)
    	}
    
    	scannerTimer := time.NewTimer(scannerCycle.Load())
    	defer scannerTimer.Stop()
    	defer globalScannerMetrics.setCycle(nil)
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-scannerTimer.C:
    			// Reset the timer for next cycle.
    			// If scanner takes longer we start at once.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  3. cmd/testdata/decryptObjectInfo.json.zst

    +0HCLpUFJT/x1CCCFq1Qa7PfdDfsoeN+oG9O4s/OhQggIUcZtEGy+Fyb8Q==","X-Minio-Internal-Server-Side-Encryption-Seal-Algorithm":"DAREv2-HMAC-SHA256","content-type":"application/octet-stream"}},{"Bucket":"buck1","Name":"go_113/src/cmd/go/testdata/src/gencycle/gencycle.go","UserDef":{"X-Minio-Internal-Server-Side-Encryption-Iv":"ycmGL1pqL/cHLvxfhcC/SLbukiPdNrqzTgo3gS/G1Qc=","X-Minio-Internal-Server-Side-Encryption-S3-Kms-Key-Id":"my-minio-key","X-Minio-Internal-Server-Side-Encryption-S3-Kms-Sealed-Key":"IA...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Oct 29 16:34:20 UTC 2020
    - 164K bytes
    - Viewed (0)
Back to top