- Sort Score
- Num 10 results
- Language All
Results 581 - 590 of 673 for wlock (0.03 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/erasure-multipart.go
plkctx, err := partIDLock.GetLock(ctx, globalOperationTimeout) if err != nil { return PartInfo{}, err } ctx = plkctx.Context() defer partIDLock.Unlock(plkctx) // Read lock for upload id, only held while reading the upload metadata. uploadIDRLock := er.NewNSLock(bucket, pathJoin(object, uploadID)) rlkctx, err := uploadIDRLock.GetRLock(ctx, globalOperationTimeout) if err != nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 47.1K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* Attempts to {@code put} an element into a full queue will result in the operation blocking; * attempts to {@code take} an element from an empty queue will similarly block. * * <p>This class supports an optional fairness policy for ordering waiting producer and consumer * threads. By default, this ordering is not guaranteed. However, a queue constructed with fairnessCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 22.4K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/LegacyRepositorySystem.java
url = "file://" + url.substring("file:".length()); } // So now we have an url of the form file://<path> // We want to eliminate any relative path nonsense and lock down the path so we // need to fully resolve it before any submodules use the path. This can happen // when you are using a custom settings.xml that contains a relative path entry
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 31.2K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.12.md
([#63176](https://github.com/kubernetes/kubernetes/pull/63176), [@bswartz](https://github.com/bswartz))
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Thu Feb 06 06:04:15 GMT 2020 - 293.8K bytes - Click Count (0) -
android/guava/src/com/google/common/base/Predicates.java
* future changes to it will alter the behavior of the predicate. * * <p>This method can technically accept any {@code Collection<?>}, but using a typed collection * helps prevent bugs. This approach doesn't block any potential users since it is always possible * to use {@code Predicates.<Object>in()}. * * <p>You may prefer to use a method reference (e.g., {@code target::contains}) instead of thisCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Mar 08 16:16:42 GMT 2026 - 26.6K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java
* the queue exceeds that value, the queue automatically removes its greatest element according to * its comparator (which might be the element that was just added). This is different from * conventional bounded queues, which either block or reject new elements when full. * * <p>This implementation is based on the <a * href="http://portal.acm.org/citation.cfm?id=6621">min-max heap</a> developed by Atkinson, et al.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 13:11:08 GMT 2026 - 34K bytes - Click Count (0) -
tensorflow/c/eager/c_api_experimental.cc
"Coordination service is not enabled."); return; } absl::Duration timeout; if (timeout_in_ms > 0) { timeout = absl::Milliseconds(timeout_in_ms); } else { // Block until the key-value is set or the worker shuts down. timeout = absl::InfiniteDuration(); } auto status_or_value = coord_agent->GetKeyValue(key, timeout); status->status = status_or_value.status();Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Sat Oct 12 05:11:17 GMT 2024 - 35.9K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.25.md
- Apimachinery/clock: This deletes the apimachinery/clock package. Please use k8s.io/utils/clock instead. ([#109752](https://github.com/kubernetes/kubernetes/pull/109752), [@MadhavJivrajani](https://github.com/MadhavJivrajani)) [SIG API Machinery]
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Mon May 06 09:23:20 GMT 2024 - 419.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java
protected CrawlerClientFactory crawlerClientFactory; /** * List of URLs to be deleted, cached for batch processing. * All access is synchronized via indexUpdateCallback lock. */ protected List<String> deleteUrlList = new ArrayList<>(); /** Maximum size of the delete URL cache before batch deletion is triggered. */ protected int maxDeleteDocumentCacheSize;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 29.7K bytes - Click Count (3) -
src/test/java/jcifs/smb1/dcerpc/msrpc/samrTest.java
} } @Nested @DisplayName("Constants Tests") class ConstantsTests { @Test @DisplayName("Should define correct ACB (Account Control Block) constants") void testACBConstants() { // Verify all ACB constants assertEquals(1, samr.ACB_DISABLED); assertEquals(2, samr.ACB_HOMDIRREQ);Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 33.6K bytes - Click Count (0)