- Sort Score
- Num 10 results
- Language All
Results 1 - 7 of 7 for isLocked (0.05 seconds)
-
android/guava/src/com/google/common/util/concurrent/Monitor.java
* Returns whether this monitor is occupied by any thread. This method is designed for use in * monitoring of the system state, not for synchronization control. */ public boolean isOccupied() { return lock.isLocked(); } /** * Returns whether the current thread is occupying this monitor (has entered more times than it * has left). */ public boolean isOccupiedByCurrentThread() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 43.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt
} } return call.messageDone( exchange = this, requestDone = requestDone && !isSocket, responseDone = responseDone && !isSocket, socketSinkDone = requestDone && isSocket, socketSourceDone = responseDone && isSocket, e = e, ) } fun noRequestBody() { call.messageDone( exchange = this, requestDone = true,Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 10.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/filter/RateLimitFilter.java
if (logger.isDebugEnabled()) { 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; }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/AbstractFutureTest.java
void awaitWaiting() { while (!isBlocked()) { if (getState() == State.TERMINATED) { throw new RuntimeException("Thread exited"); } Thread.yield(); } } private boolean isBlocked() { return getState() == Thread.State.WAITING && LockSupport.getBlocker(this) == future; } }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 45.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
void awaitWaiting() { while (!isBlocked()) { if (getState() == State.TERMINATED) { throw new RuntimeException("Thread exited"); } Thread.yield(); } } private boolean isBlocked() { return getState() == Thread.State.WAITING && LockSupport.getBlocker(this) == future; } }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 45.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/RateLimitHelper.java
} return whitelisted; } /** * Check if the IP is blocked. * @param ip the IP address to check * @return true if blocked */ public boolean isBlocked(final String ip) { if (isWhitelisted(ip)) { return false; } // Check statically configured blocked IPsCreated: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Dec 24 14:16:27 GMT 2025 - 9.4K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/aether/DefaultRepositorySystemSessionFactory.java
mirrorSelector.add( mirror.getId(), mirror.getUrl(), mirror.getLayout(), false, mirror.isBlocked(), mirror.getMirrorOf(), mirror.getMirrorOfLayouts()); } sessionBuilder.setMirrorSelector(mirrorSelector);
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Mar 19 13:42:58 GMT 2026 - 25.8K bytes - Click Count (0)