diff options
| -rw-r--r-- | qpid/cpp/src/qpid/ha/Primary.cpp | 4 | ||||
| -rw-r--r-- | qpid/cpp/src/qpid/ha/PrimaryTxObserver.cpp | 1 | ||||
| -rw-r--r-- | qpid/cpp/src/qpid/ha/RemoteBackup.cpp | 4 | ||||
| -rw-r--r-- | qpid/cpp/src/qpid/ha/types.cpp | 3 |
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; } |
