- Sort Score
- Num 10 results
- Language All
Results 31 - 40 of 718 for Acquire (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/test/java/jcifs/util/transport/TransportTest.java
@Nested @DisplayName("Resource management tests") class ResourceManagementTests { @Test @DisplayName("acquire should increment usage count") void shouldIncrementUsageCount() { long initial = transport.getUsageCount(); transport.acquire(); assertEquals(initial + 1, transport.getUsageCount()); } @TestCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 9.5K bytes - Click Count (0) -
docs/tls/kubernetes/README.md
## 1. Prerequisites - Familiarity with [MinIO deployment process on Kubernetes](https://docs.min.io/community/minio-object-store/operations/deployments/kubernetes.html). - Kubernetes cluster with `kubectl` configured. - Acquire TLS certificates, either from a CA or [create self-signed certificates](https://docs.min.io/community/minio-object-store/operations/network-encryption.html).
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 3K bytes - Click Count (0) -
internal/lock/lock_solaris.go
// it is similar to LockedOpenFile with with syscall.LOCK_EX // mode but along with syscall.LOCK_NB such that the function // doesn't wait forever but instead returns if it cannot // acquire a write lock. func TryLockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) { return lockedOpenFile(path, flag, perm, syscall.F_SETLK) } // LockedOpenFile - initializes a new lock and protects
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/CoordinatorHelper.java
// ================ /** * Attempts to acquire a distributed lock for the specified operation. * * @param operationName the operation name used as the lock document ID. * @return {@code true} if the lock was acquired. */ public boolean tryStartOperation(final String operationName) { return tryStartOperation(operationName, null);Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 33.3K bytes - Click Count (0) -
internal/lsync/lrwmutex.go
locked = true } } else { if !lm.isWriteLock { lm.ref++ locked = true } } return locked } const ( lockRetryInterval = 50 * time.Millisecond ) // lockLoop will acquire either a read or a write lock // // The call will block until the lock is granted using a built-in // timing randomized back-off algorithm to try again until successfulCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Click Count (0) -
src/test/java/jcifs/smb/SmbFileInputStreamTest.java
@Test @DisplayName("open() acquires handle and closes it") void openDelegatesEnsureOpenAndCloses() throws Exception { SmbFileInputStream in = newStream(); in.open(); // ensureOpen returns acquired handle; try-with-resources must close it verify(mockHandle, times(1)).close(); verify(mockHandle, atLeastOnce()).acquire(); } @TestCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 12.8K bytes - Click Count (0) -
cmd/callhome.go
return } go func() { r := rand.New(rand.NewSource(time.Now().UnixNano())) // Leader node (that successfully acquires the lock inside runCallhome) // will keep performing the callhome. If the leader goes down for some reason, // the lock will be released and another node will acquire it and take over // because of this loop. for { if !globalCallhomeConfig.Enabled() { return }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.3K bytes - Click Count (0) -
docs/en/docs/deployment/https.md
* Nginx * HAProxy ## Let's Encrypt { #lets-encrypt } Before Let's Encrypt, these **HTTPS certificates** were sold by trusted third parties. The process to acquire one of these certificates used to be cumbersome, require quite some paperwork and the certificates were quite expensive. But then **[Let's Encrypt](https://letsencrypt.org/)** was created.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 14K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
* cancelled without a call to {@code cancel}, such as by calling {@code * setFuture(cancelledFuture)}. * * <p>Beware of completing a future while holding a lock. Its listeners may do slow work or * acquire other locks, risking deadlocks. */ @CanIgnoreReturnValue @Override public boolean cancel(boolean mayInterruptIfRunning) { @RetainedLocalRef Object localValue = value(); boolean rValue = false;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 14:39:00 GMT 2026 - 43.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
} finally { if (!satisfied) { leave(); } } } /** * Enters this monitor when the guard is satisfied. Blocks at most the given time, including both * the time to acquire the lock and the time to wait for the guard to be satisfied, and may be * interrupted. * * @return whether the monitor was entered, which guarantees that the guard is now satisfiedCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 43.5K bytes - Click Count (0)