Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 72 for lastUpdate (0.06 sec)

  1. cmd/bucket-metadata-sys.go

    					wait() // wait to proceed to next entry.
    					continue
    				}
    
    				sys.Lock()
    				// Update if the bucket metadata in the memory is older than on-disk one
    				if lu := sys.metadataMap[bucket].lastUpdate(); lu.Before(meta.lastUpdate()) {
    					updated = true
    					sys.metadataMap[bucket] = meta
    				}
    				sys.Unlock()
    
    				if updated {
    					globalEventNotifier.set(bucket, meta)
    					globalBucketTargetSys.set(bucket, meta)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  2. cmd/data-usage-cache.go

    		return
    	}
    	if otherRoot == nil {
    		return
    	}
    	if existingRoot == nil {
    		*d = other.clone()
    		return
    	}
    	if other.Info.LastUpdate.After(d.Info.LastUpdate) {
    		d.Info.LastUpdate = other.Info.LastUpdate
    	}
    	existingRoot.merge(*otherRoot)
    	eHash := d.rootHash()
    	for key := range otherRoot.Children {
    		entry := other.Cache[key]
    		flat := other.flatten(entry)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  3. cmd/data-usage-cache_gen.go

    			}
    		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
    			}
    		case "SkipHealing":
    			z.SkipHealing, err = dc.ReadBool()
    			if err != nil {
    				err = msgp.WrapError(err, "SkipHealing")
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 85.5K bytes
    - Viewed (0)
  4. cmd/bucket-metadata.go

    	LifecycleConfigUpdatedAt         time.Time
    	NotificationConfigUpdatedAt      time.Time
    	BucketTargetsConfigUpdatedAt     time.Time
    	BucketTargetsConfigMetaUpdatedAt time.Time
    	// Add a new UpdatedAt field and update lastUpdate function
    
    	// Unexported fields. Must be updated atomically.
    	policyConfig           *policy.BucketPolicy
    	notificationConfig     *event.Config
    	lifecycleConfig        *lifecycle.Lifecycle
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 18.2K bytes
    - Viewed (0)
  5. cmd/data-scanner.go

    func (f *folderScanner) sendUpdate() {
    	// Send at most an update every minute.
    	if f.updates == nil || time.Since(f.lastUpdate) < time.Minute {
    		return
    	}
    	if flat := f.updateCache.sizeRecursive(f.newCache.Info.Name); flat != nil {
    		select {
    		case f.updates <- flat.clone():
    		default:
    		}
    		f.lastUpdate = time.Now()
    	}
    }
    
    // scanFolder will scan the provided folder.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    			for _, info := range results {
    				if info.Info.LastUpdate.IsZero() {
    					// Not filled yet.
    					return
    				}
    				allMerged.merge(info)
    			}
    			if allMerged.root() != nil && allMerged.Info.LastUpdate.After(lastUpdate) {
    				updates <- allMerged.dui(allMerged.Info.Name, allBuckets)
    				lastUpdate = allMerged.Info.LastUpdate
    			}
    		}
    		for {
    			select {
    			case <-ctx.Done():
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 89.2K bytes
    - Viewed (0)
  7. cmd/metrics.go

    		return
    	}
    
    	dataUsageInfo, err := loadDataUsageFromBackend(GlobalContext, objLayer)
    	if err != nil {
    		return
    	}
    	// data usage has not captured any data yet.
    	if dataUsageInfo.LastUpdate.IsZero() {
    		return
    	}
    
    	for bucket, usageInfo := range dataUsageInfo.BucketsUsage {
    		stat := globalReplicationStats.Load().getLatestReplicationStats(bucket)
    		// Total space used by bucket
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:06:31 UTC 2025
    - 16.7K bytes
    - Viewed (0)
  8. cmd/bucket-replication.go

    				for _, st := range brs.TargetsMap {
    					if st.LastUpdate.Equal(timeSentinel) {
    						updt = true
    						break
    					}
    				}
    				// Save the replication status if a new stats update is found and not saved in the backend yet
    				if brs.LastUpdate.After(lastResyncStatusSave[bucket]) {
    					updt = true
    				}
    				if updt {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 118.2K bytes
    - Viewed (0)
  9. cmd/bucket-replication-handlers.go

    			continue
    		}
    		rinfo.Targets = append(rinfo.Targets, ResyncTarget{
    			Arn:             tarn,
    			ResetID:         st.ResyncID,
    			StartTime:       st.StartTime,
    			EndTime:         st.LastUpdate,
    			ResyncStatus:    st.ResyncStatus.String(),
    			ReplicatedSize:  st.ReplicatedSize,
    			ReplicatedCount: st.ReplicatedCount,
    			FailedSize:      st.FailedSize,
    			FailedCount:     st.FailedCount,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  10. cmd/metrics-v2.go

    			return metrics
    		}
    
    		// data usage has not captured any data yet.
    		if dataUsageInfo.LastUpdate.IsZero() {
    			return metrics
    		}
    
    		metrics = append(metrics, MetricV2{
    			Description: getUsageLastScanActivityMD(),
    			Value:       float64(time.Since(dataUsageInfo.LastUpdate)),
    		})
    
    		var (
    			clusterSize               uint64
    			clusterBuckets            uint64
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 133.6K bytes
    - Viewed (0)
Back to top