NPLConnectionManager.h

#pragma once
#include "util/mutex.h"
#include <set>
#include <boost/noncopyable.hpp>
#include "NPLConnection.h"

namespace NPL
{
    class CNPLConnectionManager : private boost::noncopyable
    {
    public:
        CNPLConnectionManager();
        ~CNPLConnectionManager();
        
        void start(NPLConnection_ptr c);

        /* Add the specified connection to the manager without starting it.  
        * the connection might have been started already or it will is connecting and starting by itself. 
        */
        void add(NPLConnection_ptr c);

        void stop(NPLConnection_ptr c, int nReason = 0);
        
        void stop_all();

        int get_connection_count();

        struct NPLConnectionCallBack
        {
            virtual int DoCallBack(const NPLConnection_ptr& c) {return 0;};
        };

        int ForEachConnection(NPLConnectionCallBack* pCallback);

        int CheckIdleTimeout();
    private:
        typedef std::set<NPLConnection_ptr, NPLConnection_PtrOps> NPLConnectionPool_Type;
        
        NPLConnectionPool_Type m_connections;

        ParaEngine::mutex m_mutex;
    };
}