IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

style changes

Browse Source
This commit is contained in:
ShaunakDas88 2023-10-04 17:20:18 -07:00
parent 4502a5ec61
commit bce0f9b297
3 changed files with 9 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
engine-api/src/main/java/io/nosqlbench/engine/api/activityimpl/uniform/DiskStatsReader.java
View File

@ -66,20 +66,18 @@ public class DiskStatsReader {
int sectorSizeBytes = 512; int sectorSizeBytes = 512;
String line; String line;
while ((line = reader.readLine()) != null) { while ((line = reader.readLine()) != null) {
String[] fields = line.trim().split("\\s+"); String[] parts = line.trim().split("\\s+");
if (fields.length < 14) if (parts.length < 14)
continue; continue;
Map<String,Double> innerMap = new HashMap<>(); Map<String,Double> innerMap = new HashMap<>();
String device = fields[2]; String device = parts[2];
Double readsCompleted = Double.parseDouble(fields[3]); Double readsCompleted = Double.parseDouble(parts[3]);
Double sectorsRead = Double.parseDouble(fields[5]); Double sectorsRead = Double.parseDouble(parts[5]);
Double writesCompleted = Double.parseDouble(fields[7]); Double writesCompleted = Double.parseDouble(parts[7]);
Double sectorsWritten = Double.parseDouble(fields[9]); Double sectorsWritten = Double.parseDouble(parts[9]);
Double transactions = readsCompleted + writesCompleted; Double transactions = readsCompleted + writesCompleted;
Double kbRead = (sectorsRead * sectorSizeBytes) / 1024; Double kbRead = (sectorsRead * sectorSizeBytes) / 1024;
Double kbWritten = (sectorsWritten * sectorSizeBytes) / 1024; Double kbWritten = (sectorsWritten * sectorSizeBytes) / 1024;
innerMap.put("transactions", transactions); innerMap.put("transactions", transactions);
innerMap.put("kB_read", kbRead); innerMap.put("kB_read", kbRead);
innerMap.put("kB_written", kbWritten); innerMap.put("kB_written", kbWritten);

6
engine-api/src/main/java/io/nosqlbench/engine/api/activityimpl/uniform/MemInfoReader.java
View File

@ -76,12 +76,10 @@ public class MemInfoReader {
metricsMap.put(key, value); metricsMap.put(key, value);
} }
} }
if (metricsMap.get("MemTotal") != null && metricsMap.get("MemFree") != null) { if (metricsMap.get("MemTotal") != null && metricsMap.get("MemFree") != null)
metricsMap.put("MemUsed", metricsMap.get("MemTotal") - metricsMap.get("MemFree")); metricsMap.put("MemUsed", metricsMap.get("MemTotal") - metricsMap.get("MemFree"));
} if (metricsMap.get("SwapTotal") != null && metricsMap.get("SwapFree") != null)
if (metricsMap.get("SwapTotal") != null && metricsMap.get("SwapFree") != null) {
metricsMap.put("SwapUsed", metricsMap.get("SwapTotal") - metricsMap.get("SwapFree")); metricsMap.put("SwapUsed", metricsMap.get("SwapTotal") - metricsMap.get("SwapFree"));
}
} catch (FileNotFoundException e) { } catch (FileNotFoundException e) {
return; return;
} }

1
engine-api/src/main/java/io/nosqlbench/engine/api/activityimpl/uniform/StatReader.java
View File

@ -74,7 +74,6 @@ public class StatReader {
Double irq = Double.parseDouble(parts[6]); Double irq = Double.parseDouble(parts[6]);
Double softirq = Double.parseDouble(parts[7]); Double softirq = Double.parseDouble(parts[7]);
Double steal = Double.parseDouble(parts[8]); Double steal = Double.parseDouble(parts[8]);
Double total = user + nice + system + idle + iowait + irq + softirq + steal; Double total = user + nice + system + idle + iowait + irq + softirq + steal;
metricsMap.put("user", user); metricsMap.put("user", user);
metricsMap.put("system", system); metricsMap.put("system", system);