- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 48 for setReady (0.26 sec)
-
pkg/volume/git_repo/git_repo.go
strings.Join(args, " "), output, err) } files, err := ioutil.ReadDir(dir) if err != nil { return err } if len(b.revision) == 0 { // Done! volumeutil.SetReady(b.getMetaDir()) return nil } var subdir string switch { case len(b.target) != 0 && filepath.Clean(b.target) == ".": // if target dir is '.', use the current dir
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 8.2K bytes - Viewed (0) -
cni/pkg/install/install.go
// We had a watch error - that's no good return err case <-ctx.Done(): return ctx.Err() default: // Valid configuration; set isReady to true and wait for modifications before checking again setReady(in.isReady) cniInstalls.With(resultLabel.Value(resultSuccess)).Increment() // Pod set to "NotReady" before termination return watcher.Wait(ctx) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/volume/util/util.go
} if !s.Mode().IsRegular() { klog.Errorf("ready-file is not a file: %s", readyFile) return false } return true } // SetReady creates a file called 'ready' in the given // directory. It logs an error if the file cannot be // created. func SetReady(dir string) { if err := os.MkdirAll(dir, 0750); err != nil && !os.IsExist(err) { klog.Errorf("Can't mkdir %s: %v", dir, err) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.8K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir.go
// If setting up the quota fails, just log a message but don't actually error out. // We'll use the old du mechanism in this case, at least until we support // enforcement. if err == nil { volumeutil.SetReady(ed.getMetaDir()) err = ed.assignQuota(dir, mounterArgs.DesiredSize) } return err } // assignQuota checks if the underlying medium supports quotas and if so, sets
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 19K bytes - Viewed (0) -
pkg/volume/configmap/configmap_test.go
} if mounter == nil { t.Fatalf("Got a nil Mounter") } podMetadataDir := fmt.Sprintf("%v/pods/test_pod_uid3/plugins/kubernetes.io~configmap/test_volume_name", rootDir) util.SetReady(podMetadataDir) volumePath := mounter.GetPath() if !hasPathSuffix(volumePath, "pods/test_pod_uid3/volumes/kubernetes.io~configmap/test_volume_name") { t.Errorf("Got unexpected path: %s", volumePath) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 16 11:12:06 UTC 2022 - 19.9K bytes - Viewed (0) -
pkg/volume/secret/secret_test.go
} if mounter == nil { t.Fatalf("Got a nil Mounter") } podMetadataDir := fmt.Sprintf("%v/pods/test_pod_uid3/plugins/kubernetes.io~secret/test_volume_name", rootDir) util.SetReady(podMetadataDir) volumePath := mounter.GetPath() if !hasPathSuffix(volumePath, "pods/test_pod_uid3/volumes/kubernetes.io~secret/test_volume_name") { t.Errorf("Got unexpected path: %s", volumePath) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 01 15:56:32 UTC 2022 - 19.5K bytes - Viewed (0) -
pkg/volume/emptydir/empty_dir_test.go
}, }, }, }, } ) if config.readyDirExists { physicalMounter.MountPoints = []mount.MountPoint{ { Path: volumePath, }, } volumeutil.SetReady(metadataDir) } mounter, err := plug.(*emptyDirPlugin).newMounterInternal(volume.NewSpecFromVolume(spec), pod, physicalMounter, &mountDetector, volume.VolumeOptions{}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 30.7K bytes - Viewed (0) -
pkg/volume/projected/projected_test.go
} if mounter == nil { t.Errorf("Got a nil Mounter") } podMetadataDir := fmt.Sprintf("%v/pods/test_pod_uid3/plugins/kubernetes.io~projected/test_volume_name", rootDir) util.SetReady(podMetadataDir) volumePath := mounter.GetPath() if !strings.HasSuffix(volumePath, filepath.FromSlash("pods/test_pod_uid3/volumes/kubernetes.io~projected/test_volume_name")) { t.Errorf("Got unexpected path: %s", volumePath)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 40.5K bytes - Viewed (0) -
platforms/core-configuration/file-collections/src/main/java/org/gradle/api/internal/file/DefaultConfigurableUserClassFilePermissions.java
@Inject public DefaultConfigurableUserClassFilePermissions(int unixNumeric) { setRead(isRead(unixNumeric)); setWrite(isWrite(unixNumeric)); setExecute(isExecute(unixNumeric)); } @Override public void unix(String unixSymbolic) { setRead(isRead(unixSymbolic)); setWrite(isWrite(unixSymbolic)); setExecute(isExecute(unixSymbolic)); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 1.4K bytes - Viewed (0) -
src/sync/map_bench_test.go
const hits, misses = 1023, 1 benchMap(b, bench{ setup: func(_ *testing.B, m mapInterface) { for i := 0; i < hits; i++ { m.LoadOrStore(i, i) } // Prime the map to get it into a steady state. for i := 0; i < hits*2; i++ { m.Load(i % hits) } }, perG: func(b *testing.B, pb *testing.PB, i int, m mapInterface) { for ; pb.Next(); i++ { m.Load(i % (hits + misses)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 01 15:34:22 UTC 2024 - 11.5K bytes - Viewed (0)