- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 67 for counters (0.15 sec)
-
src/main/java/org/codelibs/fess/app/pager/RelatedContentPager.java
public String createdTime; /** Version number for optimistic locking. */ public String versionNo; /** * Clears all pagination state and filter parameters. * Resets pagination counters to default values and clears all filter fields. */ public void clear() { allRecordCount = 0; allPageCount = 0; existPrePage = false; existNextPage = false;Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 6.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/pager/ElevateWordPager.java
public String createdTime; /** Search parameter: version number */ public String versionNo; /** * Clears all pagination data and search parameters. * Resets counters, flags, and search form fields to their default values. */ public void clear() { allRecordCount = 0; allPageCount = 0; existPrePage = false; existNextPage = false;Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 6.6K bytes - Viewed (0) -
src/test/java/jcifs/audit/SecurityAuditLoggerTest.java
logger.resetStatistics(); Map<EventType, Long> statsAfter = logger.getStatistics(); // After reset, all counters should be 0 for (Long count : statsAfter.values()) { assertEquals(Long.valueOf(0), count, "All statistics should be 0 after reset"); } } @TestRegistered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 8.6K 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: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 26.6K bytes - Viewed (0) -
CLAUDE.md
**Template Method**: `AbstractCrawlerClient`, `AbstractExtractor` - common logic with overrides **DI**: LastaFlute container with `@Resource` and XML config ### Core Principles **Thread Safety**: - `AtomicLong` for counters (`CrawlerContext.accessCount`) - `volatile` for status flags - Synchronized blocks for critical sections - Thread-local storage via `CrawlingParameterUtil` **Resource Management**: - `AutoCloseable` throughout
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Fri Nov 28 17:31:34 UTC 2025 - 10.7K 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: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 23 05:11:12 UTC 2025 - 13.8K 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(); CloseableTestComponent.resetCounters(); // Initialize container with test componentsRegistered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 13:07:01 UTC 2025 - 36.7K bytes - Viewed (0) -
src/main/java/jcifs/util/SmbCircuitBreaker.java
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 33.4K 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: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 33.4K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/Smb2EncryptionContextTest.java
// For GCM, last 4 bytes should contain incrementing counter ByteBuffer buffer1 = ByteBuffer.wrap(nonce1, 12, 4).order(java.nio.ByteOrder.LITTLE_ENDIAN); ByteBuffer buffer2 = ByteBuffer.wrap(nonce2, 12, 4).order(java.nio.ByteOrder.LITTLE_ENDIAN); int counter1 = buffer1.getInt(); int counter2 = buffer2.getInt(); assertEquals(counter1 + 1, counter2, "Counter should increment between nonces"); }Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 44.1K bytes - Viewed (0)