- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 400 for Unmount (0.16 sec)
-
pkg/kubelet/volumemanager/reconciler/reconciler_common.go
// are all ready (before sources are ready, pods are probably missing) // // operationExecutor - used to trigger attach/detach/mount/unmount operations // safely (prevents more than one operation from being triggered on the same // volume) // // mounter - mounter passed in from kubelet, passed down unmount path // // hostutil - hostutil passed in from kubelet // // volumePluginMgr - volume plugin manager passed from kubelet
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_executor.go
OuterVolumeSpecName string // PluginName is the "Unescaped Qualified" name of the volume plugin used to // mount and unmount this volume. It can be used to fetch the volume plugin // to unmount with, on demand. It is also the name that plugins use, though // escaped, in their pod mount path, i.e. // /var/lib/kubelet/pods/{podUID}/volumes/{escapeQualifiedPluginName}/{outerVolumeSpecName}/ PluginName string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/volume/util/volumepathhandler/volume_path_handler.go
return fmt.Errorf("failed to remove file %s: %v", linkPath, err) } return nil } // Unmount file mounter := &mount.SafeFormatAndMount{Interface: mount.New(""), Exec: utilexec.New()} if err := mounter.Unmount(linkPath); err != nil { return fmt.Errorf("failed to unmount linkPath %s: %v", linkPath, err) } // Remove file if err := os.Remove(linkPath); err != nil && !os.IsNotExist(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 10.7K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
// The data structure is populated upon successful completion of attach, // detach, mount, and unmount actions triggered by the reconciler. actualStateOfWorld cache.ActualStateOfWorld // operationExecutor is used to start asynchronous attach, detach, mount, // and unmount operations. operationExecutor operationexecutor.OperationExecutor
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/volume/util/subpath/subpath_linux.go
samePath, err := checkSubPathFileEqual(subpath, bindPathTarget) if err != nil { return false, "", fmt.Errorf("error checking subpath mount info for %s: %s", bindPathTarget, err) } if !samePath { // It's already mounted but not what we want, unmount it if err = mounter.Unmount(bindPathTarget); err != nil { return false, "", fmt.Errorf("error ummounting %s: %s", bindPathTarget, err) } } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 12 14:09:11 UTC 2022 - 21.4K bytes - Viewed (0) -
src/syscall/exec_linux_test.go
const mountNotSupported = "mount is not supported: " // Output prefix indicating a test skip. if os.Getenv("GO_WANT_HELPER_PROCESS") == "1" { dir := flag.Args()[0] err := syscall.Mount("none", dir, "proc", 0, "") if testenv.SyscallIsNotSupported(err) { fmt.Print(mountNotSupported, err) } else if err != nil { fmt.Fprintf(os.Stderr, "unshare: mount %s: %v\n", dir, err) os.Exit(2) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 07:45:37 UTC 2024 - 20.6K bytes - Viewed (0) -
pkg/volume/csi/csi_test.go
} // The reason for separate volume hosts here is because the attach/detach behavior is exclusive to the // CSI plugin running in the AttachDetachController. Similarly, the mount/unmount behavior is exclusive // to the CSI plugin running in the Kubelet. kubeletVolumeHost := volumetest.NewFakeKubeletVolumeHostWithCSINodeName(t, tmpDir, client, ProbeVolumePlugins(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 15:55:13 UTC 2022 - 21.1K bytes - Viewed (0) -
pkg/volume/local/local.go
var _ volume.Unmounter = &localVolumeUnmounter{} // TearDown unmounts the bind mount func (u *localVolumeUnmounter) TearDown() error { return u.TearDownAt(u.GetPath()) } // TearDownAt unmounts the bind mount func (u *localVolumeUnmounter) TearDownAt(dir string) error { klog.V(4).Infof("Unmounting volume %q at path %q\n", u.volName, dir) return mount.CleanupMountPoint(dir, u.mounter, true) /* extensiveMountPointCheck = true */
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
// Assert if len(rcInstance.volumesFailedReconstruction) != 0 { t.Errorf("Expected volumesFailedReconstruction to be empty, got %+v", rcInstance.volumesFailedReconstruction) } // Unmount runs in a go routine, wait for its finish var lastErr error err = retryWithExponentialBackOff(testOperationBackOffDuration, func() (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
// In particular, the Unmount method uses spec.Name() as the volumeSpecName // in the mount path: // /var/lib/kubelet/pods/{podUID}/volumes/{escapeQualifiedPluginName}/{volumeSpecName}/ spec *volume.Spec // pluginName is the Unescaped Qualified name of the volume plugin used to // attach and mount this volume. It is stored separately in case the full
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0)