RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-04-01 23:02:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

client: show read throughput in csyn read_file

Browse Source
This commit is contained in:
Sage Weil 2008-07-08 11:07:18 -07:00
parent 7f6d09ac41
commit fdb1212c5d
1 changed files with 23 additions and 3 deletions

26
src/client/SyntheticClient.cc
View File

@ -1824,7 +1824,7 @@ int SyntheticClient::write_file(string& fn, int size, int wrsize) // size is i
utime_t now = g_clock.now();
if (now - from >= 1.0) {
double el = now - from;
dout(0) << (bytes / el / 1048576.0) << " MB/sec" << dendl;
dout(0) << "write " << (bytes / el / 1048576.0) << " MB/sec" << dendl;
from = now;
bytes = 0;
}
@ -1834,7 +1834,7 @@ int SyntheticClient::write_file(string& fn, int size, int wrsize) // size is i
utime_t stop = g_clock.now();
double el = stop - start;
dout(0) << "total " << (total / el / 1048576.0) << " MB/sec ("
dout(0) << "write total " << (total / el / 1048576.0) << " MB/sec ("
<< total << " bytes in " << el << " seconds)" << dendl;
client->close(fd);
@ -1901,6 +1901,10 @@ int SyntheticClient::read_file(string& fn, int size, int rdsize, bool ignoreprin
dout(5) << "reading from " << fn << " fd " << fd << dendl;
if (fd < 0) return fd;
utime_t from = g_clock.now();
utime_t start = from;
__u64 bytes = 0, total = 0;
for (unsigned i=0; i<chunks; i++) {
if (time_to_stop()) break;
dout(2) << "reading block " << i << "/" << chunks << dendl;
@ -1910,6 +1914,17 @@ int SyntheticClient::read_file(string& fn, int size, int rdsize, bool ignoreprin
break;
}
bytes += rdsize;
total += rdsize;
utime_t now = g_clock.now();
if (now - from >= 1.0) {
double el = now - from;
dout(0) << "read " << (bytes / el / 1048576.0) << " MB/sec" << dendl;
from = now;
bytes = 0;
}
// verify fingerprint
int bad = 0;
uint64_t *p = (uint64_t*)buf;
@ -1933,7 +1948,12 @@ int SyntheticClient::read_file(string& fn, int size, int rdsize, bool ignoreprin
if (bad && !ignoreprint)
dout(0) << " + " << (bad-1) << " other bad 16-byte bits in this block" << dendl;
}
utime_t stop = g_clock.now();
double el = stop - start;
dout(0) << "read total " << (total / el / 1048576.0) << " MB/sec ("
<< total << " bytes in " << el << " seconds)" << dendl;
client->close(fd);
delete[] buf;