Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 114 for counters (0.04 sec)

  1. api/maven-api-core/src/main/java/org/apache/maven/api/services/ProblemCollector.java

         * and the counter returned by {@link #totalProblemsReported()} are not equal (latter is bigger than former).
         *
         * @return true if the problem collector has overflowed and some problems were not preserved
         */
        boolean problemsOverflow();
    
        /**
         * Reports a problem: always maintains the counters, but whether problem is preserved in memory, depends on
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jul 18 17:30:19 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  2. src/main/java/jcifs/audit/SecurityAuditLogger.java

            long currentWindow = System.currentTimeMillis() / rateLimitWindow;
            String windowKey = key + "_" + currentWindow;
    
            AtomicLong counter = rateLimitCounters.computeIfAbsent(windowKey, k -> new AtomicLong(0));
            long currentCount = counter.incrementAndGet();
    
            // Clean up old windows periodically
            if (currentCount == 1) {
                cleanupOldRateLimitCounters(currentWindow);
            }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

       * exception is thrown, this exception is used as the result of the output {@code Future}.
       *
       * <p>Usage example:
       *
       * {@snippet :
       * // Falling back to a zero counter in case an exception happens when processing the RPC to fetch
       * // counters.
       * ListenableFuture<Integer> faultTolerantFuture =
       *     fetchCounters().catching(FetchException.class, x -> 0, directExecutor());
       * }
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java

        for (int i = 0; i < SIZE; i++) {
          aa.set(i, (double) COUNTDOWN);
        }
        Counter c1 = new Counter(aa);
        Counter c2 = new Counter(aa);
        Thread t1 = newStartedThread(c1);
        Thread t2 = newStartedThread(c2);
        awaitTermination(t1);
        awaitTermination(t2);
        assertEquals(SIZE * COUNTDOWN, c1.counts + c2.counts);
      }
    
      /** a deserialized serialized array holds same values */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/pool/CrawlerPooledObjectFactoryTest.java

        private CrawlerPooledObjectFactory<TestComponent> factory;
        private StandardCrawlerContainer container;
    
        @Override
        protected void setUp() throws Exception {
            super.setUp();
    
            // Reset counters before each test
            TestComponent.resetCounter();
            SingletonTestComponent.resetInstanceCount();
    
            // Initialize container with test components
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Wed Sep 03 14:42:53 UTC 2025
    - 19.3K bytes
    - Viewed (0)
  6. src/test/java/jcifs/internal/smb2/rdma/RdmaIntegrationTest.java

            stats.recordRdmaSend(512, 500000); // 512B in 0.5ms
            stats.recordRdmaReceive(1536, 1500000); // 1.5KB in 1.5ms
            stats.recordError();
    
            // Verify counters
            assertEquals(1, stats.getRdmaReads(), "Should have 1 read operation");
            assertEquals(1, stats.getRdmaWrites(), "Should have 1 write operation");
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 13.8K bytes
    - Viewed (0)
  7. cmd/bucket-stats.go

    // Update replication upload latency with a new value
    func (rl *ReplicationLatency) update(size int64, duration time.Duration) {
    	rl.UploadHistogram.Add(size, duration)
    }
    
    // ReplicationLastMinute has last minute replication counters
    type ReplicationLastMinute struct {
    	LastMinute lastMinuteLatency
    }
    
    func (rl ReplicationLastMinute) merge(other ReplicationLastMinute) (nl ReplicationLastMinute) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.5K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

            long now = System.currentTimeMillis();
            lastFailureTimes.entrySet().removeIf(entry -> now - entry.getValue() > FAILURE_RECOVERY_TIME * 2);
    
            // Clean up old consecutive failure counters
            consecutiveFailures.entrySet().removeIf(entry -> {
                String key = entry.getKey();
                Long lastFailure = lastFailureTimes.get(key);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  9. src/main/java/jcifs/util/SmbCircuitBreaker.java

                    openStateStartTime.set(0);
                }
    
                if (newState == State.OPEN) {
                    openStateStartTime.set(System.currentTimeMillis());
                }
    
                // Reset counters based on transition
                switch (newState) {
                case CLOSED:
                    failureCount.set(0);
                    successCount.set(0);
                    halfOpenAttempts.set(0);
                    break;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  10. guava/src/com/google/common/base/Joiner.java

               * modified concurrently), or it might have been only an estimate to begin with (for a
               * collection like ConcurrentHashMap, which sums up several counters that may not be in
               * sync with one another). We accommodate that by resizing as necessary.
               */
              toJoin = Arrays.copyOf(toJoin, expandedCapacity(toJoin.length, toJoin.length + 1));
            }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Apr 14 15:16:19 UTC 2025
    - 21K bytes
    - Viewed (0)
Back to top