]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
journal: migrate atomic_t to <atomic>
authorJesse Williamson <jwilliamson@suse.de>
Tue, 23 May 2017 12:49:28 +0000 (05:49 -0700)
committerJesse Williamson <jwilliamson@suse.de>
Sun, 28 May 2017 15:47:40 +0000 (08:47 -0700)
Signed-off-by: Jesse Williamson <jwilliamson@suse.de>
src/journal/JournalRecorder.cc
src/test/journal/test_Journaler.cc

index d0c6406a3ac4386b0581968f47f50cdd7b2bd124..9c38758fccaa787e3cc132a8d31a5448e5f5297f 100644 (file)
@@ -6,6 +6,8 @@
 #include "journal/Entry.h"
 #include "journal/Utils.h"
 
+#include <atomic>
+
 #define dout_subsys ceph_subsys_journaler
 #undef dout_prefix
 #define dout_prefix *_dout << "JournalRecorder: " << this << " "
@@ -19,7 +21,7 @@ namespace {
 struct C_Flush : public Context {
   JournalMetadataPtr journal_metadata;
   Context *on_finish;
-  atomic_t pending_flushes;
+  std::atomic<int64_t> pending_flushes = { 0 };
   int ret_val;
 
   C_Flush(JournalMetadataPtr _journal_metadata, Context *_on_finish,
@@ -32,7 +34,7 @@ struct C_Flush : public Context {
     if (r < 0 && ret_val == 0) {
       ret_val = r;
     }
-    if (pending_flushes.dec() == 0) {
+    if (--pending_flushes == 0) {
       // ensure all prior callback have been flushed as well
       journal_metadata->queue(on_finish, ret_val);
       delete this;
index 4fd06ad6535f52674f686a812dc9081e5c3c8b5e..529141de9a3078b237a53d6c51a3ec15f332c471 100644 (file)
@@ -1,13 +1,18 @@
 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
 // vim: ts=8 sw=2 smarttab
 
+#include "include/stringify.h"
+
 #include "journal/Journaler.h"
 #include "journal/Settings.h"
-#include "include/stringify.h"
-#include "gtest/gtest.h"
+
 #include "test/librados/test.h"
 #include "test/journal/RadosTestFixture.h"
-#include "include/stringify.h"
+
+#include "gtest/gtest.h"
+
+// reinclude our assert to clobber the system one
+#include "include/assert.h"
 
 class TestJournaler : public RadosTestFixture {
 public: