mirror of
https://github.com/status-im/consul.git
synced 2025-02-11 05:07:02 +00:00
95c027a3ea
https://github.com/shirou/gopsutil/pull/895 is merged and fixes our problem. Time to update. Since there is no new version just yet, updating to the sha.
50 lines
1.3 KiB
Go
50 lines
1.3 KiB
Go
// +build darwin
|
|
// +build cgo
|
|
|
|
package disk
|
|
|
|
/*
|
|
#cgo LDFLAGS: -framework CoreFoundation -framework IOKit
|
|
#include <stdint.h>
|
|
#include <CoreFoundation/CoreFoundation.h>
|
|
#include "iostat_darwin.h"
|
|
*/
|
|
import "C"
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/shirou/gopsutil/internal/common"
|
|
)
|
|
|
|
func IOCounters(names ...string) (map[string]IOCountersStat, error) {
|
|
return IOCountersWithContext(context.Background(), names...)
|
|
}
|
|
|
|
func IOCountersWithContext(ctx context.Context, names ...string) (map[string]IOCountersStat, error) {
|
|
var buf [C.NDRIVE]C.DriveStats
|
|
n, err := C.readdrivestat(&buf[0], C.int(len(buf)))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
ret := make(map[string]IOCountersStat, 0)
|
|
for i := 0; i < int(n); i++ {
|
|
d := IOCountersStat{
|
|
ReadBytes: uint64(buf[i].read),
|
|
WriteBytes: uint64(buf[i].written),
|
|
ReadCount: uint64(buf[i].nread),
|
|
WriteCount: uint64(buf[i].nwrite),
|
|
ReadTime: uint64(buf[i].readtime / 1000 / 1000), // note: read/write time are in ns, but we want ms.
|
|
WriteTime: uint64(buf[i].writetime / 1000 / 1000),
|
|
IoTime: uint64((buf[i].readtime + buf[i].writetime) / 1000 / 1000),
|
|
Name: C.GoString(&buf[i].name[0]),
|
|
}
|
|
if len(names) > 0 && !common.StringsHas(names, d.Name) {
|
|
continue
|
|
}
|
|
|
|
ret[d.Name] = d
|
|
}
|
|
return ret, nil
|
|
}
|