Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 408 for acquire (0.84 sec)

  1. docs/en/docs/advanced/events.md

    ### `startup` and `shutdown` together
    
    There's a high chance that the logic for your *startup* and *shutdown* is connected, you might want to start something and then finish it, acquire a resource and then release it, etc.
    
    Doing that in separated functions that don't share logic or variables together is more difficult as you would need to store values in global variables or similar tricks.
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance.go

    		}
    	}
    	if ok {
    		lock := z.serverPools[0].NewNSLock(minioMetaBucket, rebalMetaName)
    		lkCtx, err := lock.GetLock(ctx, globalOperationTimeout)
    		if err != nil {
    			rebalanceLogIf(ctx, fmt.Errorf("failed to acquire write lock on %s/%s: %w", minioMetaBucket, rebalMetaName, err))
    			return err
    		}
    		defer lock.Unlock(lkCtx)
    
    		ctx = lkCtx.Context()
    
    		noLockOpts := ObjectOptions{NoLock: true}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  3. maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/DefaultVersionResolver.java

            Versioning versioning = null;
            try {
                if (metadata != null) {
                    try (SyncContext syncContext = syncContextFactory.newInstance(session, true)) {
                        syncContext.acquire(null, Collections.singleton(metadata));
    
                        if (metadata.getPath() != null && Files.exists(metadata.getPath())) {
                            try (InputStream in = Files.newInputStream(metadata.getPath())) {
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Fri Apr 12 10:50:18 GMT 2024
    - 20.2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/hash/Striped64.java

      Striped64() {}
    
      /** CASes the base field. */
      final boolean casBase(long cmp, long val) {
        return UNSAFE.compareAndSwapLong(this, baseOffset, cmp, val);
      }
    
      /** CASes the busy field from 0 to 1 to acquire lock. */
      final boolean casBusy() {
        return UNSAFE.compareAndSwapInt(this, busyOffset, 0, 1);
      }
    
      /**
       * Computes the function of current and new value. Subclasses should open-code this update
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.5K bytes
    - Viewed (0)
  5. 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) {
        Object localValue = value;
        boolean rValue = false;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 63K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/EventListener.kt

    import java.net.InetSocketAddress
    import java.net.Proxy
    
    /**
     * Listener for metrics events. Extend this class to monitor the quantity, size, and duration of
     * your application's HTTP calls.
     *
     * All start/connect/acquire events will eventually receive a matching end/release event, either
     * successful (non-null parameters), or failed (non-null throwable). The first common parameters of
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 15.2K bytes
    - Viewed (0)
  7. helm/minio/README.md

    | `rootPassword`          | `rootPassword`         | Root password. | yes      |
    
    All corresponding variables will be ignored in values file.
    
    ### Configure TLS
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 24 07:27:57 GMT 2024
    - 10.9K bytes
    - Viewed (0)
  8. guava/src/com/google/common/cache/Striped64.java

      Striped64() {}
    
      /** CASes the base field. */
      final boolean casBase(long cmp, long val) {
        return UNSAFE.compareAndSwapLong(this, baseOffset, cmp, val);
      }
    
      /** CASes the busy field from 0 to 1 to acquire lock. */
      final boolean casBusy() {
        return UNSAFE.compareAndSwapInt(this, busyOffset, 0, 1);
      }
    
      /**
       * Computes the function of current and new value. Subclasses should open-code this update
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.5K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool.go

    	}
    
    	var unlockOnDefer bool
    	nsUnlocker := func() {}
    	defer func() {
    		if unlockOnDefer {
    			nsUnlocker()
    		}
    	}()
    
    	// Acquire lock
    	if !opts.NoLock {
    		lock := z.NewNSLock(bucket, object)
    		lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return nil, err
    		}
    		ctx = lkctx.Context()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (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
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Dec 04 18:22:01 GMT 2023
    - 38.6K bytes
    - Viewed (0)
Back to top