Measure throughput in RealDataBench
This commit is contained in:
@@ -32,6 +32,8 @@ int main(int argc, const char **argv) {
|
||||
double checkTime = 0;
|
||||
double addTime = 0;
|
||||
double gcTime = 0;
|
||||
double checkBytes = 0;
|
||||
double addBytes = 0;
|
||||
|
||||
ConflictSet cs{0};
|
||||
int64_t version = 0;
|
||||
@@ -76,6 +78,7 @@ int main(int argc, const char **argv) {
|
||||
for (const auto &read : reads) {
|
||||
iter->begin.p = (const uint8_t *)read.data();
|
||||
iter->begin.len = read.size();
|
||||
checkBytes += read.size();
|
||||
iter->end.len = 0;
|
||||
iter->readVersion = version - 100;
|
||||
++iter;
|
||||
@@ -95,6 +98,8 @@ int main(int argc, const char **argv) {
|
||||
w.begin.len = write.size();
|
||||
w.end.len = 0;
|
||||
|
||||
addBytes += write.size();
|
||||
|
||||
timer = now();
|
||||
cs.addWrites(&w, 1);
|
||||
addTime += now() - timer;
|
||||
@@ -110,5 +115,8 @@ int main(int argc, const char **argv) {
|
||||
close(fd);
|
||||
}
|
||||
|
||||
printf("Check: %g, Add: %g, Gc: %g\n", checkTime, addTime, gcTime);
|
||||
printf("Check: %g seconds, %g MB/s, Add: %g seconds, %g MB/s, Gc: %g "
|
||||
"seconds\n",
|
||||
checkTime, checkBytes / checkTime * 1e-6, addTime,
|
||||
addBytes / addTime * 1e-6, gcTime);
|
||||
}
|
Reference in New Issue
Block a user