Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 251 - 260 of 699 for takeIf (0.06 seconds)

  1. cmd/global-heal.go

    			agreed: func(entry metaCacheEntry) {
    				jt.Take()
    				go healEntry(bucket, entry)
    			},
    			partial: func(entries metaCacheEntries, _ []error) {
    				entry, ok := entries.resolve(&resolver)
    				if !ok {
    					// check if we can get one entry at least
    					// proceed to heal nonetheless.
    					entry, _ = entries.firstFound()
    				}
    				jt.Take()
    				go healEntry(bucket, *entry)
    			},
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  2. docs/sts/wso2.md

    ### 5. Setup MinIO with OpenID configuration URL
    
    MinIO server expects environment variable for OpenID configuration url as `MINIO_IDENTITY_OPENID_CONFIG_URL`, this environment variable takes a single entry.
    
    ```
    export MINIO_IDENTITY_OPENID_CONFIG_URL=https://localhost:9443/oauth2/oidcdiscovery/.well-known/openid-configuration
    export MINIO_IDENTITY_OPENID_CLIENT_ID="843351d4-1080-11ea-aa20-271ecba3924a"
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  3. src/test/java/jcifs/smb1/smb1/SmbFileTest.java

                assertThrows(MalformedURLException.class, () -> new SmbFile(invalidUrl));
            }
    
            @Test
            public void testConstructorWithContextAndName() throws Exception {
                // Test constructor that takes a context SmbFile and a name
                SmbFile context = new SmbFile("smb1://server/share/");
                String name = "file.txt";
                SmbFile smbFile = new SmbFile(context, name);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

          }
        }
      }
    
      /** Invokes {@code queue.}{@link BlockingQueue#take() take()} uninterruptibly. */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      public static <E> E takeUninterruptibly(BlockingQueue<E> queue) {
        boolean interrupted = false;
        try {
          while (true) {
            try {
              return queue.take();
            } catch (InterruptedException e) {
              interrupted = true;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 23:24:32 GMT 2026
    - 22.5K bytes
    - Click Count (0)
  5. guava/src/com/google/common/base/Throwables.java

       * by delaying the per-stack-frame work until each element is accessed. Roughly speaking:
       *
       * <ul>
       *   <li>{@code getStackTrace} takes {@code stackSize} time to return but then negligible time to
       *       retrieve each element of the returned list.
       *   <li>{@code lazyStackTrace} takes negligible time to return but then {@code 1/stackSize} time
       *       to retrieve each element of the returned list (probably slightly more than {@code
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 20.6K bytes
    - Click Count (0)
  6. android/guava-tests/benchmark/com/google/common/collect/MinMaxPriorityQueueBenchmark.java

        @Override
        public BigInteger apply(Integer from) {
          BigInteger v = BigInteger.valueOf(from);
          // Math.sin is very slow for values outside 4*pi
          // Need to take absolute value to avoid inverting the value.
          for (double i = 0; i < 100; i += 20) {
            v =
                v.add(
                    v.multiply(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  7. guava-tests/benchmark/com/google/common/collect/MinMaxPriorityQueueBenchmark.java

        @Override
        public BigInteger apply(Integer from) {
          BigInteger v = BigInteger.valueOf(from);
          // Math.sin is very slow for values outside 4*pi
          // Need to take absolute value to avoid inverting the value.
          for (double i = 0; i < 100; i += 20) {
            v =
                v.add(
                    v.multiply(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  8. okhttp/src/androidMain/kotlin/okhttp3/internal/platform/android/AndroidLog.kt

        // We need to handle long logger names before they hit Log.
        // java.lang.IllegalArgumentException: Log tag "okhttp3.mockwebserver.MockWebServer" exceeds limit of 23 characters
        return knownLoggers[loggerName] ?: loggerName.take(23)
      }
    
      fun enable() {
        try {
          for ((logger, tag) in knownLoggers) {
            enableLogging(logger, tag)
          }
        } catch (re: RuntimeException) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Oct 25 11:16:17 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  9. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/transform/SnapshotTransformation.java

                // TODO Should this be changed for MNG-6754 too?
                snapshot.setTimestamp(getDeploymentTimestamp());
    
                // we update the build number anyway so that it doesn't get lost. It requires the timestamp to take effect
                try {
                    int buildNumber = resolveLatestSnapshotBuildNumber(artifact, localRepository, remoteRepository);
    
                    snapshot.setBuildNumber(buildNumber + 1);
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  10. src/cmd/api/main_test.go

    				ok = false // broke compatibility
    			}
    		case len(required) == 0 || (len(features) > 0 && required[0] > features[0]):
    			newFeature := take(&features)
    			fmt.Fprintf(w, "+%s\n", newFeature)
    			ok = false // feature not in api/next/*
    		default:
    			take(&required)
    			take(&features)
    		}
    	}
    
    	return ok
    }
    
    // aliasReplacer applies type aliases to earlier API files,
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Mar 02 13:20:41 GMT 2026
    - 31.4K bytes
    - Click Count (0)
Back to Top