fix: fixed windows disk package leaks

- fixed goroutine leak in PartitionsWithContext
- closed registry handle in init

disk/disk_windows.go

@@ -7,7 +7,6 @@ import (
 	"bytes"
 	"context"
 	"fmt"
-	"sync"
 	"syscall"
 	"unsafe"
 
@@ -51,6 +50,7 @@ func init() {
 	key, err := registry.OpenKey(registry.LOCAL_MACHINE, `SYSTEM\CurrentControlSet\Services\PartMgr`, registry.SET_VALUE)
 	if err == nil {
 		key.SetDWordValue("EnableCounterForIoctl", 1)
+		key.Close()
 	}
 }
 
@@ -86,28 +86,22 @@ func PartitionsWithContext(ctx context.Context, all bool) ([]PartitionStat, erro
 	warnings := Warnings{
 		Verbose: true,
 	}
-	var ret []PartitionStat
-	retChan := make(chan []PartitionStat)
-	errChan := make(chan error)
-	lpBuffer := make([]byte, 254)
 
-	var waitgrp sync.WaitGroup
+	var errLogicalDrives error
-	waitgrp.Add(1)
+	retChan := make(chan PartitionStat)
-	defer waitgrp.Done()
+	quitChan := make(chan struct{})
+	defer close(quitChan)
+
+	getPartitions := func() {
+		defer close(retChan)
 
-	f := func() {
+		lpBuffer := make([]byte, 254)
-		defer func() {
-			waitgrp.Wait()
-			// fires when this func and the outside func finishes.
-			close(errChan)
-			close(retChan)
-		}()
 
 		diskret, _, err := procGetLogicalDriveStringsW.Call(
 			uintptr(len(lpBuffer)),
 			uintptr(unsafe.Pointer(&lpBuffer[0])))
 		if diskret == 0 {
-			errChan <- err
+			errLogicalDrives = err
 			return
 		}
 		for _, v := range lpBuffer {
@@ -153,28 +147,38 @@ func PartitionsWithContext(ctx context.Context, all bool) ([]PartitionStat, erro
 						opts = append(opts, "compress")
 					}
 
-					d := PartitionStat{
+					select {
+					case retChan <- PartitionStat{
 						Mountpoint: path,
 						Device:     path,
-						Fstype:     string(bytes.Replace(lpFileSystemNameBuffer, []byte("\x00"), []byte(""), -1)),
+						Fstype:     string(bytes.ReplaceAll(lpFileSystemNameBuffer, []byte("\x00"), []byte(""))),
 						Opts:       opts,
+					}:
+					case <-quitChan:
+						return
 					}
-					ret = append(ret, d)
 				}
 			}
 		}
-		retChan <- ret
 	}
 
-	go f()
+	go getPartitions()
+
+	var ret []PartitionStat
+	for {
 		select {
-	case err := <-errChan:
+		case p, ok := <-retChan:
-		return ret, err
+			if !ok {
-	case ret := <-retChan:
+				if errLogicalDrives != nil {
+					return ret, errLogicalDrives
+				}
 				return ret, warnings.Reference()
+			}
+			ret = append(ret, p)
 		case <-ctx.Done():
 			return ret, ctx.Err()
 		}
+	}
 }
 
 func IOCountersWithContext(ctx context.Context, names ...string) (map[string]IOCountersStat, error) {