Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for isLocked (0.04 sec)

  1. 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() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  2. 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();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  3. 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
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  4. cmd/update_test.go

    		}
    	}
    }
    
    func TestDownloadURL(t *testing.T) {
    	minioVersion1 := releaseTimeToReleaseTag(UTCNow())
    	durl := getDownloadURL(minioVersion1)
    	if IsDocker() {
    		if durl != "podman pull quay.io/minio/minio:"+minioVersion1 {
    			t.Errorf("Expected %s, got %s", "podman pull quay.io/minio/minio:"+minioVersion1, durl)
    		}
    	} else {
    		if runtime.GOOS == "windows" {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  5. compat/maven-artifact/src/main/java/org/apache/maven/artifact/repository/ArtifactRepository.java

        boolean isBlacklisted();
    
        @Deprecated
        void setBlacklisted(boolean blackListed);
    
        /**
         * @return whether the repository is blocked
         * @since 3.8.1
         **/
        boolean isBlocked();
    
        /**
         * @param blocked block the repository?
         * @since 3.8.1
         **/
        void setBlocked(boolean blocked);
    
        //
        // New interface methods for the repository system.
        //
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Feb 07 00:45:02 UTC 2025
    - 4.3K bytes
    - Viewed (1)
  6. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/DefaultArtifactRepository.java

            } else {
                this.mirroredRepositories = Collections.emptyList();
            }
        }
    
        @Override
        public boolean isBlocked() {
            return blocked;
        }
    
        @Override
        public void setBlocked(boolean blocked) {
            this.blocked = blocked;
        }
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 7.7K bytes
    - Viewed (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;
        }
    
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 31.2K bytes
    - Viewed (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;
        }
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (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;
        }
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  10. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/LegacyLocalRepositoryManager.java

                return Collections.emptyList();
            }
    
            @Override
            public void setMirroredRepositories(List<ArtifactRepository> mirroredRepositories) {}
    
            @Override
            public boolean isBlocked() {
                return false;
            }
    
            @Override
            public void setBlocked(boolean blocked) {}
        }
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 13.1K bytes
    - Viewed (0)
Back to top