summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/linearstore/JournalImpl.h
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/src/qpid/linearstore/JournalImpl.h')
-rw-r--r--qpid/cpp/src/qpid/linearstore/JournalImpl.h10
1 files changed, 7 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/linearstore/JournalImpl.h b/qpid/cpp/src/qpid/linearstore/JournalImpl.h
index 4352eda074..fd2433803c 100644
--- a/qpid/cpp/src/qpid/linearstore/JournalImpl.h
+++ b/qpid/cpp/src/qpid/linearstore/JournalImpl.h
@@ -48,6 +48,7 @@ class EmptyFilePool;
namespace linearstore{
class JournalImpl;
+class JournalLogImpl;
class InactivityFireEvent : public qpid::sys::TimerTask
{
@@ -78,8 +79,9 @@ class JournalImpl : public qpid::broker::ExternalQueueStore, public qpid::qls_jr
public:
typedef boost::function<void (JournalImpl&)> DeleteCallback;
- private:
+ protected:
qpid::sys::Timer& timer;
+ JournalLogImpl& _journalLogRef;
bool getEventsTimerSetFlag;
boost::intrusive_ptr<qpid::sys::TimerTask> getEventsFireEventsPtr;
qpid::sys::Mutex _getf_lock;
@@ -98,6 +100,7 @@ class JournalImpl : public qpid::broker::ExternalQueueStore, public qpid::qls_jr
JournalImpl(qpid::sys::Timer& timer,
const std::string& journalId,
const std::string& journalDirectory,
+ JournalLogImpl& journalLogRef,
const qpid::sys::Duration getEventsTimeout,
const qpid::sys::Duration flushTimeout,
qpid::management::ManagementAgent* agent,
@@ -187,7 +190,7 @@ class JournalImpl : public qpid::broker::ExternalQueueStore, public qpid::qls_jr
void resetDeleteCallback() { deleteCallback = DeleteCallback(); }
- private:
+ protected:
// void free_read_buffers();
void createStore();
@@ -215,10 +218,11 @@ class TplJournalImpl : public JournalImpl
TplJournalImpl(qpid::sys::Timer& timer,
const std::string& journalId,
const std::string& journalDirectory,
+ JournalLogImpl& journalLogRef,
const qpid::sys::Duration getEventsTimeout,
const qpid::sys::Duration flushTimeout,
qpid::management::ManagementAgent* agent) :
- JournalImpl(timer, journalId, journalDirectory, getEventsTimeout, flushTimeout, agent)
+ JournalImpl(timer, journalId, journalDirectory, journalLogRef, getEventsTimeout, flushTimeout, agent)
{}
virtual ~TplJournalImpl() {}