Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 688 for sure (0.02 seconds)

  1. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

          assertThat(striped.getAt(i)).isSameInstanceAs(object); // idempotent
          observed.add(object);
        }
        assertTrue("All stripes observed", observed.size() == striped.size());
    
        // this uses #get(key), makes sure an already observed stripe is returned
        for (int i = 0; i < striped.size() * 100; i++) {
          assertTrue(observed.contains(striped.get(new Object())));
        }
    
        try {
          striped.getAt(-1);
          fail();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java

    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests relating to cache expiration: make sure entries expire at the right times, make sure
     * expired entries don't show up, etc.
     *
     * @author mike nonemacher
     */
    @SuppressWarnings("deprecation") // tests of deprecated method
    @NullUnmarked
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 16:38:16 GMT 2026
    - 19.1K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java

          Thread.currentThread().setContextClassLoader(oldClassLoader);
        }
      }
    
      private void checkHelperVersion(ClassLoader classLoader, String expectedHelperClassName)
          throws Exception {
        // Make sure we are actually running with the expected helper implementation
        Class<?> abstractFutureStateClass = classLoader.loadClass(AbstractFutureState.class.getName());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 7.4K bytes
    - Click Count (0)
  4. cmd/site-replication-utils.go

    	for {
    		if err := sm.load(ctx, newObjectLayerFn()); err == nil {
    			<-ctx.Done()
    			return
    		}
    		duration := max(time.Duration(r.Float64()*float64(time.Second*10)),
    			// Make sure to sleep at least a second to avoid high CPU ticks.
    			time.Second)
    		time.Sleep(duration)
    	}
    }
    
    // load resync metrics saved on disk into memory
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/AbstractMultimap.java

        return get(key).add(value);
      }
    
      @CanIgnoreReturnValue
      @Override
      public boolean putAll(@ParametricNullness K key, Iterable<? extends V> values) {
        checkNotNull(values);
        // make sure we only call values.iterator() once
        // and we only call get(key) if values is nonempty
        if (values instanceof Collection) {
          Collection<? extends V> valueCollection = (Collection<? extends V>) values;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  6. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/building/DefaultSettingsBuilder.java

            problems.setSource("");
    
            userSettings = interpolate(userSettings, request, problems);
    
            // for the special case of a drive-relative Windows path, make sure it's absolute to save plugins from trouble
            String localRepository = userSettings.getLocalRepository();
            if (localRepository != null && !localRepository.isEmpty()) {
                File file = new File(localRepository);
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jul 23 17:27:08 GMT 2025
    - 9.5K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

              return new FutureAsCancellable(immediateCancelledFuture());
            }
            // We reschedule ourselves with a lock held for two reasons. 1. we want to make sure that
            // cancel calls cancel on the correct future. 2. we want to make sure that the assignment
            // to currentFuture doesn't race with itself so that currentFuture is assigned in the
            // correct order.
            Throwable scheduleFailure = null;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  8. docs/distributed/DECOMMISSION.md

    ```
    
    > NOTE: Canceled decommission will not make the pool active again, since we might have  potentially partial namespace on the other pools, to avoid this scenario be absolutely sure to make decommissioning a planned well thought activity. This is not to be run on a daily basis.
    
    ```
    λ mc admin decommission cancel alias/ http://minio{1...2}/data{1...4}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jul 11 14:59:49 GMT 2022
    - 8.3K bytes
    - Click Count (0)
  9. guava/src/com/google/common/collect/RegularContiguousSet.java

          if (this.domain.equals(that.domain)) {
            return this.first().equals(that.first()) && this.last().equals(that.last());
          }
        }
        return super.equals(object);
      }
    
      // copied to make sure not to use the GWT-emulated version
      @Override
      public int hashCode() {
        return Sets.hashCodeImpl(this);
      }
    
      @GwtIncompatible
      @J2ktIncompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/graph/StandardNetwork.java

      }
    
      @Override
      public EndpointPair<N> incidentNodes(E edge) {
        N nodeU = checkedReferenceNode(edge);
        // requireNonNull is safe because checkedReferenceNode made sure the edge is in the network.
        N nodeV = requireNonNull(nodeConnections.get(nodeU)).adjacentNode(edge);
        return EndpointPair.of(this, nodeU, nodeV);
      }
    
      @Override
      public Set<N> adjacentNodes(N node) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Apr 02 14:49:41 GMT 2026
    - 6.9K bytes
    - Click Count (0)
Back to Top