summaryrefslogtreecommitdiff
path: root/src/streamtest.cc
diff options
context:
space:
mode:
authorColin Patrick McCabe <cmccabe@alumni.cmu.edu>2011-06-14 14:14:15 -0700
committerColin Patrick McCabe <cmccabe@alumni.cmu.edu>2011-06-20 16:34:17 -0700
commit7735b35fb0c4be81c6f142db80ab497e9eb7afb4 (patch)
tree2644c2aaeeca61350b7c2d01f7cad64c197c8b27 /src/streamtest.cc
parent2452ef440e615e92fe0f6730fe0fa20f99e599c4 (diff)
downloadceph-7735b35fb0c4be81c6f142db80ab497e9eb7afb4.tar.gz
g_clock.now -> ceph_clock_now
Signed-off-by: Colin McCabe <colin.mccabe@dreamhost.com>
Diffstat (limited to 'src/streamtest.cc')
-rw-r--r--src/streamtest.cc8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/streamtest.cc b/src/streamtest.cc
index 0af3cc66c1c..8583f8d3c47 100644
--- a/src/streamtest.cc
+++ b/src/streamtest.cc
@@ -78,14 +78,14 @@ struct C_Ack : public Context {
off_t off;
C_Ack(off_t o) : off(o) {}
void finish(int r) {
- set_ack(off, g_clock.now());
+ set_ack(off, ceph_clock_now(&g_ceph_context));
}
};
struct C_Commit : public Context {
off_t off;
C_Commit(off_t o) : off(o) {}
void finish(int r) {
- set_commit(off, g_clock.now());
+ set_commit(off, ceph_clock_now(&g_ceph_context));
}
};
@@ -133,7 +133,7 @@ int main(int argc, const char **argv)
ft.create_collection(coll_t());
fs->apply_transaction(ft);
- utime_t now = g_clock.now();
+ utime_t now = ceph_clock_now(&g_ceph_context);
utime_t end = now;
end += seconds;
off_t pos = 0;
@@ -142,7 +142,7 @@ int main(int argc, const char **argv)
while (now < end) {
sobject_t poid(object_t("streamtest"), 0);
- set_start(pos, g_clock.now());
+ set_start(pos, ceph_clock_now(&g_ceph_context));
ObjectStore::Transaction *t = new ObjectStore::Transaction;
t->write(coll_t(), poid, pos, bytes, bl);
fs->queue_transaction(NULL, t, new C_Ack(pos), new C_Commit(pos));