InterprocessAppClient.h

#pragma once
#include <boost/thread.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/asio.hpp>
#include "util/Mutex.hpp"
#include "ipc_message_queue.hpp"
#include "InterprocessQueue.hpp"
#include "IParaEngineApp.h"
#include "InterprocessMsg.h"
#include "AutoUpdaterApp.h"
#include <boost/asio/steady_timer.hpp>

namespace ParaEngine
{
    class CMyProcessAppThread;
    class CCommandLineParser;

    class CInterprocessAppClient: public ParaEngine::CAutoUpdaterApp
    {
    public:
        typedef boost::shared_ptr<boost::thread> Boost_Thread_ptr_type;
        
        CInterprocessAppClient(const char* appName = NULL);
        ~CInterprocessAppClient();

    public:
        void SetAppName(const char* appName);

        virtual int SetCommandLine(const char* sCmdLine);

        int Run(HINSTANCE hInst, const char* sCmdLine);
    public:
        void SetParentWindow(HWND hWndParent);

        int Start(int nMinResolutionWidth = 0, int nMinResolutionHeight = 0);

        int Stop();

        HWND GetMainHWnd(){return m_hWnd;}

        virtual bool SendHostMsg(int nMsg, DWORD param1 = 0, DWORD param2 = 0, const char* filename = NULL, const char* sCode = NULL, int nPriority = 0);

    protected:
        static LRESULT CALLBACK DefaultWinThreadWndProc( HWND hWnd, UINT uMsg, WPARAM wParam, LPARAM lParam );

        int HandleAppMsg(InterProcessMessage& msg);

        bool CheckLoad();

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

        double GetElapsedAppTime();

        HRESULT StartWindowThread();
        void DefaultWinThreadProc();

        void PrintGetLastError();

        void EnableAutoUpdateWhenComplete(bool bEnable);

    protected:
        std::string m_app_name;
        std::string m_app_host;
        std::string m_sUsage;
        bool m_bAutoUpdateWhenStart;
        int m_nMinWidth;
        int m_nMinHeight;

        HWND m_hWndParent;
        bool m_bStarted;
        ParaEngine::CPluginLoader m_ParaEngine_plugin;
        ParaEngine::IParaEngineCore* m_pParaEngine;
        ParaEngine::IParaEngineApp * m_pParaEngineApp;
        

        CInterprocessQueue* m_ipAppQueueIn;
        CInterprocessQueue* m_ipHostQueueOut;

        bool m_bQuit;
        bool m_bMainLoopExited;

        ParaEngine::Mutex     m_mutex;

        boost::asio::io_service m_main_io_service;
        boost::asio::steady_timer m_main_timer;
        // main render window hWnd. 
        HWND m_hWnd;
        
        std::string m_sRedistDir;

        Domain_Map_t m_trusted_domains;

        //  the default window thread ptr. 
        Boost_Thread_ptr_type m_win_thread;
        ParaEngine::Mutex     m_win_thread_mutex;
        DWORD m_dwWinThreadID;

        HINSTANCE m_hInst;
        friend class CMyProcessAppThread;
    };

}