| 36 | } |
| 37 | |
| 38 | void MessageQueue::storeGroupMessage(ReceivedGroupMessage const& message) { |
| 39 | QMutexLocker lock(&m_mutex); |
| 40 | if (m_storedGroupMessages.contains(message.messageHeader.getGroupId())) { |
| 41 | QVector<ReceivedGroupMessage>& queue = *m_storedGroupMessages.find(message.messageHeader.getGroupId()); |
| 42 | queue.append(message); |
| 43 | } else { |
| 44 | QVector<ReceivedGroupMessage> queue; |
| 45 | queue.append(message); |
| 46 | m_storedGroupMessages.insert(message.messageHeader.getGroupId(), queue); |
| 47 | } |
| 48 | } |
| 49 | |
| 50 | bool MessageQueue::hasMessageForGroup(openmittsu::protocol::GroupId const& group) const { |
| 51 | if (m_storedGroupMessages.contains(group)) { |
no test coverage detected