Search Options

Results per page
Sort
Preferred Languages
Advance

Results 2491 - 2500 of 3,237 for get2 (0.02 sec)

  1. cmd/namespace-lock.go

    	if readLock {
    		locked = nsLk.GetRLock(ctx, opsID, lockSource, timeout)
    	} else {
    		locked = nsLk.GetLock(ctx, opsID, lockSource, timeout)
    	}
    
    	if !locked { // We failed to get the lock
    		// Decrement ref count since we failed to get the lock
    		n.lockMapMutex.Lock()
    		n.lockMap[resource].ref--
    		if n.lockMap[resource].ref < 0 {
    			logger.CriticalIf(GlobalContext, errors.New("resource reference count was lower than 0"))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/ImmutableSetMultimap.java

       * parameters used to build this multimap.
       */
      @Override
      public ImmutableSet<V> get(K key) {
        // This cast is safe as its type is known in constructor.
        ImmutableSet<V> set = (ImmutableSet<V>) map.get(key);
        return MoreObjects.firstNonNull(set, emptySet);
      }
    
      @LazyInit @RetainedWith @CheckForNull private transient ImmutableSetMultimap<V, K> inverse;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  3. cmd/batch-handlers.go

    			slowCh = walkCh
    		}
    
    		workerSize, err := strconv.Atoi(env.Get("_MINIO_BATCH_REPLICATION_WORKERS", strconv.Itoa(runtime.GOMAXPROCS(0)/2)))
    		if err != nil {
    			return err
    		}
    
    		wk, err := workers.New(workerSize)
    		if err != nil {
    			// invalid worker size.
    			return err
    		}
    
    		walkQuorum := env.Get("_MINIO_BATCH_REPLICATION_WALK_QUORUM", "strict")
    		if walkQuorum == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/primitives/Bytes.java

       *
       * <p>The returned list maintains the values, but not the identities, of {@code Byte} objects
       * written to or read from it. For example, whether {@code list.get(0) == list.get(0)} is true for
       * the returned list is unspecified.
       *
       * <p>The returned list is serializable.
       *
       * @param backingArray the array to back the list
       * @return a list view of the array
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 27 16:47:48 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  5. guava/src/com/google/common/reflect/Invokable.java

     * will resolve the type parameters of the method or constructor in the context of the owner type,
     * which may be a subtype of the declaring class. For example:
     *
     * <pre>{@code
     * Method getMethod = List.class.getMethod("get", int.class);
     * Invokable<List<String>, ?> invokable = new TypeToken<List<String>>() {}.method(getMethod);
     * assertEquals(TypeToken.of(String.class), invokable.getReturnType()); // Not Object.class!
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 19.6K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/io/IoTestCase.java

        if (!tempFile.delete() || !tempFile.mkdir()) {
          throw new IOException("failed to create temp dir");
        }
        filesToDelete.add(tempFile);
        return tempFile;
      }
    
      /**
       * Gets a temp dir for testing. The returned directory and all contents of it will be deleted in
       * the tear-down for this test. Subsequent invocations of this method will return the same
       * directory.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 31 12:36:13 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  7. internal/bucket/bandwidth/monitor.go

    }
    
    // BucketBandwidthReport captures the details for all buckets.
    type BucketBandwidthReport struct {
    	BucketStats map[BucketOptions]Details `json:"bucketStats,omitempty"`
    }
    
    // GetReport gets the report for all bucket bandwidth details.
    func (m *Monitor) GetReport(selectBucket SelectionFunction) *BucketBandwidthReport {
    	m.mlock.RLock()
    	defer m.mlock.RUnlock()
    	return m.getReport(selectBucket)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/ConnectionSpec.kt

       * Returns the cipher suites to use for a connection. Returns null if all of the SSL socket's
       * enabled cipher suites should be used.
       */
      @get:JvmName("cipherSuites")
      val cipherSuites: List<CipherSuite>?
        get() {
          return cipherSuitesAsString?.map { CipherSuite.forJavaName(it) }
        }
    
      @JvmName("-deprecated_cipherSuites")
      @Deprecated(
        message = "moved to val",
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  9. cmd/http-stats.go

    	if stats == nil {
    		return
    	}
    	stats.Lock()
    	defer stats.Unlock()
    	if val, ok := stats.apiStats[api]; ok && val > 0 {
    		stats.apiStats[api]--
    	}
    }
    
    // Get returns the current counter on input API string
    func (stats *HTTPAPIStats) Get(api string) int {
    	if stats == nil {
    		return 0
    	}
    
    	stats.RLock()
    	defer stats.RUnlock()
    
    	val, ok := stats.apiStats[api]
    	if ok {
    		return val
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  10. architecture/standards/0006-use-of-provider-apis-in-gradle.md

    // Unacceptable
    String value
    if (!getSomeProperty().isPresent()) {
       value = "convention"
    } else {
       value = getSomeProperty().get()
    }
    
    // Also unacceptable
    String value = getSomeProperty().getOrElse("convention")
    
    // This should be always:
    String value = getSomeProperty().get()
    ```
    
    ## Status
    
    ACCEPTED
    
    ## Consequences
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Oct 15 20:00:57 UTC 2024
    - 10K bytes
    - Viewed (0)
Back to top