service.h

/* $Id: service.h 2926 2013-02-05 19:07:32Z roma $ */
#ifndef _FFL_CSSC_MULTITHREADED_SERVICE_H_
#define _FFL_CSSC_MULTITHREADED_SERVICE_H_

#include "../service.h"
#include "server.h"

namespace ffl
{

        namespace cssc
        {

                namespace multithreaded
                {

                        class service:public cssc::service
                        {
                        public:

                                class server:public multithreaded::server
                                {
                                public:

                                        server(service& _service, int _max_users, int _max_processors, const char* _log_path, long _idle_timeout) throw():
                                        Service(_service),
                                        LogPath(_log_path),
                                        multithreaded::server(_max_users, _max_processors, (std::string(_log_path) + "/server.Log").c_str(), _idle_timeout)
                                        {}

                                private:

                                        service& Service;

                                        void just_started() throw(){Service.Context.checkpoint();}

                                        void just_ready() throw(){Service.Context.state(RUNNING, service::STOP);}
                                        
                                        void just_canceled() throw(){Service.Context.pending(STOP_PENDING, 5000);}
                                
                                protected:

                                        std::string LogPath;    
        
                        };

                                service(cssc::service::context& _c) throw():cssc::service(_c){}

                                void run(int _argc, const char* _argv[]) throw();

                        protected:

                                virtual server* create(int _max_users, int _max_processors, const char* _path, long _idle_timeout) throw(...) = 0;

                                virtual void adjust(int &_max_users, int &_max_processors, std::string &_path, long &_idle_timeout) throw(...){}

                        private:

                                std::auto_ptr<server> Server;   

                                server* initialize(int _argc, const char* _argv[]) throw(...);

                                void stop() throw(){Server->cancel();}

                        };

                }

        }

}

#endif