Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 7 of 7 for isLocked (0.05 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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 IPs
    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)
  7. 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)
Back to Top