summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/linearstore/JournalImpl.cpp
diff options
context:
space:
mode:
authorKim van der Riet <kpvdr@apache.org>2013-11-14 20:39:32 +0000
committerKim van der Riet <kpvdr@apache.org>2013-11-14 20:39:32 +0000
commit7b69da362fa2f2d53ec5378539195b8a4a7cfa41 (patch)
tree9acd64a5e5ac0062dd12dd425ae3b1aaa31f1f82 /cpp/src/qpid/linearstore/JournalImpl.cpp
parent7dd5803403d7e371a5dcadd05f6d0a97ce25d0c1 (diff)
downloadqpid-python-7b69da362fa2f2d53ec5378539195b8a4a7cfa41.tar.gz
QPID-4984: Fix for recovery ambiguity issue, other code tidy-ups
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1542066 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/linearstore/JournalImpl.cpp')
-rw-r--r--cpp/src/qpid/linearstore/JournalImpl.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/cpp/src/qpid/linearstore/JournalImpl.cpp b/cpp/src/qpid/linearstore/JournalImpl.cpp
index 4f904665ee..354fca4f7e 100644
--- a/cpp/src/qpid/linearstore/JournalImpl.cpp
+++ b/cpp/src/qpid/linearstore/JournalImpl.cpp
@@ -36,7 +36,7 @@
#include "qmf/org/apache/qpid/linearstore/EventFull.h"
#include "qmf/org/apache/qpid/linearstore/EventRecovered.h"
-using namespace qpid::qls_jrnl;
+using namespace qpid::linearstore::journal;
using namespace qpid::linearstore;
using qpid::management::ManagementAgent;
namespace _qmf = qmf::org::apache::qpid::linearstore;
@@ -128,10 +128,10 @@ JournalImpl::initManagement(qpid::management::ManagementAgent* a)
void
-JournalImpl::initialize(qpid::qls_jrnl::EmptyFilePool* efpp_,
+JournalImpl::initialize(qpid::linearstore::journal::EmptyFilePool* efpp_,
const uint16_t wcache_num_pages,
const uint32_t wcache_pgsize_sblks,
- qpid::qls_jrnl::aio_callback* const cbp)
+ qpid::linearstore::journal::aio_callback* const cbp)
{
// efpp->createJournal(_jdir);
// QLS_LOG2(notice, _jid, "Initialized");
@@ -167,10 +167,10 @@ JournalImpl::recover(/*const uint16_t num_jfiles,
const bool auto_expand,
const uint16_t ae_max_jfiles,
const uint32_t jfsize_sblks,*/
- boost::shared_ptr<qpid::qls_jrnl::EmptyFilePoolManager> efpm,
+ boost::shared_ptr<qpid::linearstore::journal::EmptyFilePoolManager> efpm,
const uint16_t wcache_num_pages,
const uint32_t wcache_pgsize_sblks,
- qpid::qls_jrnl::aio_callback* const cbp,
+ qpid::linearstore::journal::aio_callback* const cbp,
boost::ptr_list<PreparedTransaction>* prep_tx_list_ptr,
uint64_t& highest_rid,
uint64_t queue_id)
@@ -463,12 +463,12 @@ JournalImpl::handleIoResult(const iores r)
writeActivityFlag = true;
switch (r)
{
- case qpid::qls_jrnl::RHM_IORES_SUCCESS:
+ case qpid::linearstore::journal::RHM_IORES_SUCCESS:
return;
default:
{
std::ostringstream oss;
- oss << "Unexpected I/O response (" << qpid::qls_jrnl::iores_str(r) << ").";
+ oss << "Unexpected I/O response (" << qpid::linearstore::journal::iores_str(r) << ").";
QLS_LOG2(error, _jid, oss.str());
THROW_STORE_FULL_EXCEPTION(oss.str());
}