- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 48 for isLocked (0.13 sec)
-
pkg/volume/hostpath/host_path_test.go
if oftc.IsChar() { t.Errorf("[%d: %q] expected file, got unexpected character device: %s", i, tc.name, path) } } if tc.isSocket { if !oftc.IsSocket() { t.Errorf("[%d: %q] expected socket file, got unexpected: %s", i, tc.name, path) } if oftc.IsDir() { t.Errorf("[%d: %q] expected socket file, got unexpected folder: %s", i, tc.name, path) } if oftc.IsFile() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 20.5K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher.go
} mode := info.Mode() if mode.IsDir() { if err := w.fsWatcher.Add(path); err != nil { return fmt.Errorf("failed to watch %s, err: %v", path, err) } } else if isSocket, _ := util.IsUnixDomainSocket(path); isSocket { event := fsnotify.Event{ Name: path, Op: fsnotify.Create, } //TODO: Handle errors by taking corrective measures if err := w.handleCreateEvent(event); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 01 00:26:37 UTC 2023 - 6.1K bytes - Viewed (0) -
pkg/volume/util/hostutil/hostutil_windows.go
// on Windows. In this case, we need to use a different method to check if it's a Unix Socket. if err == errUnknownFileType || isSystemCannotAccessErr(err) { if isSocket, errSocket := filesystem.IsUnixDomainSocket(pathname); errSocket == nil && isSocket { return FileTypeSocket, nil } } return filetype, err } // PathExists checks whether the path exists
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 13:38:40 UTC 2024 - 4.7K 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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 18.7K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/artifact/repository/MavenArtifactRepository.java
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Dec 26 15:12:32 UTC 2022 - 11K bytes - Viewed (0) -
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: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Feb 23 17:14:45 UTC 2023 - 4.2K bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime.go
} // detectCRISocketImpl is separated out only for test purposes, DON'T call it directly, use DetectCRISocket instead func detectCRISocketImpl(isSocket func(string) bool, knownCRISockets []string) (string, error) { foundCRISockets := []string{} for _, socket := range knownCRISockets { if isSocket(socket) { foundCRISockets = append(foundCRISockets, socket) } } switch len(foundCRISockets) { case 0:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 06:33:22 UTC 2024 - 8.4K bytes - Viewed (0) -
pkg/volume/hostpath/host_path.go
} type hostPathTypeChecker interface { Exists() bool IsFile() bool MakeFile() error IsDir() bool MakeDir() error IsBlock() bool IsChar() bool IsSocket() bool GetPath() string } type fileTypeChecker struct { path string hu hostutil.HostUtils } func (ftc *fileTypeChecker) Exists() bool { exists, err := ftc.hu.PathExists(ftc.path)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 15.3K bytes - Viewed (0) -
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: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 6.7K bytes - Viewed (0) -
cmd/update_test.go
sci := globalIsCICD globalIsCICD = false defer func() { globalIsCICD = sci }() 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 Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Mar 09 03:07:08 UTC 2024 - 10.7K bytes - Viewed (0)