- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for isLocked (0.08 sec)
-
internal/dsync/drwmutex.go
// Granted - represents a structure of a granted lock. type Granted struct { index int lockUID string // Locked if set with UID string, unlocked if empty } func (g *Granted) isLocked() bool { return isLocked(g.lockUID) } func isLocked(uid string) bool { return len(uid) > 0 } // NewDRWMutex - initializes a new dsync RW mutex. func NewDRWMutex(clnt *Dsync, names ...string) *DRWMutex {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 15:49:49 UTC 2024 - 20.4K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/artifact/repository/MavenArtifactRepository.java
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 11K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/DefaultArtifactRepository.java
this.mirroredRepositories = Collections.unmodifiableList(mirroredRepositories); } else { this.mirroredRepositories = Collections.emptyList(); } } public boolean isBlocked() { return blocked; } public void setBlocked(boolean blocked) { this.blocked = blocked; }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 7.3K 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 Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 31.6K bytes - Viewed (0) -
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 Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 6.7K 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 Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4.2K bytes - Viewed (1) -
impl/maven-core/src/main/java/org/apache/maven/bridge/MavenRepositorySystem.java
mirror.setId(repo.getId()); mirror.setUrl(repo.getUrl()); mirror.setLayout(repo.getContentType()); mirror.setBlocked(repo.isBlocked()); return mirror; } } } return null; }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 32.6K 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 Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 47.1K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/LegacyLocalRepositoryManager.java
return Collections.emptyList(); } public void setMirroredRepositories(List<ArtifactRepository> mirroredRepositories) {} public boolean isBlocked() { return false; } public void setBlocked(boolean blocked) {} }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 12.2K 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 Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 25.8K bytes - Viewed (0)