| 904 | } |
| 905 | |
| 906 | void ProtocolClient::encryptAndSendDataPacketToServer(QByteArray const& dataPacket) { |
| 907 | QByteArray const encryptedDataPacket = m_cryptoBox->encryptForServer(dataPacket); |
| 908 | LOGGER_DEBUG("Writing Message with {} Bytes to outbound queue.", encryptedDataPacket.size()); |
| 909 | |
| 910 | QMutexLocker lock(&outgoingMessagesMutex); |
| 911 | outgoingMessages.append(encryptedDataPacket); |
| 912 | outgoingMessagesTimer->start(0); |
| 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); |
nothing calls this directly
no test coverage detected