- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 23 for isLocked (0.06 sec)
-
impl/maven-core/src/main/java/org/apache/maven/internal/aether/LegacyRepositorySystemSessionExtender.java
if (mirror.getLayout() != null && !mirror.getLayout().isEmpty()) { repository.setLayout(original.getLayout()); } repository.setBlocked(mirror.isBlocked()); } } private void injectProxy(ProxySelector selector, List<ArtifactRepository> repositories) { if (repositories != null && selector != null) {Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 6.7K 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 Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:45:32 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 Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:45:32 UTC 2025 - 46.8K bytes - Viewed (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);
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Jul 17 05:56:35 UTC 2025 - 25.8K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/RepositoryUtils.java
builder.setProxy(toProxy(repo.getProxy())); builder.setMirroredRepositories(toRepos(repo.getMirroredRepositories())); builder.setBlocked(repo.isBlocked()); result = builder.build(); } return result; } public static String getLayout(ArtifactRepository repo) { try { return repo.getLayout().getId();
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Sep 04 18:33:16 UTC 2025 - 15.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 Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 13.1K bytes - Viewed (0) -
cmd/admin-handlers.go
RuntimeVersion: server.RuntimeVersion, GCStats: server.GCStats, MinioEnvVars: server.MinioEnvVars, }) } tls := getTLSInfo() isK8s := IsKubernetes() isDocker := IsDocker() healthInfo.Minio.Info = madmin.MinioInfo{ Mode: infoMessage.Mode, Domain: infoMessage.Domain, Region: infoMessage.Region, SQSARN: infoMessage.SQSARN,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 99.7K bytes - Viewed (0) -
cmd/endpoint.go
endpoints[i].Hostname()), endpoints[i].Hostname(), logger.ErrorKind) } continue } // return err if not Docker or Kubernetes // We use IsDocker() to check for Docker environment // We use IsKubernetes() to check for Kubernetes environment isLocal, err := isLocalHost(endpoints[i].Hostname(), endpoints[i].Port(), globalMinioPort, )
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 34.5K bytes - Viewed (0) -
cmd/common-main.go
) // serverDebugLog will enable debug printing var ( serverDebugLog = env.Get("_MINIO_SERVER_DEBUG", config.EnableOff) == config.EnableOn currentReleaseTime time.Time orchestrated = IsKubernetes() || IsDocker() ) func init() { if !term.IsTerminal(int(os.Stdout.Fd())) || !term.IsTerminal(int(os.Stderr.Fd())) { color.TurnOff() } if env.Get("NO_COLOR", "") != "" || env.Get("TERM", "") == "dumb" { color.TurnOff()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 32.5K bytes - Viewed (3) -
android/guava/src/com/google/common/base/Converter.java
* existing users, but it can't *fix* existing users because any users who needed * `Function<@Nullable A, @Nullable B>` already had to find a workaround. Still, there is a *ton* of * fallout from trying to switch. I would be shocked if the switch would offer benefits to anywhere * near enough users to justify the costs. * * Fortunately, if anyone does want to use a Converter as a `Function<@Nullable A, @Nullable B>`,
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Jun 18 21:43:06 UTC 2025 - 22.8K bytes - Viewed (0)