Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 56 for isStale (0.05 seconds)

  1. cmd/erasure-healing.go

    				if disk == OfflineDisk {
    					continue
    				}
    
    				// A non-nil stale disk which did not receive
    				// a healed part checksum had a write error.
    				if writers[i] == nil {
    					outDatedDisks[i] = nil
    					disksToHealCount--
    					continue
    				}
    
    				// A non-nil stale disk which got error on Close()
    				if closeErrs[i] != nil {
    					outDatedDisks[i] = nil
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  2. cmd/bucket-metadata-sys.go

    	sys.Lock()
    	for _, bucket := range buckets {
    		sys.group.Forget(bucket)
    		delete(sys.metadataMap, bucket)
    		globalBucketMonitor.DeleteBucket(bucket)
    	}
    	sys.Unlock()
    }
    
    // RemoveStaleBuckets removes all stale buckets in memory that are not on disk.
    func (sys *BucketMetadataSys) RemoveStaleBuckets(diskBuckets set.StringSet) {
    	sys.Lock()
    	defer sys.Unlock()
    
    	for bucket := range sys.metadataMap {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  3. cmd/bucket-targets.go

    				sys.hMutex.Unlock()
    			}
    			hcTimer.Reset(defaultHealthCheckDuration)
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    // periodically rebuild the healthCheck map from list of targets to clear
    // out stale endpoints
    func (sys *BucketTargetSys) reloadHealthCheckers(ctx context.Context) {
    	m := make(map[string]epHealth)
    	tgts := sys.ListTargets(ctx, "", "")
    	sys.hMutex.Lock()
    	for _, t := range tgts {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 20.9K bytes
    - Click Count (0)
  4. cmd/site-replication.go

    		epDeplIDMap[p.Endpoint] = p.DeploymentID
    	}
    	// fix stale ARN's in replication config and endpoint mismatch between site config and
    	// targets associated to this config.
    	if rcfg != nil {
    		for _, rule := range rcfg.Rules {
    			if rule.Status != sreplication.Status(replication.Disabled) {
    				tgt, isValidARN := arnTgtMap[rule.Destination.ARN] // detect stale ARN in replication config
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  5. cmd/admin-handlers.go

    		if err != nil {
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    	}
    	stale := r.Form.Get("stale") == "true" // list also stale locks
    
    	peerLocks := globalNotificationSys.GetLocks(ctx, r)
    
    	topLocks := topLockEntries(peerLocks, stale)
    
    	// Marshal API response upto requested count.
    	if len(topLocks) > count && count > 0 {
    		topLocks = topLocks[:count]
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  6. cmd/peer-s3-client.go

    				}
    				bucketsMap[bi.Name]++
    				if bucketsMap[bi.Name] >= quorum {
    					resultMap[bi.Name] = bi
    				}
    			}
    		}
    		// loop through buckets and see if some with lost quorum
    		// these could be stale buckets lying around, queue a heal
    		// of such a bucket. This is needed here as we identify such
    		// buckets here while listing buckets. As part of regular
    		// globalBucketMetadataSys.Init() call would get a valid
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  7. cmd/storage-rest-client.go

    		// value is cached we should attempt to invalidate it if such calls
    		// were attempted. This can lead to false success under certain conditions
    		// - this change attempts to avoid stale information if the underlying
    		// transport is already down.
    		return "", errDiskNotFound
    	}
    
    	// This call should never be over the network, this is always
    	// a cached value - caller should make sure to use this
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  8. internal/lru/lru.go

    		}
    		c.evictList.MoveToFront(ent)
    		return ent.Value, true
    	}
    	return
    }
    
    // Contains checks if a key is in the cache, without updating the recent-ness
    // or deleting it for being stale.
    func (c *LRU[K, V]) Contains(key K) (ok bool) {
    	c.mu.Lock()
    	defer c.mu.Unlock()
    	_, ok = c.items[key]
    	return ok
    }
    
    // Peek returns the key value (or undefined if not found) without updating
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 12.5K bytes
    - Click Count (0)
  9. docs/pt/docs/index.md

    ## Instalação { #installation }
    
    Crie e ative um <a href="https://fastapi.tiangolo.com/pt/virtual-environments/" class="external-link" target="_blank">ambiente virtual</a> e então instale o FastAPI:
    
    <div class="termy">
    
    ```console
    $ pip install "fastapi[standard]"
    
    ---> 100%
    ```
    
    </div>
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Dec 16 20:32:40 GMT 2025
    - 24.5K bytes
    - Click Count (0)
  10. cmd/bucket-replication-handlers.go

    		if clnt == nil {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErrWithErr(ErrRemoteTargetNotFoundError, fmt.Errorf("replication config with rule ID %s has a stale target", rule.ID)), r.URL)
    			return
    		}
    		if lockEnabled {
    			lock, _, _, _, err := clnt.GetObjectLockConfig(ctx, clnt.Bucket)
    			if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 15 12:04:40 GMT 2024
    - 23.3K bytes
    - Click Count (0)
Back to Top