haraldwolff
/
aasdk
mirror of https://github.com/opencardev/aasdk
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Bug fixes

pull/14/head
Simon.Dean 2022-02-02 11:33:32 +00:00
parent db60c041b0
commit e744e6cf7e
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Messenger/MessageInStream.cpp
View File

@ -82,7 +82,7 @@ void MessageInStream::receiveFrameHeaderHandler(const common::DataConstBuffer& b
// If Frame Channel does not match Message Channel, store Existing Message in Buffer.
if(message_ != nullptr && message_->getChannelId() != frameHeader.getChannelId())
{
AASDK_LOG(debug) << "[MessageInStream] ChannelId mismatch -- Frame " << channelIdToString(frameHeader_.getChannelId()) << " -- Message -- " << channelIdToString(message_.getChannelId());
AASDK_LOG(debug) << "[MessageInStream] ChannelId mismatch -- Frame " << channelIdToString(frameHeader.getChannelId()) << " -- Message -- " << channelIdToString(message_->getChannelId());
isInterleaved_ = true;
messageBuffer_[message_->getChannelId()] = message_;
@ -186,11 +186,13 @@ void MessageInStream::receiveFramePayloadHandler(const common::DataConstBuffer&
{
// If this isn't an interleaved frame, then we can resolve the promise
if (!isInterleaved_) {
AASDK_LOG(debug) << "[MessageInStream] Resolving message.";
isResolved = true;
promise_->resolve(std::move(message_));
promise_.reset();
} else {
// Otherwise resolve through our random promise
AASDK_LOG(debug) << "[MessageInStream] Resolving interleaved frame";
interleavedPromise_->resolve(std::move(message_));
}
}