blob: 7cda42081fe2b97224428354c7daab78c28031a8 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
#include "diskio.h"
#include "common/strutil.h"
#include <kstat.h>
static inline void kstatFreeWrap(kstat_ctl_t** pkc) {
assert(pkc);
if (*pkc) {
kstat_close(*pkc);
}
}
const char* ffDiskIOGetIoCounters(FFlist* result, FFDiskIOOptions* options) {
FF_A_CLEANUP(kstatFreeWrap) kstat_ctl_t* kc = kstat_open();
if (!kc) {
return "kstat_open() failed";
}
for (kstat_t* ks = kc->kc_chain; ks; ks = ks->ks_next) {
if (ks->ks_type != KSTAT_TYPE_IO || !ffStrEquals(ks->ks_class, "disk")) {
continue;
}
if (options->namePrefix.length && strncmp(ks->ks_name, options->namePrefix.chars, options->namePrefix.length) != 0) {
continue;
}
kstat_io_t kio;
if (kstat_read(kc, ks, &kio) < 0) {
continue;
}
FFDiskIOResult* device = FF_LIST_ADD(FFDiskIOResult, *result);
ffStrbufInit(&device->devPath); // unlike other platforms, `/dev/ks_name` is not available
ffStrbufInitS(&device->name, ks->ks_name);
device->bytesRead = kio.nread;
device->readCount = kio.reads;
device->bytesWritten = kio.nwritten;
device->writeCount = kio.writes;
}
return NULL;
}
|