- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 114 for counters (0.04 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
src/main/java/jcifs/util/SmbCircuitBreaker.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 33.4K bytes - Viewed (0) -
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)