fix: remove usage of deprecated "io/ioutil" (#278)

anonymous-api.go

@@ -27,7 +27,6 @@ import (
 	"errors"
 	"fmt"
 	"io"
-	"io/ioutil"
 	"net/http"
 	"net/http/cookiejar"
 	"net/http/httptrace"
@@ -193,7 +192,7 @@ func (an AnonymousClient) newRequest(ctx context.Context, method string, reqData
 	}
 	sum := sha256.Sum256(reqData.content)
 	req.Header.Set("X-Amz-Content-Sha256", hex.EncodeToString(sum[:]))
-	req.Body = ioutil.NopCloser(bytes.NewReader(reqData.content))
+	req.Body = io.NopCloser(bytes.NewReader(reqData.content))
 
 	return req, nil
 }

api-error-response.go

@@ -25,7 +25,6 @@ import (
 	"encoding/xml"
 	"fmt"
 	"io"
-	"io/ioutil"
 	"net/http"
 	"unicode/utf8"
 )
@@ -76,7 +75,7 @@ func httpRespToErrorResponse(resp *http.Response) error {
 
 	defer closeResponse(resp)
 	// Limit to 100K
-	body, err := ioutil.ReadAll(io.LimitReader(resp.Body, 100<<10))
+	body, err := io.ReadAll(io.LimitReader(resp.Body, 100<<10))
 	if err != nil {
 		return ErrorResponse{
 			Code:    resp.Status,

api.go

@@ -27,7 +27,6 @@ import (
 	"errors"
 	"fmt"
 	"io"
-	"io/ioutil"
 	"math/rand"
 	"net/http"
 	"net/http/cookiejar"
@@ -420,7 +419,7 @@ func (adm AdminClient) executeMethod(ctx context.Context, method string, reqData
 		}
 
 		// Read the body to be saved later.
-		errBodyBytes, err := ioutil.ReadAll(res.Body)
+		errBodyBytes, err := io.ReadAll(res.Body)
 		// res.Body should be closed
 		closeResponse(res)
 		if err != nil {
@@ -429,14 +428,14 @@ func (adm AdminClient) executeMethod(ctx context.Context, method string, reqData
 
 		// Save the body.
 		errBodySeeker := bytes.NewReader(errBodyBytes)
-		res.Body = ioutil.NopCloser(errBodySeeker)
+		res.Body = io.NopCloser(errBodySeeker)
 
 		// For errors verify if its retryable otherwise fail quickly.
 		errResponse := ToErrorResponse(httpRespToErrorResponse(res))
 
 		// Save the body back again.
 		errBodySeeker.Seek(0, 0) // Seek back to starting point.
-		res.Body = ioutil.NopCloser(errBodySeeker)
+		res.Body = io.NopCloser(errBodySeeker)
 
 		// Verify if error response code is retryable.
 		if isAdminErrCodeRetryable(errResponse.Code) {
@@ -534,9 +533,9 @@ func (adm AdminClient) newRequest(ctx context.Context, method string, reqData re
 	sum := sha256.Sum256(reqData.content)
 	req.Header.Set("X-Amz-Content-Sha256", hex.EncodeToString(sum[:]))
 	if reqData.contentReader != nil {
-		req.Body = ioutil.NopCloser(reqData.contentReader)
+		req.Body = io.NopCloser(reqData.contentReader)
 	} else {
-		req.Body = ioutil.NopCloser(bytes.NewReader(reqData.content))
+		req.Body = io.NopCloser(bytes.NewReader(reqData.content))
 	}
 
 	req = signer.SignV4(*req, accessKeyID, secretAccessKey, sessionToken, location)

bucket-metadata.go

@@ -23,7 +23,6 @@ import (
 	"context"
 	"encoding/json"
 	"io"
-	"io/ioutil"
 	"net/http"
 	"net/url"
 )
@@ -77,7 +76,7 @@ type BucketMetaImportErrs struct {
 
 // ImportBucketMetadata makes an admin call to set bucket metadata of a bucket from imported content
 func (adm *AdminClient) ImportBucketMetadata(ctx context.Context, bucket string, contentReader io.ReadCloser) (r BucketMetaImportErrs, err error) {
-	content, err := ioutil.ReadAll(contentReader)
+	content, err := io.ReadAll(contentReader)
 	if err != nil {
 		return r, err
 	}

cgroup/linux.go

@@ -29,7 +29,6 @@ import (
 	"bytes"
 	"fmt"
 	"io"
-	"io/ioutil"
 	"os"
 	"os/exec"
 	"path/filepath"
@@ -168,7 +167,7 @@ func GetMemoryLimit(pid int) (limit uint64, err error) {
 		// might not be installed. We fallback to using the the sysfs
 		// path instead to lookup memory limits.
 		var b []byte
-		b, err = ioutil.ReadFile(getMemoryLimitFilePath(path))
+		b, err = os.ReadFile(getMemoryLimitFilePath(path))
 		if err != nil {
 			return 0, err
 		}

cgroup/linux_test.go

@@ -23,14 +23,13 @@
 package cgroup
 
 import (
-	"io/ioutil"
 	"os"
 	"testing"
 )
 
 // Testing parsing correctness for various process cgroup files.
 func TestProcCGroup(t *testing.T) {
-	tmpPath, err := ioutil.TempFile("", "cgroup")
+	tmpPath, err := os.CreateTemp("", "cgroup")
 	if err != nil {
 		t.Fatal(err)
 	}

cluster-commands.go

@@ -22,7 +22,7 @@ package madmin
 import (
 	"context"
 	"encoding/json"
-	"io/ioutil"
+	"io"
 	"net/http"
 	"net/url"
 	"strconv"
@@ -98,7 +98,7 @@ func (adm *AdminClient) SiteReplicationAdd(ctx context.Context, sites []PeerSite
 		return ReplicateAddStatus{}, httpRespToErrorResponse(resp)
 	}
 
-	b, err := ioutil.ReadAll(resp.Body)
+	b, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return ReplicateAddStatus{}, err
 	}
@@ -139,7 +139,7 @@ func (adm *AdminClient) SiteReplicationInfo(ctx context.Context) (info SiteRepli
 		return info, httpRespToErrorResponse(resp)
 	}
 
-	b, err := ioutil.ReadAll(resp.Body)
+	b, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return info, err
 	}
@@ -600,7 +600,7 @@ func (adm *AdminClient) SRPeerGetIDPSettings(ctx context.Context) (info IDPSetti
 		return info, httpRespToErrorResponse(resp)
 	}
 
-	b, err := ioutil.ReadAll(resp.Body)
+	b, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return info, err
 	}

group-commands.go

@@ -22,7 +22,7 @@ package madmin
 import (
 	"context"
 	"encoding/json"
-	"io/ioutil"
+	"io"
 	"net/http"
 	"net/url"
 	"time"
@@ -94,7 +94,7 @@ func (adm *AdminClient) GetGroupDescription(ctx context.Context, group string) (
 		return nil, httpRespToErrorResponse(resp)
 	}
 
-	data, err := ioutil.ReadAll(resp.Body)
+	data, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return nil, err
 	}
@@ -123,7 +123,7 @@ func (adm *AdminClient) ListGroups(ctx context.Context) ([]string, error) {
 		return nil, httpRespToErrorResponse(resp)
 	}
 
-	data, err := ioutil.ReadAll(resp.Body)
+	data, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return nil, err
 	}

heal-commands.go

@@ -23,7 +23,7 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"io/ioutil"
+	"io"
 	"net/http"
 	"net/url"
 	"sort"
@@ -278,7 +278,7 @@ func (adm *AdminClient) Heal(ctx context.Context, bucket, prefix string,
 		return healStart, healTaskStatus, httpRespToErrorResponse(resp)
 	}
 
-	respBytes, err := ioutil.ReadAll(resp.Body)
+	respBytes, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return healStart, healTaskStatus, err
 	}
@@ -445,7 +445,7 @@ func (adm *AdminClient) BackgroundHealStatus(ctx context.Context) (BgHealState,
 		return BgHealState{}, httpRespToErrorResponse(resp)
 	}
 
-	respBytes, err := ioutil.ReadAll(resp.Body)
+	respBytes, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return BgHealState{}, err
 	}

health.go

@@ -25,7 +25,6 @@ import (
 	"encoding/json"
 	"errors"
 	"io"
-	"io/ioutil"
 	"net/http"
 	"net/url"
 	"os"
@@ -274,7 +273,7 @@ func getDriveHwInfo(partDevice string) (info driveHwInfo, err error) {
 	}
 
 	var data []byte
-	data, err = ioutil.ReadFile(devPath)
+	data, err = os.ReadFile(devPath)
 	if err != nil {
 		return
 	}

iam-migrate.go

@@ -22,7 +22,6 @@ package madmin
 import (
 	"context"
 	"io"
-	"io/ioutil"
 	"net/http"
 )
 
@@ -48,7 +47,7 @@ func (adm *AdminClient) ExportIAM(ctx context.Context) (io.ReadCloser, error) {
 
 // ImportIAM makes an admin call to setup IAM  from imported content
 func (adm *AdminClient) ImportIAM(ctx context.Context, contentReader io.ReadCloser) error {
-	content, err := ioutil.ReadAll(contentReader)
+	content, err := io.ReadAll(contentReader)
 	if err != nil {
 		return err
 	}

kernel/kernel.go

@@ -24,7 +24,7 @@ package kernel
 
 import (
 	"fmt"
-	"io/ioutil"
+	"os"
 	"regexp"
 	"strconv"
 	"strings"
@@ -78,7 +78,7 @@ func currentReleaseUname() (string, error) {
 }
 
 func currentReleaseUbuntu() (string, error) {
-	procVersion, err := ioutil.ReadFile("/proc/version_signature")
+	procVersion, err := os.ReadFile("/proc/version_signature")
 	if err != nil {
 		return "", err
 	}
@@ -101,7 +101,7 @@ func parseDebianRelease(str string) (string, error) {
 }
 
 func currentReleaseDebian() (string, error) {
-	procVersion, err := ioutil.ReadFile("/proc/version")
+	procVersion, err := os.ReadFile("/proc/version")
 	if err != nil {
 		return "", fmt.Errorf("error reading /proc/version: %s", err)
 	}

policy-commands.go

@@ -22,7 +22,7 @@ package madmin
 import (
 	"context"
 	"encoding/json"
-	"io/ioutil"
+	"io"
 	"net/http"
 	"net/url"
 	"time"
@@ -52,7 +52,7 @@ func (adm *AdminClient) InfoCannedPolicy(ctx context.Context, policyName string)
 		return nil, httpRespToErrorResponse(resp)
 	}
 
-	return ioutil.ReadAll(resp.Body)
+	return io.ReadAll(resp.Body)
 }
 
 // PolicyInfo contains information on a policy.
@@ -101,7 +101,7 @@ func (adm *AdminClient) InfoCannedPolicyV2(ctx context.Context, policyName strin
 		return nil, httpRespToErrorResponse(resp)
 	}
 
-	data, err := ioutil.ReadAll(resp.Body)
+	data, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return nil, err
 	}
@@ -129,7 +129,7 @@ func (adm *AdminClient) ListCannedPolicies(ctx context.Context) (map[string]json
 		return nil, httpRespToErrorResponse(resp)
 	}
 
-	respBytes, err := ioutil.ReadAll(resp.Body)
+	respBytes, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return nil, err
 	}

profiling-commands.go

@@ -25,7 +25,6 @@ import (
 	"errors"
 	"fmt"
 	"io"
-	"io/ioutil"
 	"net/http"
 	"net/url"
 	"time"
@@ -76,7 +75,7 @@ func (adm *AdminClient) StartProfiling(ctx context.Context, profiler ProfilerTyp
 		return nil, httpRespToErrorResponse(resp)
 	}
 
-	jsonResult, err := ioutil.ReadAll(resp.Body)
+	jsonResult, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return nil, err
 	}

quota-commands.go

@@ -22,7 +22,7 @@ package madmin
 import (
 	"context"
 	"encoding/json"
-	"io/ioutil"
+	"io"
 	"net/http"
 	"net/url"
 )
@@ -81,7 +81,7 @@ func (adm *AdminClient) GetBucketQuota(ctx context.Context, bucket string) (q Bu
 		return q, httpRespToErrorResponse(resp)
 	}
 
-	b, err := ioutil.ReadAll(resp.Body)
+	b, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return q, err
 	}

rebalance.go

@@ -22,7 +22,7 @@ package madmin
 import (
 	"context"
 	"encoding/json"
-	"io/ioutil"
+	"io"
 	"net/http"
 	"time"
 )
@@ -72,7 +72,7 @@ func (adm *AdminClient) RebalanceStart(ctx context.Context) (id string, err erro
 	var rebalInfo struct {
 		ID string `json:"id"`
 	}
-	respBytes, err := ioutil.ReadAll(resp.Body)
+	respBytes, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return id, err
 	}
@@ -99,7 +99,7 @@ func (adm *AdminClient) RebalanceStatus(ctx context.Context) (r RebalanceStatus,
 		return r, httpRespToErrorResponse(resp)
 	}
 
-	respBytes, err := ioutil.ReadAll(resp.Body)
+	respBytes, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return r, err
 	}