udpclient.h

/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at https://mozilla.org/MPL/2.0/. */
 
#pragma once
 
// External includes
#include <nap/device.h>
#include <queue>
#include <mutex>
 
// NAP includes
#include <utility/threading.h>
#include <concurrentqueue.h>
 
// Local includes
#include "udpadapter.h"
#include "udppacket.h"
 
namespace nap
{
    class NAPAPI UDPClient final : public UDPAdapter
    {
        RTTI_ENABLE(UDPAdapter)
    public:
        UDPClient();
 
        virtual ~UDPClient();
 
        void send(const UDPPacket& packet);
 
        void send(UDPPacket&& packet);
 
        int mPort                           = 13251;        
        std::string mEndpoint               = "10.8.0.3";   
        int  mMaxPacketQueueSize            = 1000;         
        bool mStopOnMaxQueueSizeExceeded    = true;         
        bool mBroadcast                     = false;        
 
    protected:
        bool onStart(utility::ErrorState& errorState) override final;
 
        void onStop() override final;
 
        void onProcess() override final;
    private:
        // Client specific ASIO implementation
        class Impl;
        std::unique_ptr<Impl> mImpl;
        std::vector<nap::uint8> mBuffer;
 
        // Threading
        moodycamel::ConcurrentQueue<UDPPacket>  mQueue;
    };
}