72 lines
1.5 KiB
C++
72 lines
1.5 KiB
C++
|
#include "drape_frontend/message_acceptor.hpp"
|
||
|
|
|
||
|
|
#include "drape_frontend/message.hpp"
|
||
|
|
|
||
|
|
namespace df
|
||
|
|
{
|
||
|
|
MessageAcceptor::MessageAcceptor() : m_infinityWaiting(false) {}
|
||
|
|
|
||
|
|
bool MessageAcceptor::ProcessSingleMessage(bool waitForMessage)
|
||
|
|
{
|
||
|
|
m_infinityWaiting = waitForMessage;
|
||
|
|
drape_ptr<Message> message = m_messageQueue.PopMessage(waitForMessage);
|
||
|
|
m_infinityWaiting = false;
|
||
|
|
|
||
|
|
if (message == nullptr)
|
||
|
|
return false;
|
||
|
|
|
||
|
|
AcceptMessage(make_ref(message));
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
|
||
|
|
void MessageAcceptor::EnableMessageFiltering(MessageQueue::FilterMessageFn && filter)
|
||
|
|
{
|
||
|
|
m_messageQueue.EnableMessageFiltering(std::move(filter));
|
||
|
|
}
|
||
|
|
|
||
|
|
void MessageAcceptor::DisableMessageFiltering()
|
||
|
|
{
|
||
|
|
m_messageQueue.DisableMessageFiltering();
|
||
|
|
}
|
||
|
|
|
||
|
|
void MessageAcceptor::InstantMessageFilter(MessageQueue::FilterMessageFn && filter)
|
||
|
|
{
|
||
|
|
m_messageQueue.InstantFilter(std::move(filter));
|
||
|
|
}
|
||
|
|
|
||
|
|
void MessageAcceptor::PostMessage(drape_ptr<Message> && message, MessagePriority priority)
|
||
|
|
{
|
||
|
|
m_messageQueue.PushMessage(std::move(message), priority);
|
||
|
|
}
|
||
|
|
|
||
|
|
void MessageAcceptor::CloseQueue()
|
||
|
|
{
|
||
|
|
m_messageQueue.CancelWait();
|
||
|
|
m_messageQueue.ClearQuery();
|
||
|
|
}
|
||
|
|
|
||
|
|
void MessageAcceptor::CancelMessageWaiting()
|
||
|
|
{
|
||
|
|
m_messageQueue.CancelWait();
|
||
|
|
}
|
||
|
|
|
||
|
|
bool MessageAcceptor::IsInInfinityWaiting() const
|
||
|
|
{
|
||
|
|
return m_infinityWaiting;
|
||
|
|
}
|
||
|
|
|
||
|
|
#ifdef DEBUG_MESSAGE_QUEUE
|
||
|
|
|
||
|
|
bool MessageAcceptor::IsQueueEmpty() const
|
||
|
|
{
|
||
|
|
return m_messageQueue.IsEmpty();
|
||
|
|
}
|
||
|
|
|
||
|
|
size_t MessageAcceptor::GetQueueSize() const
|
||
|
|
{
|
||
|
|
return m_messageQueue.GetSize();
|
||
|
|
}
|
||
|
|
|
||
|
|
#endif
|
||
|
|
} // namespace df
|