Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for isLocked (0.12 sec)

  1. 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)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  3. 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();
        }
    
        public Artifact find(Artifact artifact) {
            File artifactFile = new File(getBasedir(), pathOf(artifact));
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 11K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top