- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 272 for unlocks (0.5 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)