Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 57 for UnixNano (0.05 seconds)

  1. cmd/benchmark-utils_test.go

    func getRandomByte() []byte {
    	const letterBytes = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"
    	// seeding the random number generator.
    	rand.Seed(UTCNow().UnixNano())
    	// pick a character randomly.
    	return []byte{letterBytes[rand.Intn(len(letterBytes))]}
    }
    
    // picks a random byte and repeats it to size bytes.
    func generateBytesData(size int) []byte {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  2. cmd/server-main.go

    		return
    	}
    
    	globalTrace.Publish(info)
    }
    
    func initServerConfig(ctx context.Context, newObject ObjectLayer) error {
    	t1 := time.Now()
    
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	for {
    		select {
    		case <-ctx.Done():
    			// Retry was canceled successfully.
    			return fmt.Errorf("Initializing sub-systems stopped gracefully %w", ctx.Err())
    		default:
    		}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  3. cmd/site-replication-utils.go

    	}
    	go s.save(ctx)
    	go s.init(ctx)
    	return &s
    }
    
    // init site resync metrics
    func (sm *siteResyncMetrics) init(ctx context.Context) {
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	// Run the site resync metrics load in a loop
    	for {
    		if err := sm.load(ctx, newObjectLayerFn()); err == nil {
    			<-ctx.Done()
    			return
    		}
    		duration := max(time.Duration(r.Float64()*float64(time.Second*10)),
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  4. cmd/batch-rotate.go

    		retryAttempts = batchKeyRotateJobDefaultRetries
    	}
    	delay := job.KeyRotate.Flags.Retry.Delay
    	if delay <= 0 {
    		delay = batchKeyRotateJobDefaultRetryDelay
    	}
    
    	rnd := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	selectObj := func(info FileInfo) (ok bool) {
    		if r.Flags.Filter.OlderThan > 0 && time.Since(info.ModTime) < r.Flags.Filter.OlderThan {
    			// skip all objects that are newer than specified older duration
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  5. cmd/tier.go

    	}
    }
    
    func (config *TierConfigMgr) refreshTierConfig(ctx context.Context, objAPI ObjectLayer) {
    	const tierCfgRefresh = 15 * time.Minute
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	randInterval := func() time.Duration {
    		return time.Duration(r.Float64() * 5 * float64(time.Second))
    	}
    
    	// To avoid all MinIO nodes reading the tier config object at the same
    	// time.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  6. internal/logger/logger.go

    			logKind = ek
    		}
    	}
    
    	req := GetReqInfo(ctx)
    	if req == nil {
    		req = &ReqInfo{
    			API:       "SYSTEM",
    			RequestID: fmt.Sprintf("%X", time.Now().UTC().UnixNano()),
    		}
    	}
    	req.RLock()
    	defer req.RUnlock()
    
    	API := "SYSTEM"
    	switch {
    	case req.API != "":
    		API = req.API
    	case subsystem != "":
    		API += "." + subsystem
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  7. cmd/erasure-decode_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	if n != length {
    		t.Errorf("erasureCreateFile returned %d, expected %d", n, length)
    	}
    
    	// To generate random offset/length.
    	r := rand.New(rand.NewSource(UTCNow().UnixNano()))
    
    	buf := &bytes.Buffer{}
    
    	// Verify erasure.Decode() for random offsets and lengths.
    	for range iterations {
    		offset := r.Int63n(length)
    		readLen := r.Int63n(length - offset)
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 21K bytes
    - Click Count (0)
  8. cmd/object-api-utils.go

    // returns an online host (and corresponding port) from a slice of DNS records
    func getHostFromSrv(records []dns.SrvRecord) (host string) {
    	hosts := getHostsSlice(records)
    	rng := rand.New(rand.NewSource(time.Now().UTC().UnixNano()))
    	var d net.Dialer
    	var retry int
    	for retry < len(hosts) {
    		ctx, cancel := context.WithTimeout(GlobalContext, 300*time.Millisecond)
    
    		host = hosts[rng.Intn(len(hosts))]
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 37.3K bytes
    - Click Count (0)
  9. cmd/xl-storage-format-v2.go

    			VersionID: uv,
    			ModTime:   fi.ModTime.UnixNano(),
    			MetaSys:   make(map[string][]byte),
    		}
    	} else {
    		ventry.Type = ObjectType
    		ventry.ObjectV2 = &xlMetaV2Object{
    			VersionID:          uv,
    			DataDir:            dd,
    			Size:               fi.Size,
    			ModTime:            fi.ModTime.UnixNano(),
    			ErasureAlgorithm:   ReedSolomon,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 65.6K bytes
    - Click Count (1)
  10. cmd/iam.go

    	loadDuration := time.Since(loadStartTime)
    
    	atomic.StoreUint64(&sys.LastRefreshDurationMilliseconds, uint64(loadDuration.Milliseconds()))
    	atomic.StoreUint64(&sys.LastRefreshTimeUnixNano, uint64(loadStartTime.Add(loadDuration).UnixNano()))
    	atomic.AddUint64(&sys.TotalRefreshSuccesses, 1)
    
    	if !globalSiteReplicatorCred.IsValid() {
    		sa, _, err := sys.getServiceAccount(ctx, siteReplicatorSvcAcc)
    		if err == nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 76.5K bytes
    - Click Count (0)
Back to Top