NPLNetServer.h

#pragma once
#include <boost/thread.hpp>
#include <boost/asio.hpp>
#include <boost/noncopyable.hpp>
#include <boost/scoped_ptr.hpp>
#include <boost/asio/steady_timer.hpp>
#include "NPLConnectionManager.h"
#include "NPLDispatcher.h"

namespace NPL
{
    class CNPLNetServer : private boost::noncopyable
    {
    public:
        CNPLNetServer();
        ~CNPLNetServer();

        void start(const char* server=NULL, const char* port=NULL);

        void stop();

        void Cleanup();

        CNPLDispatcher& GetDispatcher(){return m_msg_dispatcher;};

        CNPLConnectionManager& GetConnectionManager(){return m_connection_manager;};

        NPLConnection_ptr CreateConnection(NPLRuntimeAddress_ptr pAddress);

        void SetTCPKeepAlive(bool bEnable);

        bool IsTCPKeepAliveEnabled();

        void SetKeepAlive(bool bEnable);
        bool IsKeepAliveEnabled();

        void EnableIdleTimeout(bool bEnable);
        bool IsIdleTimeoutEnabled();

        void SetIdleTimeoutPeriod(int nMilliseconds);
        int GetIdleTimeoutPeriod();

        void EnableAnsiMode(bool bEnable);
        bool IsAnsiMode();

        int GetMaxPendingConnections() const;
        void SetMaxPendingConnections(int val);
    public:
        std::string GetExternalIP();

        virtual const std::string& GetHostPort();
        virtual const std::string& GetHostIP();
        virtual bool IsServerStarted();
    private:
        void handle_resolve_local(const boost::system::error_code& err, boost::asio::ip::tcp::resolver::iterator endpoint_iterator);

        void handle_accept(const boost::system::error_code& e);

        void handle_stop();

        void handle_idle_timeout(const boost::system::error_code& err);

        boost::asio::io_service m_io_service_dispatcher;

        boost::scoped_ptr<boost::thread> m_dispatcherThread;

        boost::asio::ip::tcp::resolver m_resolver;

        boost::asio::ip::tcp::acceptor m_acceptor;

        CNPLConnectionManager m_connection_manager;

        NPLConnection_ptr m_new_connection;

        string m_strServer;
        string m_strPort;

        bool m_bTCPKeepAlive;

        bool m_bKeepAlive;

        bool m_bEnableIdleTimeout;

        bool m_bIsServerStarted;

        int m_nIdleTimeoutMS;

        int m_nMaxPendingConnections;

        typedef boost::asio::basic_waitable_timer<boost::chrono::steady_clock> timer_type;
        timer_type m_idle_timer;


        boost::scoped_ptr<boost::asio::io_service::work> m_work_lifetime;

        CNPLDispatcher m_msg_dispatcher;
    };
}