summaryrefslogtreecommitdiffstats
path: root/src/test/journal
diff options
context:
space:
mode:
authorAdam C. Emerson <aemerson@redhat.com>2016-11-15 01:33:56 +0100
committerAdam C. Emerson <aemerson@redhat.com>2016-12-22 19:55:37 +0100
commit750ad8340c827d2f8896e1251e45f921dddb9f30 (patch)
tree436f838c7eb7e3a6109a90202162e23540248af5 /src/test/journal
parentMerge pull request #12616 from atheism/rgw-ldap-fix-simple-bind (diff)
downloadceph-750ad8340c827d2f8896e1251e45f921dddb9f30.tar.xz
ceph-750ad8340c827d2f8896e1251e45f921dddb9f30.zip
common: Unskew clock
In preparation to deglobalizing CephContext, remove the CephContext* parameter to ceph_clock_now() and ceph::real_clock::now() that carries a configurable offset. Signed-off-by: Adam C. Emerson <aemerson@redhat.com>
Diffstat (limited to 'src/test/journal')
-rw-r--r--src/test/journal/RadosTestFixture.cc3
-rw-r--r--src/test/journal/test_JournalPlayer.cc2
-rw-r--r--src/test/journal/test_ObjectRecorder.cc2
3 files changed, 1 insertions, 6 deletions
diff --git a/src/test/journal/RadosTestFixture.cc b/src/test/journal/RadosTestFixture.cc
index a066559c923..0a71a859043 100644
--- a/src/test/journal/RadosTestFixture.cc
+++ b/src/test/journal/RadosTestFixture.cc
@@ -119,8 +119,7 @@ bool RadosTestFixture::wait_for_update(journal::JournalMetadataPtr metadata) {
Mutex::Locker locker(m_listener.mutex);
while (m_listener.updates[metadata.get()] == 0) {
if (m_listener.cond.WaitInterval(
- reinterpret_cast<CephContext*>(m_ioctx.cct()),
- m_listener.mutex, utime_t(10, 0)) != 0) {
+ m_listener.mutex, utime_t(10, 0)) != 0) {
return false;
}
}
diff --git a/src/test/journal/test_JournalPlayer.cc b/src/test/journal/test_JournalPlayer.cc
index 03255d06b76..6888ee06bb5 100644
--- a/src/test/journal/test_JournalPlayer.cc
+++ b/src/test/journal/test_JournalPlayer.cc
@@ -101,7 +101,6 @@ public:
if (m_replay_hander.entries_available) {
m_replay_hander.entries_available = false;
} else if (m_replay_hander.cond.WaitInterval(
- reinterpret_cast<CephContext*>(m_ioctx.cct()),
m_replay_hander.lock, utime_t(10, 0)) != 0) {
break;
}
@@ -117,7 +116,6 @@ public:
player->try_pop_front(&entry, &commit_tid);
if (m_replay_hander.cond.WaitInterval(
- reinterpret_cast<CephContext*>(m_ioctx.cct()),
m_replay_hander.lock, utime_t(10, 0)) != 0) {
return false;
}
diff --git a/src/test/journal/test_ObjectRecorder.cc b/src/test/journal/test_ObjectRecorder.cc
index e2113365af9..1e0a366d7b4 100644
--- a/src/test/journal/test_ObjectRecorder.cc
+++ b/src/test/journal/test_ObjectRecorder.cc
@@ -372,7 +372,6 @@ TEST_F(TestObjectRecorder, Close) {
Mutex::Locker locker(m_handler.lock);
while (!m_handler.is_closed) {
if (m_handler.cond.WaitInterval(
- reinterpret_cast<CephContext*>(m_ioctx.cct()),
m_handler.lock, utime_t(10, 0)) != 0) {
break;
}
@@ -423,7 +422,6 @@ TEST_F(TestObjectRecorder, Overflow) {
Mutex::Locker locker(m_handler.lock);
while (m_handler.overflows == 0) {
if (m_handler.cond.WaitInterval(
- reinterpret_cast<CephContext*>(m_ioctx.cct()),
m_handler.lock, utime_t(10, 0)) != 0) {
break;
}