chore: remove refs to deprecated io/ioutil

api-service/node/services/hugepages.go

@@ -15,7 +15,7 @@ package services
 
 import (
 	"context"
-	"io/ioutil"
+	"os"
 	"strconv"
 	"strings"
 
@@ -41,7 +41,7 @@ func (n *Node) SetHugepages(ctx context.Context, h *protos.Hugepages) (*protos.H
 	}
 
 	msg := []byte(strconv.Itoa(int(hugepages.Pages)))
-	err := ioutil.WriteFile(hugepagesPath, msg, 0644)
+	err := os.WriteFile(hugepagesPath, msg, 0600)
 	if err != nil {
 		klog.Errorf("Error setting huge pages: %v", err)
 		return nil, status.Errorf(codes.Internal, "Error setting hugepages")
@@ -55,7 +55,7 @@ func (n *Node) GetHugepages(ctx context.Context, null *protos.Null) (*protos.Hug
 
 	klog.Info("Getting the number of hugepages")
 
-	hugepages, err := ioutil.ReadFile(hugepagesPath)
+	hugepages, err := os.ReadFile(hugepagesPath)
 	if err != nil {
 		klog.Errorf("Error fetching number of hugepages %v", err)
 		return nil, status.Errorf(codes.Internal, "Error fetching the number of hugepages set on the node")

cmd/ndm_daemonset/controller/ndmconfig.go

@@ -18,7 +18,7 @@ package controller
 
 import (
 	"encoding/json"
-	"io/ioutil"
+	"os"
 
 	"k8s.io/klog/v2"
 	"sigs.k8s.io/yaml"
@@ -73,7 +73,7 @@ type MetaConfig struct {
 // SetNDMConfig sets config for probes and filters which user provides via configmap. If
 // no configmap present then ndm will load default config for each probes and filters.
 func (c *Controller) SetNDMConfig(opts NDMOptions) {
-	data, err := ioutil.ReadFile(opts.ConfigFilePath)
+	data, err := os.ReadFile(opts.ConfigFilePath)
 	if err != nil {
 		c.NDMConfig = nil
 		klog.Error("unable to set ndm config : ", err)

cmd/ndm_daemonset/controller/ndmconfig_test.go

@@ -17,7 +17,6 @@ limitations under the License.
 package controller
 
 import (
-	"io/ioutil"
 	"os"
 	"testing"
 
@@ -47,7 +46,7 @@ func TestSetNDMConfig(t *testing.T) {
             },
         ]
     }`)
-	err := ioutil.WriteFile(fakeConfigFilePath, fileContent, 0644)
+	err := os.WriteFile(fakeConfigFilePath, fileContent, 0644)
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -88,7 +87,7 @@ func TestSetNDMConfig(t *testing.T) {
 	expectedNDMConfig.FilterConfigs = append(expectedNDMConfig.FilterConfigs, expectedFilterConfig)
 	expectedNDMConfig.ProbeConfigs = append(expectedNDMConfig.ProbeConfigs, expectedProbeConfig)
 
-	err = ioutil.WriteFile(fakeConfigFilePath, fileContent, 0644)
+	err = os.WriteFile(fakeConfigFilePath, fileContent, 0644)
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -135,6 +134,6 @@ filterconfigs:
     exclude: /,/etc/hosts,/boot
 `
 
-	err := ioutil.WriteFile(fpath, []byte(data), 0644)
+	err := os.WriteFile(fpath, []byte(data), 0644)
 	assert.NoError(t, err)
 }

cmd/ndm_daemonset/controller/sparsefilegenerator.go

@@ -17,7 +17,6 @@ limitations under the License.
 package controller
 
 import (
-	"io/ioutil"
 	"strings"
 
 	"github.com/openebs/node-disk-manager/blockdevice"
@@ -183,7 +182,7 @@ func GetSparseBlockDeviceUUID(hostname, sparseFile string) string {
 func GetActiveSparseBlockDevicesUUID(hostname string) []string {
 	sparseFileLocation := GetSparseFileDir()
 	sparseUuids := make([]string, 0)
-	files, err := ioutil.ReadDir(sparseFileLocation)
+	files, err := os.ReadDir(sparseFileLocation)
 	if err != nil {
 		klog.Error("Failed to read sparse file names : ", err)
 		return sparseUuids

cmd/ndm_daemonset/probe/mountprobe_test.go

@@ -17,7 +17,6 @@ limitations under the License.
 package probe
 
 import (
-	"io/ioutil"
 	"os"
 	"path"
 	"syscall"
@@ -141,5 +140,5 @@ func exitFakeRoot() error {
 }
 
 func createMountsFile(dest string) error {
-	return ioutil.WriteFile(dest, []byte(sampleMountsFile), 0444)
+	return os.WriteFile(dest, []byte(sampleMountsFile), 0444)
 }

integration_tests/sanity/mount_change_test.go

@@ -17,7 +17,7 @@ limitations under the License.
 package sanity
 
 import (
-	"io/ioutil"
+	"os"
 
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
@@ -78,7 +78,7 @@ func tearDown(kcli *k8s.K8sClient, disk *udev.Disk) func() {
 
 func generateMountPath(mountPath *string) func() {
 	return func() {
-		mp, err := ioutil.TempDir("", "ndm-integration-tests")
+		mp, err := os.MkdirTemp("", "ndm-integration-tests")
 		Expect(err).ToNot(HaveOccurred())
 		*mountPath = mp
 	}

integration_tests/utils/file.go

@@ -18,14 +18,13 @@ package utils
 
 import (
 	"fmt"
-	"io/ioutil"
 	"os"
 	"path/filepath"
 )
 
 // GetYAMLString gets the yaml-string from the given YAML file
 func GetYAMLString(fileName string) (string, error) {
-	fileBytes, err := ioutil.ReadFile(filepath.Clean(fileName))
+	fileBytes, err := os.ReadFile(filepath.Clean(fileName))
 	if err != nil {
 		return "", err
 	}

pkg/mount/mountutil_test.go

@@ -18,7 +18,6 @@ package mount
 
 import (
 	"errors"
-	"io/ioutil"
 	"os"
 	"path/filepath"
 	"strings"
@@ -164,7 +163,7 @@ func TestGetMountAttr(t *testing.T) {
 			mountUtil := NewMountUtil(filePath, test.devPath, test.mountPoint)
 
 			// create the temp file which will be read for getting attributes
-			err := ioutil.WriteFile(filePath, test.fileContent, 0644)
+			err := os.WriteFile(filePath, test.fileContent, 0644)
 			if err != nil {
 				t.Fatal(err)
 			}

pkg/sysfs/syspath.go

@@ -18,7 +18,6 @@ package sysfs
 
 import (
 	"fmt"
-	"io/ioutil"
 	"os"
 	"path/filepath"
 	"strings"
@@ -112,7 +111,7 @@ func (s Device) getPartitions() ([]string, bool) {
 
 	partitions := make([]string, 0)
 
-	files, err := ioutil.ReadDir(s.sysPath)
+	files, err := os.ReadDir(s.sysPath)
 	if err != nil {
 		return nil, false
 	}
@@ -135,7 +134,7 @@ func (s Device) getHolders() ([]string, bool) {
 		return nil, false
 	}
 
-	files, err := ioutil.ReadDir(holderPath)
+	files, err := os.ReadDir(holderPath)
 	if err != nil {
 		return nil, false
 	}
@@ -157,7 +156,7 @@ func (s Device) getSlaves() ([]string, bool) {
 		return nil, false
 	}
 
-	files, err := ioutil.ReadDir(slavePath)
+	files, err := os.ReadDir(slavePath)
 	if err != nil {
 		return nil, false
 	}

pkg/sysfs/util.go

@@ -17,7 +17,7 @@ limitations under the License.
 package sysfs
 
 import (
-	"io/ioutil"
+	"os"
 	"path/filepath"
 	"strconv"
 	"strings"
@@ -26,7 +26,7 @@ import (
 // readSysFSFileAsInt64 reads a file and
 // converts that content into int64
 func readSysFSFileAsInt64(sysFilePath string) (int64, error) {
-	b, err := ioutil.ReadFile(filepath.Clean(sysFilePath))
+	b, err := os.ReadFile(filepath.Clean(sysFilePath))
 	if err != nil {
 		return 0, err
 	}
@@ -35,7 +35,7 @@ func readSysFSFileAsInt64(sysFilePath string) (int64, error) {
 }
 
 func readSysFSFileAsString(sysFilePath string) (string, error) {
-	b, err := ioutil.ReadFile(filepath.Clean(sysFilePath))
+	b, err := os.ReadFile(filepath.Clean(sysFilePath))
 	if err != nil {
 		return "", err
 	}

pkg/udev/mockdata.go

@@ -25,7 +25,6 @@ package udev
 import "C"
 import (
 	"bufio"
-	"io/ioutil"
 	"os"
 	"path"
 	"path/filepath"
@@ -145,7 +144,7 @@ func OsDiskName() (string, string, error) {
 
 // getSyspathOfOsDisk returns syspath of os disk in success
 func getSyspathOfOsDisk(osDiskName string) (string, error) {
-	data, err := ioutil.ReadFile(filepath.Clean(path.Join("/sys/class/block/", osDiskName, "dev")))
+	data, err := os.ReadFile(filepath.Clean(path.Join("/sys/class/block/", osDiskName, "dev")))
 	if err != nil {
 		return "", err
 	}
@@ -154,7 +153,7 @@ func getSyspathOfOsDisk(osDiskName string) (string, error) {
 
 // getOsDiskSize returns size of os disk in success
 func getOsDiskSize(osDiskName string) (string, error) {
-	sizeByte, err := ioutil.ReadFile(filepath.Clean(path.Join("/sys/class/block/", osDiskName, "size")))
+	sizeByte, err := os.ReadFile(filepath.Clean(path.Join("/sys/class/block/", osDiskName, "size")))
 	if err != nil {
 		return "", err
 	}