Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 718 for Acquire (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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());
            }
    
            @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 9.5K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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 successful
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.8K bytes
    - Click Count (0)
  6. 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();
            }
    
            @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 12.8K bytes
    - Click Count (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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 satisfied
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 43.5K bytes
    - Click Count (0)
Back to Top