diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/MessageGroupManager.cpp')
-rw-r--r-- | qpid/cpp/src/qpid/broker/MessageGroupManager.cpp | 8 |
1 files changed, 1 insertions, 7 deletions
diff --git a/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp b/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp index 5c86a918ba..98313e74ad 100644 --- a/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp +++ b/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp @@ -43,19 +43,13 @@ const std::string MessageGroupManager::qpidSharedGroup("qpid.shared_msg_group"); const std::string MessageGroupManager::qpidMessageGroupTimestamp("qpid.group_timestamp"); +/** return an iterator to the message at position, or members.end() if not found */ MessageGroupManager::GroupState::MessageFifo::iterator MessageGroupManager::GroupState::findMsg(const framing::SequenceNumber &position) { MessageState mState(position); MessageFifo::iterator found = std::lower_bound(members.begin(), members.end(), mState); return (found->position == position) ? found : members.end(); -#if 0 - MessageFifo::iterator msg = members.begin(); - const MessageFifo::iterator end = members.end(); - while (msg != end && msg->position != position) - ++msg; - return msg; -#endif } void MessageGroupManager::unFree( const GroupState& state ) |