Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 19 for isLocked (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  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/jcifs/util/AuthenticationRateLimiter.java

                }
            }
    
            // Check per-IP limit
            if (sourceIp != null) {
                IpAttempts ip = ipAttempts.computeIfAbsent(sourceIp, k -> new IpAttempts());
                if (ip.isBlocked()) {
                    if (ip.getBlockExpiry().isAfter(Instant.now())) {
                        totalAttemptsBlocked.incrementAndGet();
                        totalIpsBlocked.incrementAndGet();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 15.1K bytes
    - Click Count (0)
  4. cmd/update.go

    	return getModTime(os.Args[0])
    }
    
    // IsDocker - returns if the environment minio is running in docker or
    // not. The check is a simple file existence check.
    //
    // https://github.com/moby/moby/blob/master/daemon/initlayer/setup_unix.go
    // https://github.com/containers/podman/blob/master/libpod/runtime.go
    //
    //	"/.dockerenv":        "file",
    //	"/run/.containerenv": "file",
    func IsDocker() bool {
    	var err error
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  5. impl/maven-core/src/main/java/org/apache/maven/artifact/repository/MavenArtifactRepository.java

                sb.append(", update => ").append(releases.getUpdatePolicy()).append(']');
            }
    
            sb.append("   blocked: ").append(isBlocked()).append('\n');
    
            return sb.toString();
        }
    
        @Override
        public Artifact find(Artifact artifact) {
            File artifactFile = new File(getBasedir(), pathOf(artifact));
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  6. 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)
  7. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/LegacyRepositorySystem.java

                effectiveRepository.setProxy(aliasedRepo.getProxy());
    
                effectiveRepository.setMirroredRepositories(mirroredRepos);
    
                effectiveRepository.setBlocked(aliasedRepo.isBlocked());
    
                effectiveRepositories.add(effectiveRepository);
            }
    
            return effectiveRepositories;
        }
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 31.2K bytes
    - Click Count (0)
  8. 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)
  9. 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)
  10. 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)
Back to Top