summaryrefslogtreecommitdiffstats
path: root/src/test/journal/mock/MockJournaler.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/test/journal/mock/MockJournaler.h')
-rw-r--r--src/test/journal/mock/MockJournaler.h22
1 files changed, 14 insertions, 8 deletions
diff --git a/src/test/journal/mock/MockJournaler.h b/src/test/journal/mock/MockJournaler.h
index b925ddfebe9..ab424cd6b09 100644
--- a/src/test/journal/mock/MockJournaler.h
+++ b/src/test/journal/mock/MockJournaler.h
@@ -120,7 +120,8 @@ struct MockJournaler {
MOCK_METHOD0(stop_replay, void());
MOCK_METHOD1(stop_replay, void(Context *on_finish));
- MOCK_METHOD4(start_append, void(int, uint64_t, double, uint64_t));
+ MOCK_METHOD1(start_append, void(uint64_t));
+ MOCK_METHOD3(set_append_batch_options, void(int, uint64_t, double));
MOCK_CONST_METHOD0(get_max_append_size, uint64_t());
MOCK_METHOD2(append, MockFutureProxy(uint64_t tag_id,
const bufferlist &bl));
@@ -143,7 +144,8 @@ struct MockJournalerProxy {
template <typename IoCtxT>
MockJournalerProxy(IoCtxT &header_ioctx, const std::string &,
- const std::string &, const Settings&) {
+ const std::string &, const Settings&,
+ journal::CacheManagerHandler *) {
MockJournaler::get_instance().construct();
}
@@ -151,7 +153,8 @@ struct MockJournalerProxy {
MockJournalerProxy(WorkQueue *work_queue, Timer *timer, Mutex *timer_lock,
librados::IoCtx &header_ioctx,
const std::string &journal_id,
- const std::string &client_id, const Settings&) {
+ const std::string &client_id, const Settings&,
+ journal::CacheManagerHandler *) {
MockJournaler::get_instance().construct();
}
@@ -257,11 +260,14 @@ struct MockJournalerProxy {
MockJournaler::get_instance().stop_replay(on_finish);
}
- void start_append(int flush_interval, uint64_t flush_bytes, double flush_age,
- uint64_t max_in_flight_appends) {
- MockJournaler::get_instance().start_append(flush_interval, flush_bytes,
- flush_age,
- max_in_flight_appends);
+ void start_append(uint64_t max_in_flight_appends) {
+ MockJournaler::get_instance().start_append(max_in_flight_appends);
+ }
+
+ void set_append_batch_options(int flush_interval, uint64_t flush_bytes,
+ double flush_age) {
+ MockJournaler::get_instance().set_append_batch_options(
+ flush_interval, flush_bytes, flush_age);
}
uint64_t get_max_append_size() const {