udpserver.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 <thread>
#include <mutex>
 
// NAP includes
#include <nap/numeric.h>
#include <concurrentqueue.h>
#include <nap/signalslot.h>
 
// Local includes
#include "udpadapter.h"
#include "udppacket.h"
 
namespace nap
{
    class NAPAPI UDPServer final : public UDPAdapter
    {
        RTTI_ENABLE(UDPAdapter)
    public:
        UDPServer();
 
        virtual ~UDPServer();
 
        void registerListenerSlot(Slot<const UDPPacket&>& slot);
 
        void removeListenerSlot(Slot<const UDPPacket&>& slot);
 
        int mPort                       = 13251;        
        std::string mIPAddress          = "";           
        std::vector<std::string> mMulticastGroups;      
    protected:
        Signal<const UDPPacket&> packetReceived;
 
        virtual bool onStart(utility::ErrorState& errorState) override final;
 
        virtual void onStop() override final;
 
        void onProcess() override final;
    private:
        // Server specific ASIO implementation
        class Impl;
        std::unique_ptr<Impl> mImpl;
 
        // mutex
        std::mutex mMutex;
    };
}