| 913 | } |
| 914 | |
| 915 | void ProtocolClient::enqeueWaitForAcknowledgment(openmittsu::protocol::ContactId const& sender, openmittsu::protocol::MessageId const& messageId, std::shared_ptr<openmittsu::acknowledgments::AcknowledgmentProcessor> const& acknowledgmentProcessor) { |
| 916 | QMutexLocker lock(&acknowledgmentWaitingMutex); |
| 917 | |
| 918 | acknowledgmentProcessor->addMessage(messageId); |
| 919 | acknowledgmentWaitingMessages.insert(messageId, acknowledgmentProcessor); |
| 920 | } |
| 921 | |
| 922 | void ProtocolClient::socketOnError(QAbstractSocket::SocketError socketError) { |
| 923 | switch (socketError) { |
nothing calls this directly
no test coverage detected