WorkerThread.h

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

#ifndef BASE_WORKERTHREAD_H
#define BASE_WORKERTHREAD_H

#include <ctime>
#include "MTSocketDaemon.h"
#include "Log.h"
#include "Mutex.h"
#include "Socket.h"
#include "Thread.h"
#include "WorkPile.h"

namespace base {

    class PPBASE_EXPORT WorkerThread: public Thread, public Mutex {
    public:

        WorkerThread(MTSocketDaemon *daemon, time_t lifetime = 0, bool web = false);

        ~WorkerThread();


        time_t getLifetime() const;


        Log *getLog();


        void getStatus(int *status, String &request, String &addr, u_longlong_t *tv);


        bool isAuxiliary() const;


        bool isWeb() const;

        void run();

        void run(Socket *sock);

    protected:
        virtual void config();

        virtual void handle() = 0;

        bool readln(String &buf, bool strip = false);


        void setStatus(int status, const String &request, const String &addr, u_longlong_t tv = 0);

        void write(const String &s);

        void writef(const char *fmt, ...)
        #ifdef __GNUC__
            __attribute__((format(printf, 2, 3)))
        #endif
            ;

        String             _addr;             
        MTSocketDaemon    *_daemon;           
        time_t             _lifetime;         
        Log               *_log;              
        WorkPile<Socket*> *_queue;            
        Socket            *_sock;             
        int                _status;           
        String             _status_addr;      
        String             _status_request;   
        u_longlong_t       _status_time;      
        int                _timeout;          
        bool               _web;              
    };
}

#endif