- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 204 for DevicePath (0.27 sec)
-
pkg/controller/volume/attachdetach/cache/actual_state_of_world_test.go
node2Name := types.NodeName("node2-name") devicePath := "fake/device/path" // Act logger, _ := ktesting.NewTestContext(t) generatedVolumeName1, add1Err := asw.AddVolumeNode(logger, volumeName, volumeSpec, node1Name, devicePath, true) generatedVolumeName2, add2Err := asw.AddVolumeNode(logger, volumeName, volumeSpec, node2Name, devicePath, true) // Assert if add1Err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 66.1K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi_util_test.go
} exist = waitForPathToExistInternal(&devicePath[1], 1, "tcp", os.Stat, fakeFilepathGlob) if exist != false { t.Errorf("waitForPathToExist: wrong code path called for %s", devicePath[1]) } _ = waitForPathToExistInternal(&devicePath[1], 1, "fake_iface", os.Stat, fakeFilepathGlob2) if devicePath[1] != fpath { t.Errorf("waitForPathToExist: wrong code path called for %s", devicePath[1]) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 18 09:43:07 UTC 2022 - 14.5K bytes - Viewed (0) -
pkg/volume/flexvolume/attacher.go
} else if err != nil { return "", err } return status.DevicePath, err } // WaitForAttach is part of the volume.Attacher interface func (a *flexVolumeAttacher) WaitForAttach(spec *volume.Spec, devicePath string, _ *v1.Pod, timeout time.Duration) (string, error) { call := a.plugin.NewDriverCallWithTimeout(waitForAttachCmd, timeout) call.Append(devicePath) call.AppendSpec(spec, a.plugin.host, nil) status, err := call.Run()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 03 23:29:42 UTC 2021 - 3.6K bytes - Viewed (0) -
pkg/volume/fc/fc_util.go
func (util *fcUtil) DetachBlockFCDisk(c fcDiskUnmapper, mapPath, devicePath string) error { // Check if devicePath is valid if len(devicePath) != 0 { if pathExists, pathErr := checkPathExists(devicePath); !pathExists || pathErr != nil { return pathErr } } else { // TODO: FC plugin can't obtain the devicePath from kubelet because devicePath // in volume object isn't updated when volume is attached to kubelet node.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 16 11:12:06 UTC 2022 - 12.8K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/core/v1/attachedvolume.go
return b } // WithDevicePath sets the DevicePath field in the declarative configuration to the given value // and returns the receiver, so that objects can be built by chaining "With" function invocations. // If called multiple times, the DevicePath field is set to the value of the last call. func (b *AttachedVolumeApplyConfiguration) WithDevicePath(value string) *AttachedVolumeApplyConfiguration { b.DevicePath = &value return b
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 04 18:31:34 UTC 2021 - 2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct.go
if volumeID != attachedVolume.Name { continue } rc.actualStateOfWorld.UpdateReconstructedDevicePath(volumeID, attachedVolume.DevicePath) attachable = true klog.V(4).InfoS("Updated devicePath from node status for volume", "volumeName", attachedVolume.Name, "path", attachedVolume.DevicePath) } rc.actualStateOfWorld.UpdateReconstructedVolumeAttachability(volumeID, attachable) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/volume/flexvolume/attacher-defaults.go
} // WaitForAttach is part of the volume.Attacher interface func (a *attacherDefaults) WaitForAttach(spec *volume.Spec, devicePath string, timeout time.Duration) (string, error) { klog.Warning(logPrefix(a.plugin.flexVolumePlugin), "using default WaitForAttach for volume ", spec.Name(), ", device ", devicePath) return devicePath, nil } // GetDeviceMountPath is part of the volume.Attacher interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 17 04:51:24 UTC 2020 - 2.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/cache/actual_state_of_world.go
deviceMountState: operationexecutor.DeviceNotMounted, devicePath: devicePath, } } else { // If volume object already exists, update the fields such as device path volumeObj.devicePath = devicePath klog.V(2).InfoS("Volume is already added to attachedVolume list, update device path", "volumeName", volumeName, "path", devicePath) } asw.attachedVolumes[volumeName] = volumeObj return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 45.8K bytes - Viewed (0) -
pkg/volume/util/volumepathhandler/volume_path_handler.go
if err := mounter.MountSensitiveWithoutSystemd(devicePath, linkPath, "" /* fsType */, []string{"bind"}, nil); err != nil { return fmt.Errorf("failed to bind mount devicePath: %s to linkPath %s: %v", devicePath, linkPath, err) } return nil } func mapSymlinkDevice(v VolumePathHandler, devicePath string, mapPath string, linkName string) error {
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/kubelet_pods_linux_test.go
Name: "container1", VolumeDevices: []v1.VolumeDevice{ { DevicePath: "/dev/sda", Name: "disk1", }, { DevicePath: "/dev/xvda", Name: "disk2", }, { DevicePath: "/dev/xvdb", Name: "disk3", }, { DevicePath: "/mnt/rawdisk", Name: "disk4", }, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 18:00:59 UTC 2024 - 11.3K bytes - Viewed (0)