Skip to content

Commit

Permalink
Cleanup various linting issues (#548)
Browse files Browse the repository at this point in the history
Fix up minor issues found by newer golangci-lint.
* Remove unused params.
* Fix unused-parameter issues.
* Fix redefines-builtin-id issues.

Signed-off-by: SuperQ <superq@gmail.com>
  • Loading branch information
SuperQ committed Jul 17, 2023
1 parent 4b2218e commit 9684daf
Show file tree
Hide file tree
Showing 10 changed files with 20 additions and 24 deletions.
2 changes: 1 addition & 1 deletion btrfs/get.go
Expand Up @@ -207,7 +207,7 @@ func (r *reader) calcRatio(p string) float64 {

// readDeviceInfo returns the information for all devices associated with this filesystem.
func (r *reader) readDeviceInfo(d string) map[string]*Device {
devs := r.listFiles("devices")
devs := r.listFiles(d)
info := make(map[string]*Device, len(devs))
for _, n := range devs {
info[n] = &Device{
Expand Down
8 changes: 4 additions & 4 deletions fs.go
Expand Up @@ -20,8 +20,8 @@ import (
// FS represents the pseudo-filesystem sys, which provides an interface to
// kernel data structures.
type FS struct {
proc fs.FS
real bool
proc fs.FS
isReal bool
}

// DefaultMountPoint is the common mount point of the proc filesystem.
Expand All @@ -41,10 +41,10 @@ func NewFS(mountPoint string) (FS, error) {
return FS{}, err
}

real, err := isRealProc(mountPoint)
isReal, err := isRealProc(mountPoint)
if err != nil {
return FS{}, err
}

return FS{fs, real}, nil
return FS{fs, isReal}, nil
}
6 changes: 2 additions & 4 deletions iscsi/get.go
Expand Up @@ -195,9 +195,8 @@ func (fs FS) GetRBDMatch(rbdNumber string, poolImage string) (*RBD, error) {
bSystemPool, err := os.ReadFile(systemPoolPath)
if err != nil {
continue
} else {
systemPool = strings.TrimSpace(string(bSystemPool))
}
systemPool = strings.TrimSpace(string(bSystemPool))

systemImagePath := filepath.Join(systemRbdPath, "name")
if _, err := os.Stat(systemImagePath); os.IsNotExist(err) {
Expand All @@ -206,9 +205,8 @@ func (fs FS) GetRBDMatch(rbdNumber string, poolImage string) (*RBD, error) {
bSystemImage, err := os.ReadFile(systemImagePath)
if err != nil {
continue
} else {
systemImage = strings.TrimSpace(string(bSystemImage))
}
systemImage = strings.TrimSpace(string(bSystemImage))

if strings.Compare(strconv.FormatInt(int64(systemRbdNumber), 10), rbdNumber) == 0 &&
matchPoolImage(systemPool, systemImage, poolImage) {
Expand Down
2 changes: 1 addition & 1 deletion proc.go
Expand Up @@ -244,7 +244,7 @@ func (p Proc) FileDescriptorTargets() ([]string, error) {
// a process.
func (p Proc) FileDescriptorsLen() (int, error) {
// Use fast path if available (Linux v6.2): https://github.com/torvalds/linux/commit/f1f1f2569901
if p.fs.real {
if p.fs.isReal {
stat, err := os.Stat(p.path("fd"))
if err != nil {
return 0, err
Expand Down
4 changes: 2 additions & 2 deletions proc_psi.go
Expand Up @@ -64,11 +64,11 @@ func (fs FS) PSIStatsForResource(resource string) (PSIStats, error) {
return PSIStats{}, fmt.Errorf("%s: psi_stats: unavailable for %q: %w", ErrFileRead, resource, err)
}

return parsePSIStats(resource, bytes.NewReader(data))
return parsePSIStats(bytes.NewReader(data))
}

// parsePSIStats parses the specified file for pressure stall information.
func parsePSIStats(resource string, r io.Reader) (PSIStats, error) {
func parsePSIStats(r io.Reader) (PSIStats, error) {
psiStats := PSIStats{}

scanner := bufio.NewScanner(r)
Expand Down
6 changes: 3 additions & 3 deletions proc_psi_test.go
Expand Up @@ -111,7 +111,7 @@ func TestPSIStats(t *testing.T) {
func TestParsePSIStats(t *testing.T) {
t.Run("unknown measurement type", func(t *testing.T) {
raw := "nonsense haha test=fake"
_, err := parsePSIStats("fake", strings.NewReader(raw))
_, err := parsePSIStats(strings.NewReader(raw))
if err != nil {
t.Error("unknown measurement type must be ignored")
}
Expand All @@ -121,7 +121,7 @@ func TestParsePSIStats(t *testing.T) {
t.Run("some", func(t *testing.T) {
raw := `some avg10=0.10 avg60=2.00 avg300=3.85 total=oops
full avg10=0.20 avg60=3.00 avg300=teddy total=25`
stats, err := parsePSIStats("fake", strings.NewReader(raw))
stats, err := parsePSIStats(strings.NewReader(raw))
if err == nil {
t.Error("a malformed line must result in a parse error")
}
Expand All @@ -133,7 +133,7 @@ full avg10=0.20 avg60=3.00 avg300=teddy total=25`
t.Run("full", func(t *testing.T) {
raw := `some avg10=0.10 avg60=2.00 avg300=3.85 total=1
full avg10=0.20 avg60=3.00 avg300=test total=25`
stats, err := parsePSIStats("fake", strings.NewReader(raw))
stats, err := parsePSIStats(strings.NewReader(raw))
t.Log(err)
t.Log(stats)
if err == nil {
Expand Down
4 changes: 2 additions & 2 deletions proc_smaps.go
Expand Up @@ -135,12 +135,12 @@ func (s *ProcSMapsRollup) parseLine(line string) error {
}
vBytes := vKBytes * 1024

s.addValue(k, v, vKBytes, vBytes)
s.addValue(k, vBytes)

return nil
}

func (s *ProcSMapsRollup) addValue(k string, vString string, vUint uint64, vUintBytes uint64) {
func (s *ProcSMapsRollup) addValue(k string, vUintBytes uint64) {
switch k {
case "Rss":
s.Rss += vUintBytes
Expand Down
3 changes: 1 addition & 2 deletions sysfs/class_sas_device.go
Expand Up @@ -163,9 +163,8 @@ func (fs FS) blockSASDeviceBlockDevices(name string) ([]string, error) {
if err != nil {
if os.IsNotExist(err) {
continue
} else {
return nil, err
}
return nil, err
}

for _, blockdevice := range blocks {
Expand Down
3 changes: 1 addition & 2 deletions sysfs/class_sas_phy.go
Expand Up @@ -99,9 +99,8 @@ func (fs FS) parseSASPhy(name string) (*SASPhy, error) {
if err != nil {
if os.IsPermission(err) {
continue
} else {
return nil, fmt.Errorf("failed to read file %q: %w", name, err)
}
return nil, fmt.Errorf("failed to read file %q: %w", name, err)
}

vp := util.NewValueParser(value)
Expand Down
6 changes: 3 additions & 3 deletions thread.go
Expand Up @@ -55,7 +55,7 @@ func (fs FS) AllThreads(pid int) (Procs, error) {
continue
}

t = append(t, Proc{PID: int(tid), fs: FS{fsi.FS(taskPath), fs.real}})
t = append(t, Proc{PID: int(tid), fs: FS{fsi.FS(taskPath), fs.isReal}})
}

return t, nil
Expand All @@ -67,12 +67,12 @@ func (fs FS) Thread(pid, tid int) (Proc, error) {
if _, err := os.Stat(taskPath); err != nil {
return Proc{}, err
}
return Proc{PID: tid, fs: FS{fsi.FS(taskPath), fs.real}}, nil
return Proc{PID: tid, fs: FS{fsi.FS(taskPath), fs.isReal}}, nil
}

// Thread returns a process for a given TID of Proc.
func (proc Proc) Thread(tid int) (Proc, error) {
tfs := FS{fsi.FS(proc.path("task")), proc.fs.real}
tfs := FS{fsi.FS(proc.path("task")), proc.fs.isReal}
if _, err := os.Stat(tfs.proc.Path(strconv.Itoa(tid))); err != nil {
return Proc{}, err
}
Expand Down

0 comments on commit 9684daf

Please sign in to comment.