Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 272 for unlocks (0.25 sec)

  1. docs/zh/llm-prompt.md

    ### Quotes and punctuation
    
    1) Keep punctuation style consistent with existing Simplified Chinese docs (they often mix English terms like “FastAPI” with Chinese text).
    2) Never change punctuation inside inline code, code blocks, URLs, or file paths.
    
    ### Ellipsis
    
    1) Keep ellipsis style consistent within each document, prefer `...` over  `……`.
    2) Never change ellipsis in code, URLs, or CLI examples.
    
    ### Preferred translations / glossary
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Dec 27 18:49:08 UTC 2025
    - 1.4K 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. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertTrue(task.isDone());
        assertFalse(task.isCancelled());
      }
    
      public void testListenerCalledOnException() throws Exception {
        throwException = true;
    
        // Start up the task and unblock the latch to finish the task.
        exec.execute(task);
        runLatch.await();
        taskLatch.countDown();
    
        ExecutionException e = assertThrows(ExecutionException.class, () -> task.get(5, SECONDS));
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  4. 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)
  5. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlanExecutor.java

    import java.util.Set;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Executors;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.maven.api.Lifecycle;
    import org.apache.maven.api.MonotonicClock;
    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/notification.go

    				// zip writer only handles one concurrent write
    				writeMu.Lock()
    				profilingDataFound = true
    				err := embedFileInZip(zipWriter, fmt.Sprintf("profile-%s-%s", client.host.String(), typ), data, 0o600)
    				writeMu.Unlock()
    				if err != nil {
    					reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", client.host.String())
    					ctx := logger.SetReqInfo(ctx, reqInfo)
    					peersLogOnceIf(ctx, err, client.host.String())
    				}
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 46K bytes
    - Viewed (0)
  8. internal/config/subnet/subnet.go

    	return c.submitPost(r)
    }
    
    func (c Config) submitPost(r *http.Request) (string, error) {
    	configLock.RLock()
    	r.Header.Set(xhttp.SubnetAPIKey, c.APIKey)
    	configLock.RUnlock()
    	r.Header.Set(xhttp.MinioDeploymentID, xhttp.GlobalDeploymentID)
    
    	client := &http.Client{
    		Timeout:   10 * time.Second,
    		Transport: c.transport,
    	}
    
    	resp, err := client.Do(r)
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  9. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

        connection.readTimeout = 500
        assertFailsWith<SocketTimeoutException> {
          connection.responseCode
        }
    
        // Closing the server should unblock the dispatcher.
        server.close()
      }
    
      @Test
      fun requestUrlReconstructed() {
        server.enqueue(
          MockResponse
            .Builder()
            .body("hello world")
            .build(),
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Aug 03 22:38:00 UTC 2025
    - 28K bytes
    - Viewed (0)
  10. 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)
Back to top