Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 281 for unblock (0.06 sec)

  1. internal/config/config.go

    	siteLK.Lock()
    	s.name = n.name
    	s.region = n.region
    	siteLK.Unlock()
    }
    
    // Name returns currently configured site name
    func (s *Site) Name() string {
    	siteLK.RLock()
    	defer siteLK.RUnlock()
    
    	return s.name
    }
    
    // Region returns currently configured site region
    func (s *Site) Region() string {
    	siteLK.RLock()
    	defer siteLK.RUnlock()
    
    	return s.region
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 37.7K bytes
    - Viewed (0)
  2. cmd/erasure-object-conditional_test.go

    	z.serverPools[0].erasureDisksMu.Lock()
    	xl.getDisks = func() []StorageAPI {
    		for i := range erasureDisks[:8] {
    			erasureDisks[i] = nil
    		}
    		return erasureDisks
    	}
    	z.serverPools[0].erasureDisksMu.Unlock()
    
    	t.Run("if-none-match with read quorum failure", func(t *testing.T) {
    		// Test Case 1: if-none-match (create only if doesn't exist)
    		// With if-none-match: *, this should only succeed if object doesn't exist.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  3. cmd/bucket-stats.go

    	qs.TgtXferStats = make(map[string]map[RMetricName]XferStats)
    	qs.MRFStats = ReplicationMRFStats{
    		LastFailedCount: atomic.LoadUint64(&r.mrfStats.LastFailedCount),
    	}
    
    	r.RLock()
    	defer r.RUnlock()
    
    	brs, ok := r.Cache[bucket]
    	if !ok {
    		return qs
    	}
    	for arn := range brs.Stats {
    		qs.TgtXferStats[arn] = make(map[RMetricName]XferStats)
    	}
    	count := 0
    	var totPeak float64
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.5K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    		return
    	}
    
    	nsLock := objectAPI.NewNSLock(minioMetaBucket, "site-net-perf")
    	lkctx, err := nsLock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(toAPIErrorCode(ctx, err)), r.URL)
    		return
    	}
    	ctx = lkctx.Context()
    	defer nsLock.Unlock(lkctx)
    
    	durationStr := r.Form.Get(peerRESTDuration)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 99.7K bytes
    - Viewed (0)
  5. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlanExecutor.java

                                lock.writeLock().lock();
                                try {
                                    plan();
                                } finally {
                                    lock.writeLock().unlock();
                                }
                            }
                            executePlan();
                        } catch (Exception e) {
                            step.status.compareAndSet(SCHEDULED, FAILED);
    
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Oct 16 06:12:36 UTC 2025
    - 55.1K bytes
    - Viewed (0)
  6. cmd/object_api_suite_test.go

    	globalCompressConfig.Enabled = true
    	globalCompressConfig.MimeTypes = mimeTypes
    	globalCompressConfig.Extensions = extensions
    	globalCompressConfig.AllowEncrypted = encrypt
    	globalCompressConfigMu.Unlock()
    	if encrypt {
    		globalAutoEncryption = encrypt
    		KMS, err := kms.ParseSecretKey("my-minio-key:5lF+0pJM0OWwlQrvK2S/I7W9mO4a6rJJI7wzj7v09cw=")
    		if err != nil {
    			t.Fatal(err)
    		}
    		GlobalKMS = KMS
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  7. cmd/erasure-common.go

    				//
    				// - Do not consume disks which are being healed
    				//
    				// - Future: skip busy disks
    				return
    			}
    
    			mu.Lock()
    			newDisks = append(newDisks, disks[i])
    			mu.Unlock()
    		}()
    	}
    	wg.Wait()
    	return newDisks
    }
    
    func (er erasureObjects) getOnlineLocalDisks() (newDisks []StorageAPI) {
    	disks := er.getOnlineDisks()
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/io/Closer.java

     *   <li>If a {@code Throwable} is thrown in the try block, no exceptions that occur when attempting
     *       to close resources will be thrown from the finally block. The throwable from the try block
     *       will be thrown.
     *   <li>If no exceptions or errors were thrown in the try block, the <i>first</i> exception thrown
     *       by an attempt to close a resource will be thrown.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  9. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/model/ClassExtensionDoc.groovy

        List<BlockDoc> getExtensionBlocks() {
            List<BlockDoc> blocks = []
            mixinClasses.each { mixin ->
                mixin.classBlocks.each { block ->
                    blocks << block.forClass(targetClass)
                }
            }
            extraBlocks.each { block->
                blocks << block.forClass(targetClass)
            }
            return blocks.sort { it.name }
        }
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 2.5K bytes
    - Viewed (0)
  10. KEYS.md

    To do this, run the following command:
    
    ```bash
    gpg --sign-key 1BD97A6A154E7810EE0BC832E2F38302C8075E3D
    ```
    
    ## Public Key Block in ascii-armored format
    
    ```
    -----BEGIN PGP PUBLIC KEY BLOCK-----
    
    mQINBGOtCzoBEAC7hGOPLFnfvQKzCZpJb3QYq8X9OiUL4tVa5mG0lDTeBBiuQCDy
    Iyhpo8IypllGG6Wxj6ZJbhuHXcnXSu/atmtrnnjARMvDnQ20jX77B+g39ZYuqxgw
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Thu Dec 04 14:29:13 UTC 2025
    - 4.7K bytes
    - Viewed (0)
Back to top