Skip to content

Commit

Permalink
journal/JournalTrimmer: move C_RemoveSet struct
Browse files Browse the repository at this point in the history
Signed-off-by: Michal Jarzabek <stiopa@gmail.com>
  • Loading branch information
stiopaa1 committed Aug 29, 2016
1 parent 537cbb3 commit 35a3f69
Show file tree
Hide file tree
Showing 2 changed files with 18 additions and 15 deletions.
16 changes: 16 additions & 0 deletions src/journal/JournalTrimmer.cc
Expand Up @@ -13,6 +13,22 @@

namespace journal {

struct JournalTrimmer::C_RemoveSet : public Context {
JournalTrimmer *journal_trimmer;
uint64_t object_set;
Mutex lock;
uint32_t refs;
int return_value;

C_RemoveSet(JournalTrimmer *_journal_trimmer, uint64_t _object_set,
uint8_t _splay_width);
virtual void complete(int r);
virtual void finish(int r) {
journal_trimmer->handle_set_removed(r, object_set);
journal_trimmer->m_async_op_tracker.finish_op();
}
};

JournalTrimmer::JournalTrimmer(librados::IoCtx &ioctx,
const std::string &object_oid_prefix,
const JournalMetadataPtr &journal_metadata)
Expand Down
17 changes: 2 additions & 15 deletions src/journal/JournalTrimmer.h
Expand Up @@ -58,21 +58,8 @@ class JournalTrimmer {
virtual void finish(int r) {
}
};
struct C_RemoveSet : public Context {
JournalTrimmer *journal_trimmer;
uint64_t object_set;
Mutex lock;
uint32_t refs;
int return_value;

C_RemoveSet(JournalTrimmer *_journal_trimmer, uint64_t _object_set,
uint8_t _splay_width);
virtual void complete(int r);
virtual void finish(int r) {
journal_trimmer->handle_set_removed(r, object_set);
journal_trimmer->m_async_op_tracker.finish_op();
}
};

struct C_RemoveSet;

librados::IoCtx m_ioctx;
CephContext *m_cct;
Expand Down

0 comments on commit 35a3f69

Please sign in to comment.