- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 30 for blockedOn (0.06 seconds)
-
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
* interrupting thread. In theory, interruptTask() should be very fast, but due to * InterruptibleChannel and JavaLangAccess.blockedOn(Thread, Interruptible), it isn't * predictable what work might be done. (e.g., close a file and flush buffers to disk). To * protect ourselves from this, we park ourselves and tell our interrupter that we did so.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 10K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/RateLimitHelper.java
} return true; } // Check dynamically blocked IPs (Cache handles expiration automatically) final Boolean blocked = blockedIps.getIfPresent(ip); if (blocked != null) { if (logger.isDebugEnabled()) { logger.debug("IP dynamically blocked: ip={}", ip); } return true; } return false;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Dec 24 14:16:27 GMT 2025 - 9.4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/app/web/admin/design/AdminDesignActionTest.java
assertFalse("Path traversal should be blocked", result); } @Test public void test_isValidVirtualHostPath_pathTraversal_encoded() throws Exception { setupVirtualHostHelper("/site1", "/site2"); Boolean result = invokeIsValidVirtualHostPath("/site1/../../../etc"); assertFalse("Encoded path traversal should be blocked", result); } @Test
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 13.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/filter/RateLimitFilter.java
logger.debug("Rate limit check: clientIp={}, path={}", clientIp, httpRequest.getRequestURI()); } // Check if IP is blocked if (rateLimitHelper.isBlocked(clientIp)) { if (logger.isDebugEnabled()) { logger.debug("Request blocked: clientIp={}", clientIp); } sendBlockedResponse(httpResponse); return; } // Check rate limit
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Dec 24 14:16:27 GMT 2025 - 4.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
private static final long SMALL_TIMEOUT_MILLIS = 10; /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */ private static final long EXPECTED_HANG_DELAY_MILLIS = 75; /** * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked. */ private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000; /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
// 1. the runner has been woken up // 2. the interrupter is stuck in the call the Thread.interrupt() // after some period of time the runner thread should become blocked on the task because it is // waiting for the slow interrupting thread to complete Thread.interrupt awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
// 1. the runner has been woken up // 2. the interrupter is stuck in the call the Thread.interrupt() // after some period of time the runner thread should become blocked on the task because it is // waiting for the slow interrupting thread to complete Thread.interrupt awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.2K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/MarkdownRendererTest.java
// javascript: protocol should be blocked assertFalse(result.contains("javascript:")); } @Test public void test_render_xss_dataProtocol() { String malicious = "[Click me](data:text/html,<script>alert('XSS')</script>)"; String result = markdownRenderer.render(malicious); // data: protocol should be blocked assertFalse(result.contains("data:text/html"));Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 11.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
private static final long SMALL_TIMEOUT_MILLIS = 10; /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */ private static final long EXPECTED_HANG_DELAY_MILLIS = 75; /** * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked. */ private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000; /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
} throw new RejectedExecutionException(); } }; SequentialExecutor executor = new SequentialExecutor(delegate); ExecutorService blocked = newCachedThreadPool(); Future<?> first = blocked.submit(() -> executor.execute(Runnables.doNothing())); future.get(10, SECONDS); assertThrows(RejectedExecutionException.class, () -> executor.execute(Runnables.doNothing()));Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 10.5K bytes - Click Count (0)