Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NextCycle (0.23 sec)

  1. cmd/erasure.go

    	if err := oldCache.load(ctx, er, dataUsageCacheName); err != nil {
    		return err
    	}
    
    	// New cache..
    	cache := dataUsageCache{
    		Info: dataUsageCacheInfo{
    			Name:      dataUsageRoot,
    			NextCycle: oldCache.Info.NextCycle,
    		},
    		Cache: make(map[string]dataUsageEntry, len(oldCache.Cache)),
    	}
    
    	// Put all buckets into channel.
    	bucketCh := make(chan BucketInfo, len(buckets))
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  2. cmd/data-usage_test.go

    		t.Fatal(err)
    	}
    	// Changed dir must be picked up in this many cycles.
    	for range dataUsageUpdateDirCycles {
    		got, err = scanDataFolder(t.Context(), nil, &xls, got, getSize, 0, weSleep)
    		got.Info.NextCycle++
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    
    	want = []struct {
    		path       string
    		isNil      bool
    		size, objs int
    		flatten    bool
    		oSizes     sizeHistogram
    	}{
    		{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  3. cmd/data-usage-cache_gen.go

    		case "Name":
    			z.Name, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "Name")
    				return
    			}
    		case "NextCycle":
    			z.NextCycle, err = dc.ReadUint32()
    			if err != nil {
    				err = msgp.WrapError(err, "NextCycle")
    				return
    			}
    		case "LastUpdate":
    			z.LastUpdate, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "LastUpdate")
    				return
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Dec 15 22:50:12 UTC 2024
    - 86.4K bytes
    - Viewed (0)
  4. cmd/data-scanner.go

    	if err != nil {
    		// No useful information...
    		return cache, err
    	}
    	s.newCache.forceCompact(dataScannerCompactAtChildren)
    	s.newCache.Info.LastUpdate = UTCNow()
    	s.newCache.Info.NextCycle = cache.Info.NextCycle
    	return s.newCache, nil
    }
    
    // sendUpdate() should be called on a regular basis when the newCache contains more recent total than previously.
    // May or may not send an update upstream.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  5. cmd/data-usage-cache.go

    type dataUsageEntryInfo struct {
    	Name   string
    	Parent string
    	Entry  dataUsageEntry
    }
    
    type dataUsageCacheInfo struct {
    	// Name of the bucket. Also root element.
    	Name       string
    	NextCycle  uint32
    	LastUpdate time.Time
    	// indicates if the disk is being healed and scanner
    	// should skip healing the disk
    	SkipHealing bool
    
    	// Active lifecycle, if any on the bucket
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.7K bytes
    - Viewed (0)
Back to top