diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/PriorityQueue.cpp')
-rw-r--r-- | qpid/cpp/src/qpid/broker/PriorityQueue.cpp | 19 |
1 files changed, 0 insertions, 19 deletions
diff --git a/qpid/cpp/src/qpid/broker/PriorityQueue.cpp b/qpid/cpp/src/qpid/broker/PriorityQueue.cpp index 3305bb4f79..e07e73d323 100644 --- a/qpid/cpp/src/qpid/broker/PriorityQueue.cpp +++ b/qpid/cpp/src/qpid/broker/PriorityQueue.cpp @@ -88,25 +88,6 @@ bool PriorityQueue::find(const framing::SequenceNumber& position, QueuedMessage& return find(position, message, false); } -bool PriorityQueue::next(const QueuedMessage& message, QueuedMessage& next) -{ - uint p = getPriorityLevel(message); - QueuedMessage match; - match.position = message.position+1; - Deque::iterator m = lower_bound(messages[p].begin(), messages[p].end(), match); - if (m != messages[p].end()) { - next = *m; - return true; - } - while (p-- > 0) { - if (!messages[p].empty()) { - next = messages[p].front(); - return true; - } - } - return false; -} - bool PriorityQueue::next(const framing::SequenceNumber& position, QueuedMessage& message) { QueuedMessage match; |