Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 331 - 340 of 359 for cluster (0.05 seconds)

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

  1. android/guava/src/com/google/common/util/concurrent/Futures.java

       * Future}.
       *
       * <p>Usage example:
       *
       * {@snippet :
       * ListenableFuture<Integer> fetchCounterFuture = ...;
       *
       * // Falling back to a zero counter in case an exception happens when
       * // processing the RPC to fetch counters.
       * ListenableFuture<Integer> faultTolerantFuture = Futures.catching(
       *     fetchCounterFuture, FetchException.class, x -> 0, directExecutor());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/Ordering.java

      }
    
      @J2ktIncompatible // MapMaker
      @VisibleForTesting
      static class ArbitraryOrdering extends Ordering<@Nullable Object> {
    
        private final AtomicInteger counter = new AtomicInteger(0);
        private final ConcurrentMap<Object, Integer> uids =
            Platform.tryWeakKeys(new MapMaker()).makeMap();
    
        private Integer getUid(Object obj) {
          Integer uid = uids.get(obj);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 39.4K bytes
    - Click Count (0)
  3. src/main/java/jcifs/smb/SmbTreeImpl.java

        }
    
        /**
         * @return the tid
         */
        public int getTid() {
            return this.tid;
        }
    
        /**
         * @return the tree_num (monotonically increasing counter to track reconnects)
         */
        public long getTreeNum() {
            return this.treeNum;
        }
    
        /**
         * {@inheritDoc}
         *
         * @see java.lang.Object#hashCode()
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 30K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java

         */
        public static class StatsObject extends LinkedHashMap<String, Long> {
            /** Serial version UID for serialization. */
            private static final long serialVersionUID = 1L;
    
            /** Atomic counter for tracking reference count across multiple threads. */
            protected final AtomicInteger count;
    
            /**
             * Creates a new statistics object with the current timestamp as the begin time.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 17.4K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/Lists.java

       * }
       *
       * <p>Note that if any input list is empty, the Cartesian product will also be empty. If no lists
       * at all are provided (an empty list), the resulting Cartesian product has one element, an empty
       * list (counter-intuitive, but mathematically consistent).
       *
       * <p><i>Performance notes:</i> while the cartesian product of lists of size {@code m, n, p} is a
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 16:38:09 GMT 2026
    - 42.1K bytes
    - Click Count (0)
  6. src/test/java/org/codelibs/fess/helper/CrawlingConfigHelperTest.java

            assertNull(crawlingConfigHelper.getCrawlingConfig("W123"));
        }
    
        @Test
        public void test_store_counterIncrement() {
            final String sessionId = "testSession";
    
            // Test counter increment
            String sessionCountId1 = crawlingConfigHelper.store(sessionId, crawlingConfigHelper.getCrawlingConfig("W1"));
            assertEquals("testSession-1", sessionCountId1);
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 35.3K bytes
    - Click Count (0)
  7. guava/src/com/google/common/collect/Ordering.java

      }
    
      @J2ktIncompatible // MapMaker
      @VisibleForTesting
      static class ArbitraryOrdering extends Ordering<@Nullable Object> {
    
        private final AtomicInteger counter = new AtomicInteger(0);
        private final ConcurrentMap<Object, Integer> uids =
            Platform.tryWeakKeys(new MapMaker()).makeMap();
    
        private Integer getUid(Object obj) {
          Integer uid = uids.get(obj);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 39.4K bytes
    - Click Count (0)
  8. src/main/webapp/js/admin/popper.min.js.map

    an initial placement, returns all the subsequent placements\n * clockwise (or counter-clockwise).\n *\n * @method\n * @memberof Popper.Utils\n * @argument {String} placement - A valid placement (it accepts variations)\n * @argument {Boolean} counter - Set to true to walk the placements counterclockwise\n * @returns {Array} placements including their variations\n */\nexport default function clockwise(placement, counter = false) {\n  const index = validPlacements.indexOf(placement);\n  const arr =...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Oct 26 01:49:09 GMT 2024
    - 120.9K bytes
    - Click Count (0)
  9. src/test/java/org/codelibs/curl/io/IOIntegrationTest.java

            String[] specialUrls = { "http://localhost:9200/{index}/_search", "http://example.com/path?q=a|b",
                    "http://example.com/page#section", "http://user:******@****.***/path", "http://localhost:9200/_cluster/health" };
    
            for (String specialUrl : specialUrls) {
                final AtomicInteger openCalled = new AtomicInteger(0);
                CurlRequest req = new OpenOverrideCurlRequest(Curl.Method.GET, specialUrl, u -> {
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 12:00:34 GMT 2026
    - 44.1K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/math/IntMath.java

            if (cmpRemToHalfDivisor == 0) { // exactly on the half mark
              increment = (mode == HALF_UP || (mode == HALF_EVEN & (div & 1) != 0));
            } else {
              increment = cmpRemToHalfDivisor > 0; // closer to the UP value
            }
            break;
          default:
            throw new AssertionError();
        }
        return increment ? div + signum : div;
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 26.1K bytes
    - Click Count (0)
Back to Top