- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for isLocked (0.07 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)