AsioDispatcher.h

Go to the documentation of this file.

/******************************************************************************
*
* Copyright Saab AB, 2008-2015 (http://safirsdkcore.com)
*
* Created by: Lars Hagström / lars.hagstrom@consoden.se
*
*******************************************************************************
*
* This file is part of Safir SDK Core.
*
* Safir SDK Core is free software: you can redistribute it and/or modify
* it under the terms of version 3 of the GNU General Public License as
* published by the Free Software Foundation.
*
* Safir SDK Core is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with Safir SDK Core.  If not, see <http://www.gnu.org/licenses/>.
*
******************************************************************************/
#pragma once
 
#include <memory>
#include <Safir/Dob/Connection.h>
 
#ifdef _MSC_VER
#pragma warning (push)
#pragma warning (disable: 4267)
#endif
 
#include <boost/asio.hpp>
 
#ifdef _MSC_VER
#pragma warning (pop)
#endif
 
namespace Safir
{
namespace Utilities
{
 
    class AsioDispatcher
        : public Safir::Dob::Dispatcher
    {
    public:
        AsioDispatcher(const Safir::Dob::Connection & connection,
                       boost::asio::io_context& ioContext)
            : m_connection(connection)
            , m_strand(new boost::asio::io_context::strand(ioContext))
            , m_isNotified()
        {
 
        }
 
        AsioDispatcher(const Safir::Dob::Connection & connection,
                       boost::asio::io_context::strand& strand)
            : m_connection(connection)
            , m_strand(&strand,null_deleter())
            , m_isNotified()
        {
 
        }
 
        AsioDispatcher(const AsioDispatcher&) = delete;
        AsioDispatcher& operator=(const AsioDispatcher&) = delete;
 
        boost::asio::io_context::strand& Strand() {return *m_strand;}
 
    private:
        struct null_deleter
        {
            void operator()(void const *) const
            {
            }
        };
 
        void CallDobDispatch()
        {
            m_isNotified.clear();
            m_connection.Dispatch();
        }
 
        void OnDoDispatch() override
        {
            if (!m_isNotified.test_and_set())
            {
                boost::asio::dispatch(*m_strand, [this]{CallDobDispatch();});
            }
        }
 
        const Safir::Dob::Connection&                      m_connection;
        std::shared_ptr<boost::asio::io_context::strand>   m_strand;
        std::atomic_flag                                   m_isNotified;
    };
 
 
}
}