oscbridge2/oscpacketdecoder.cpp at master · ragnarula/oscbridge2 · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
#include "oscpacketdecoder.h"
#include "messagehandler.h"
#include "oscpkt.hh"
#include <boost/bind.hpp>


OSCPacketDecoder::OSCPacketDecoder(const std::string& Message,
                                   boost::asio::io_service& IOService,
                                   MessageHandler& MessageHandler) :
    m_Message(Message),
    m_IOService(IOService),
    m_MessageHandler(MessageHandler),
    m_MessageHandlerSharedLock(m_MessageHandler.GetMutex())
{

}

void OSCPacketDecoder::AsyncDecode(const std::string &Message,
                                   boost::asio::io_service &IOService,
                                   MessageHandler &MessageHandler)
{
    auto Decoder = std::make_shared<OSCPacketDecoder>(Message,
                                                      IOService,
                                                      MessageHandler);
    Decoder->BeginDecode();
}

void OSCPacketDecoder::BeginDecode()
{
    m_IOService.post(boost::bind(&OSCPacketDecoder::DoDecode, shared_from_this()));
}


void OSCPacketDecoder::DoDecode()
{
    oscpkt::PacketReader OSCPacketReader;
    OSCPacketReader.init(m_Message.c_str(), m_Message.size());
    oscpkt::Message* OSCMessage;

    if(!OSCPacketReader.isOk())
    {
        m_MessageHandler.OnOSCMessageParseError(OSCPacketReader.getErr());
    }

    while(OSCPacketReader.isOk() && (OSCMessage = OSCPacketReader.popMessage()) != 0)
    {
        m_MessageHandler.OnOSCMessageParseSuccess(*OSCMessage);
    }
}