summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/SemanticState.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2009-05-04 16:37:21 +0000
committerAlan Conway <aconway@apache.org>2009-05-04 16:37:21 +0000
commit2407f9f523b0eeeb8988e30c797fdb46039fc3d3 (patch)
tree210c28cd631446b599a8224b0a2138a2dd90a132 /cpp/src/qpid/broker/SemanticState.cpp
parent564d179640cf49feeb8ff84133f892499afb0e65 (diff)
downloadqpid-python-2407f9f523b0eeeb8988e30c797fdb46039fc3d3.tar.gz
Undo buggy commit 770802.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@771354 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/SemanticState.cpp')
-rw-r--r--cpp/src/qpid/broker/SemanticState.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/src/qpid/broker/SemanticState.cpp b/cpp/src/qpid/broker/SemanticState.cpp
index b2df5e36a3..3c7c6d9afa 100644
--- a/cpp/src/qpid/broker/SemanticState.cpp
+++ b/cpp/src/qpid/broker/SemanticState.cpp
@@ -440,7 +440,7 @@ void SemanticState::recover(bool requeue)
//unconfirmed messages re redelivered and therefore have their
//id adjusted, confirmed messages are not and so the ordering
//w.r.t id is lost
- std::sort(unacked.begin(), unacked.end());
+ unacked.sort();
}
}
@@ -642,12 +642,12 @@ void SemanticState::accepted(DeliveryId first, DeliveryId last)
//if the messages are already completed, they can be
//removed from the record
- unacked.erase(std::remove_if(unacked.begin(), unacked.end(), mem_fun_ref(&DeliveryRecord::isRedundant)), unacked.end());
+ unacked.remove_if(mem_fun_ref(&DeliveryRecord::isRedundant));
}
} else {
for_each(range.start, range.end, boost::bind(&DeliveryRecord::accept, _1, (TransactionContext*) 0));
- unacked.erase(std::remove_if(unacked.begin(), unacked.end(), mem_fun_ref(&DeliveryRecord::isRedundant)), unacked.end());
+ unacked.remove_if(mem_fun_ref(&DeliveryRecord::isRedundant));
}
}
@@ -655,7 +655,7 @@ void SemanticState::completed(DeliveryId first, DeliveryId last)
{
AckRange range = findRange(first, last);
for_each(range.start, range.end, boost::bind(&SemanticState::complete, this, _1));
- unacked.erase(std::remove_if(unacked.begin(), unacked.end(), mem_fun_ref(&DeliveryRecord::isRedundant)), unacked.end());
+ unacked.remove_if(mem_fun_ref(&DeliveryRecord::isRedundant));
requestDispatch();
}