diff options
Diffstat (limited to 'src/test/journal/mock/MockJournaler.h')
-rw-r--r-- | src/test/journal/mock/MockJournaler.h | 22 |
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 { |