Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for MapPodDevice (0.66 sec)

  1. pkg/volume/csi/csi_block_test.go

    	if err != nil {
    		t.Fatalf("failed to setup VolumeAttachment: %v", err)
    	}
    	t.Log("created attachment ", attachID)
    
    	// Map device to global and pod device map path
    	path, err := csiMapper.MapPodDevice()
    	if err != nil {
    		t.Fatalf("mapper failed to GetGlobalMapPath: %v", err)
    	}
    
    	// Check if NodePublishVolume published to the right path
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 11 06:07:40 UTC 2023
    - 26.5K bytes
    - Viewed (0)
  2. pkg/volume/csi/csi_block.go

    }
    
    func (m *csiBlockMapper) MapPodDevice() (string, error) {
    	klog.V(4).Infof(log("blockMapper.MapPodDevice called"))
    
    	// Get csiSource from spec
    	if m.spec == nil {
    		return "", errors.New(log("blockMapper.MapPodDevice spec is nil"))
    	}
    
    	csiSource, err := getCSISourceFromSpec(m.spec)
    	if err != nil {
    		return "", errors.New(log("blockMapper.MapPodDevice failed to get CSI persistent source: %v", err))
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 11 06:07:40 UTC 2023
    - 20.1K bytes
    - Viewed (0)
  3. pkg/volume/volume.go

    	SetUpDevice() (stagingPath string, err error)
    
    	// MapPodDevice maps the block device to a path and return the path.
    	// Unique device path across kubelet node reboot is required to avoid
    	// unexpected block volume destruction.
    	// If empty string is returned, the path returned by attacher.Attach() and
    	// attacher.WaitForAttach() will be used.
    	MapPodDevice() (publishPath string, err error)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  4. pkg/volume/local/local.go

    func (m *localVolumeMapper) SetUpDevice() (string, error) {
    	return "", nil
    }
    
    // MapPodDevice provides physical device path for the local PV.
    func (m *localVolumeMapper) MapPodDevice() (string, error) {
    	globalPath := util.MakeAbsolutePath(runtime.GOOS, m.globalPath)
    	klog.V(4).Infof("MapPodDevice returning path %s", globalPath)
    	return globalPath, nil
    }
    
    // GetStagingPath returns
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  5. pkg/volume/local/local_test.go

    		_, err = customMapper.SetUpDevice()
    		if err != nil {
    			t.Errorf("Failed to SetUpDevice, err: %v", err)
    		}
    		devPath, err = customMapper.MapPodDevice()
    		if err != nil {
    			t.Errorf("Failed to MapPodDevice, err: %v", err)
    		}
    	}
    
    	if _, err := os.Stat(devPath); err != nil {
    		if os.IsNotExist(err) {
    			t.Errorf("SetUpDevice() failed, volume path not created: %s", devPath)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 08 10:53:39 UTC 2023
    - 22.5K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_volumes_test.go

    func (f *stubBlockVolume) GetPodDeviceMapPath() (string, string) {
    	return f.dirPath, f.volName
    }
    
    func (f *stubBlockVolume) SetUpDevice() (string, error) {
    	return "", nil
    }
    
    func (f stubBlockVolume) MapPodDevice() error {
    	return nil
    }
    
    func (f *stubBlockVolume) TearDownDevice(mapPath string, devicePath string) error {
    	return nil
    }
    
    func (f *stubBlockVolume) UnmapPodDevice() error {
    	return nil
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 17 16:53:28 UTC 2023
    - 20.4K bytes
    - Viewed (0)
Back to top