- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for setReady (0.18 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/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) -
subprojects/core-api/src/main/java/org/gradle/api/file/ConfigurableUserClassFilePermissions.java
* <p> * Read access grants the capability to view the contents of a file, * or to list the contents of a directory. */ void setRead(boolean read); /** * Enables or disables write access to a file or directory for a certain class of users. * <p> * Write access grants the capability to modify or remove the contents of a file,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 06 12:31:43 UTC 2024 - 2K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager.go
} } // We have 3 major flows to handle: // 1. kubelet running, normal allocation (needed > 0, container being [re]created). Steady state and most common case by far and large. // 2. kubelet restart. In this scenario every other component of the stack (device plugins, app container, runtime) is still running.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/analysis/side_effect_analysis.cc
ResourceId GetResourceId() const { return resource_id_; } void SetAlloc() { effects_.set(kAlloc); } void SetFree() { effects_.set(kFree); } void SetRead() { effects_.set(kRead); } void SetWrite() { effects_.set(kWrite); } void SetUnknownEffect() { effects_.set(); } void SetResourceId(ResourceId resource_id) { resource_id_ = resource_id; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 15 09:04:13 UTC 2024 - 41.2K bytes - Viewed (0) -
src/runtime/mgcpacer.go
scan := c.heapScan.Load() work := c.heapScanWork.Load() + c.stackScanWork.Load() + c.globalsScanWork.Load() // Assume we're under the soft goal. Pace GC to complete at // heapGoal assuming the heap is in steady-state. heapGoal := int64(c.heapGoal()) // The expected scan work is computed as the amount of bytes scanned last // GC cycle (both heap and stack), plus our estimate of globals work for this cycle.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 55.4K bytes - Viewed (0) -
src/sync/map.go
// (so it would be made more efficient by promoting the dirty // map to read-only). // Count it as a miss so that we will eventually switch to the // more efficient steady state. m.missLocked() } return swapped } // CompareAndDelete deletes the entry for key if its value is equal to old. // The old value must be of a comparable type. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 15.6K bytes - Viewed (0)