summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--qpid/cpp/src/qpid/ha/Primary.cpp4
-rw-r--r--qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp1
-rw-r--r--qpid/cpp/src/qpid/ha/RemoteBackup.cpp4
-rw-r--r--qpid/cpp/src/qpid/ha/types.cpp3
4 files changed, 6 insertions, 6 deletions
diff --git a/qpid/cpp/src/qpid/ha/Primary.cpp b/qpid/cpp/src/qpid/ha/Primary.cpp
index 3790d14626..0e87346ac1 100644
--- a/qpid/cpp/src/qpid/ha/Primary.cpp
+++ b/qpid/cpp/src/qpid/ha/Primary.cpp
@@ -158,7 +158,7 @@ Primary::Primary(HaBroker& hb, const BrokerInfo::Set& expect) :
// the QueueGuards are created.
QPID_LOG(notice, logPrefix << "Recovering backups: " << expect);
for (BrokerInfo::Set::const_iterator i = expect.begin(); i != expect.end(); ++i) {
- boost::shared_ptr<RemoteBackup> backup(new RemoteBackup(*i, 0, logPrefix));
+ boost::shared_ptr<RemoteBackup> backup(new RemoteBackup(*i, 0, haBroker.logPrefix));
backups[i->getSystemId()] = backup;
if (!backup->isReady()) expectedBackups.insert(backup);
setCatchupQueues(backup, true); // Create guards
@@ -361,7 +361,7 @@ void Primary::exchangeDestroy(const ExchangePtr& ex) {
shared_ptr<RemoteBackup> Primary::backupConnect(
const BrokerInfo& info, broker::Connection& connection, Mutex::ScopedLock&)
{
- shared_ptr<RemoteBackup> backup(new RemoteBackup(info, &connection, logPrefix));
+ shared_ptr<RemoteBackup> backup(new RemoteBackup(info, &connection, haBroker.logPrefix));
queueLimits.addBackup(backup);
backups[info.getSystemId()] = backup;
return backup;
diff --git a/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp b/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp
index bbfcbba3a3..3c6318fbfe 100644
--- a/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp
+++ b/qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp
@@ -136,7 +136,6 @@ void PrimaryTxObserver::initialize() {
txQueue = result.first;
txQueue->markInUse(); // Prevent auto-delete till we are done.
txQueue->deliver(TxBackupsEvent(backups).message());
-
}
diff --git a/qpid/cpp/src/qpid/ha/RemoteBackup.cpp b/qpid/cpp/src/qpid/ha/RemoteBackup.cpp
index c263d37e43..d511b5bd0e 100644
--- a/qpid/cpp/src/qpid/ha/RemoteBackup.cpp
+++ b/qpid/cpp/src/qpid/ha/RemoteBackup.cpp
@@ -70,7 +70,7 @@ void RemoteBackup::catchupQueue(const QueuePtr& q, bool createGuard) {
QPID_LOG(debug, logPrefix << "Catch-up queue"
<< (createGuard ? " and guard" : "") << ": " << q->getName());
catchupQueues.insert(q);
- if (createGuard) guards[q].reset(new QueueGuard(*q, brokerInfo, logPrefix));
+ if (createGuard) guards[q].reset(new QueueGuard(*q, brokerInfo, logPrefix.prePrefix));
}
}
@@ -91,7 +91,7 @@ void RemoteBackup::ready(const QueuePtr& q) {
// Called via BrokerObserver::queueCreate and from catchupQueue
void RemoteBackup::queueCreate(const QueuePtr& q) {
if (replicationTest.getLevel(*q) == ALL)
- guards[q].reset(new QueueGuard(*q, brokerInfo, logPrefix));
+ guards[q].reset(new QueueGuard(*q, brokerInfo, logPrefix.prePrefix));
}
// Called via BrokerObserver
diff --git a/qpid/cpp/src/qpid/ha/types.cpp b/qpid/cpp/src/qpid/ha/types.cpp
index 00058a8a32..60cc0f27ce 100644
--- a/qpid/cpp/src/qpid/ha/types.cpp
+++ b/qpid/cpp/src/qpid/ha/types.cpp
@@ -90,7 +90,8 @@ istream& operator>>(istream& i, EnumBase& e) {
ostream& operator<<(ostream& o, const UuidSet& ids) {
ostream_iterator<qpid::types::Uuid> out(o, " ");
o << "{ ";
- copy(ids.begin(), ids.end(), out);
+ for (UuidSet::const_iterator i = ids.begin(); i != ids.end(); ++i)
+ o << shortStr(*i) << " ";
o << "}";
return o;
}