mini/zz_worker_thread.h

Go to the documentation of this file.

/* libzzinet
 *
 * This program is distributed under the GNU General Public License, version 2.
 * A copy of this license is included with this source.
 *
 * Copyright 2004-2006, Toni Thomsson <toni@tonjac.org> 
*/
 
#ifndef zz_worker_thread_h
#define zz_worker_thread_h

#include <zz_http_server.h>
#include <zz_win_pool_thread.h>
#include <zz_http_request.h>
#include <zz_log.h>
#include <zz_win_threadmutex.h>
#include <zz_library.h>
#include <map>
#include <jni.h>
#include <zz_cgi.h>

class CzzWorkerThread : public CzzWinThread, CzzHTTPServer
{
public:

        //* Construction
        CzzWorkerThread( CzzAccessLog* log, JavaVM* jvm_instance, CzzHTTPRequest* req = NULL );
        virtual ~CzzWorkerThread();

        virtual void OnStart( void );


    void Queue( CzzHTTPRequest* req );

protected:
private:

        bool checkAuth( CzzHTTPRequest* req );
        bool checkLogout( CzzHTTPRequest* req );

    // Services
    int execute_cgi_script( CzzHTTPRequest* req, CzzString& script, CzzString& params );
        int execute_dll_script( CzzHTTPRequest* req, CzzString& script, CzzString& params );
        int execute_class_script( CzzHTTPRequest* req, CzzString& script, CzzString& params );
        int get_file( CzzHTTPRequest* req, CzzString& uri );
    
    // Errors
    int serviceNotFound( const char* msg );
    int internalError( const char* msg );
        void notAuthorized( void );

        // Helpers
        CzzString getDate( void );
        CzzString translateToLocal( CzzString& uri );
    CzzString urlDecode( const CzzString& url );
    CzzString toClassPath( const CzzString& name );
        CzzString trim( const CzzString& in );

        bool createChildProcess( char* env, const char* cmd, PROCESS_INFORMATION* pinfo, STARTUPINFO* sinfo );

    static CzzLibrary* getLibrary( const CzzString& name );

        int java_service( JNIEnv* env, MINI_SESSION* session, const CzzString& script, const CzzString& method, CzzCGI* cgi, char** buff, int* buff_size, char* errmsg, int size, int connect );
        void java_rollback( JNIEnv* env, jobject session, int connect );
        void java_commit( JNIEnv* env, jobject session, int connect );

        CzzLog m_Log;
        CzzString m_User;
        CzzString m_IP;
    JavaVM*   m_JvmInstance;
        CzzHTTPRequest* m_LastRequest;
        static map<CzzString, CzzLibrary* > m_LibraryMap;

        static CzzWinThreadMutex m_Mutex;
};

#endif // zz_worker_thread_h

---