MTSocketDaemon.h

// $Id: MTSocketDaemon.h 21 2010-09-05 04:18:17Z cschwarz1 $

#ifndef BASE_MTSOCKETDAEMON_H
#define BASE_MTSOCKETDAEMON_H

#ifndef _WIN32
    #include <sys/poll.h>
#endif
#include "Daemon.h"
#include "Socket.h"
#include "ThreadList.h"
#include "WorkPile.h"

namespace base {
    class WorkerThread;


    class PPBASE_EXPORT MTSocketDaemon: public Daemon {
    public:
        virtual ~MTSocketDaemon();


        int getClientTimeout() const;


        size_t getNumberOfActiveThreads();


        size_t getNumberOfConnections();


        size_t getNumberOfThreads();


        int getMaxNumberOfThreads() const;


        WorkPile<Socket*> *getWebQueue();


        WorkPile<Socket*> *getWorkerQueue();


        ThreadList *getWorkerThreads();

protected:

        MTSocketDaemon(const String &name);

        void closeSockets();

        virtual void config();

        virtual void createThreads(bool init);


        virtual WorkerThread *createWorkerThread(time_t lifetime, bool web = false) = 0;


        bool dumpState(bool force);


        virtual void handler(Socket::socket_type fd, int what);


        virtual int loop();


        virtual bool needRootPrivileges();

        void openSockets();

        virtual void terminateThreads();

        int               _children;         
        WorkPile<Socket*> _clientqueue;      
        int               _clienttimeout;    
        int               _fdtype[8];        
        size_t            _nfds;             
        int               _port;             
        int               _sslport;          
        int               _sslwebport;       
        ThreadList        _threads;          
        bool              _threads_waitexit; 
        int               _udpport;          
        int               _webport;          
        int               _web_lifetime;     
        int               _web_max;          
        int               _web_min;          
        int               _web_start;        
        WorkPile<Socket*> _webqueue;         
        int               _worker_lifetime;  
        int               _worker_max;       
        int               _worker_min;       
        int               _worker_start;     
        ThreadList        _workerthreads;    

    #ifdef _WIN32
        Socket::socket_type  _fd[8];            
    #else
        struct pollfd     _fd[8];            
        String            _unixsocket;       
    #endif
    };
}

#endif