--- parser3/src/targets/isapi/parser3isapi.C 2001/10/13 17:42:52 1.52 +++ parser3/src/targets/isapi/parser3isapi.C 2002/05/07 07:39:19 1.71 @@ -1,10 +1,10 @@ /** @file Parser: IIS extension. - Copyright (c) 2000,2001 ArtLebedev Group (http://www.artlebedev.com) - Author: Alexander Petrosyan (http://design.ru/paf) + Copyright (c) 2000,2001, 2002 ArtLebedev Group (http://www.artlebedev.com) + Author: Alexandr Petrosian (http://paf.design.ru) - $Id: parser3isapi.C,v 1.52 2001/10/13 17:42:52 parser Exp $ + $Id: parser3isapi.C,v 1.71 2002/05/07 07:39:19 paf Exp $ */ #ifndef _MSC_VER @@ -13,11 +13,6 @@ #include "pa_config_includes.h" -#include -#include - -#include - #include "pa_sapi.h" #include "pa_globals.h" #include "pa_request.h" @@ -25,9 +20,11 @@ #include "pool_storage.h" #include "pa_socks.h" -#ifdef XML -#include -#endif +#include +#include +#include + +#include #define MAX_STATUS_LENGTH sizeof("xxxx LONGEST STATUS DESCRIPTION") @@ -41,9 +38,6 @@ extern const char *gd_RCSIds[]; extern const char *classes_RCSIds[]; extern const char *types_RCSIds[]; extern const char *parser3isapi_RCSIds[]; -#ifdef XML -extern const char *xalan_patched_RCSIds[]; -#endif const char **RCSIds[]={ main_RCSIds, #ifdef USE_SMTP @@ -53,12 +47,13 @@ const char **RCSIds[]={ classes_RCSIds, types_RCSIds, parser3isapi_RCSIds, -#ifdef XML - xalan_patched_RCSIds, -#endif 0 }; +// globals + +char argv0[MAX_STRING]=""; + // SAPI #ifndef DOXYGEN @@ -73,27 +68,9 @@ struct SAPI_func_context { }; #endif -#ifdef XML -/** - * Terminate Xalan and Xerces. - * - * Should be called only once per process after deleting all - * instances of XalanTransformer. Once a process has called - * this function, it cannot use the API for the remaining - * lifetime of the process. - - - this requirement is fullfilled by using Pool::register_cleanup - */ -void callXalanTerminate(void *) { - //_asm int 3; - XalanTerminate(); -} -#endif - // goes to 'cs-uri-query' log file field. webmaster: switch it ON[default OFF]. void SAPI::log(Pool& pool, const char *fmt, ...) { - SAPI_func_context& ctx=*static_cast(pool.context()); + SAPI_func_context& ctx=*static_cast(pool.get_context()); va_list args; va_start(args,fmt); @@ -108,8 +85,19 @@ void SAPI::log(Pool& pool, const char *f HSE_APPEND_LOG_PARAMETER, buf, &size, 0); } +/// @todo event log +void SAPI::die(const char *fmt, ...) { + if(FILE *log=fopen("c:\\die.log", "at")) { + va_list args; + va_start(args,fmt); + vfprintf(log, fmt, args); + fclose(log); + } + exit(1); +} + const char *SAPI::get_env(Pool& pool, const char *name) { - SAPI_func_context& ctx=*static_cast(pool.context()); + SAPI_func_context& ctx=*static_cast(pool.get_context()); char *variable_buf=(char *)pool.malloc(MAX_STRING); DWORD variable_len = MAX_STRING-1; @@ -132,7 +120,7 @@ const char *SAPI::get_env(Pool& pool, co } size_t SAPI::read_post(Pool& pool, char *buf, size_t max_bytes) { - SAPI_func_context& ctx=*static_cast(pool.context()); + SAPI_func_context& ctx=*static_cast(pool.get_context()); DWORD read_from_buf=0; DWORD read_from_input=0; @@ -162,7 +150,7 @@ size_t SAPI::read_post(Pool& pool, char } void SAPI::add_header_attribute(Pool& pool, const char *key, const char *value) { - SAPI_func_context& ctx=*static_cast(pool.context()); + SAPI_func_context& ctx=*static_cast(pool.get_context()); if(strcasecmp(key, "location")==0) ctx.http_response_code=302; @@ -179,11 +167,8 @@ void SAPI::add_header_attribute(Pool& po /// @todo intelligent cache-control void SAPI::send_header(Pool& pool) { - SAPI_func_context& ctx=*static_cast(pool.context()); + SAPI_func_context& ctx=*static_cast(pool.get_context()); - ctx.header->APPEND_CONST( - "expires: Fri, 23 Mar 2001 09:32:23 GMT\r\n" - "\r\n"); HSE_SEND_HEADER_EX_INFO header_info; char status_buf[MAX_STATUS_LENGTH]; @@ -204,6 +189,7 @@ void SAPI::send_header(Pool& pool) { break; } header_info.cchStatus=strlen(header_info.pszStatus); + *ctx.header << "\r\n"; // ISAPI v<5 did quite well without it header_info.pszHeader=ctx.header->cstr(); header_info.cchHeader=ctx.header->size(); header_info.fKeepConn=true; @@ -215,7 +201,7 @@ void SAPI::send_header(Pool& pool) { } void SAPI::send_body(Pool& pool, const void *buf, size_t size) { - SAPI_func_context& ctx=*static_cast(pool.context()); + SAPI_func_context& ctx=*static_cast(pool.get_context()); DWORD num_bytes=size; ctx.lpECB->WriteClient(ctx.lpECB->ConnID, @@ -224,43 +210,43 @@ void SAPI::send_body(Pool& pool, const v // +int failed_new(size_t size) { + SAPI::die("out of memory in 'new', failed to allocated %u bytes", size); + return 0; // not reached +} + +#ifdef _DEBUG +static Pool_storage *global_pool_storagep; +#endif static bool parser_init() { static bool globals_inited=false; if(globals_inited) return true; globals_inited=true; - static Pool pool(0); // global pool - PTRY { - // init socks - init_socks(pool); + _set_new_handler(failed_new); -#ifdef XML - /** - * Initialize Xerces and Xalan. - * - * Should be called only once per process before making - * any other API calls. - */ - //_asm int 3; - XalanInitialize(); - pool.register_cleanup(callXalanTerminate, 0); + static Pool_storage pool_storage; +#ifdef _DEBUG + global_pool_storagep=&pool_storage; #endif - + static Pool pool(&pool_storage); // global pool + try { + // init socks + init_socks(pool); // init global classes init_methoded_array(pool); // init global variables pa_globals_init(pool); - + // successful finish return true; - } PCATCH(e) { // global problem - //const char *body=e.comment(); + } catch(const Exception& e) { // global problem + const char *body=e.comment(); // unsuccessful finish return false; } - PEND_CATCH } /// ISAPI // @@ -282,7 +268,122 @@ BOOL WINAPI GetExtensionVersion(HSE_VERS @test PARSER_VERSION from outside */ -DWORD WINAPI HttpExtensionProc(LPEXTENSION_CONTROL_BLOCK lpECB) { + +void real_parser_handler(Pool& pool, LPEXTENSION_CONTROL_BLOCK lpECB, bool header_only) { + static_cast(pool.get_context())->header=new(pool) String(pool); + + // Request info + Request::Info request_info; + + size_t path_translated_buf_size=strlen(lpECB->lpszPathTranslated)+1; + char *filespec_to_process=(char *)pool.malloc(path_translated_buf_size); + memcpy(filespec_to_process, lpECB->lpszPathTranslated, path_translated_buf_size); +#ifdef WIN32 + back_slashes_to_slashes(filespec_to_process); +#endif + + if(const char *path_info=SAPI::get_env(pool, "PATH_INFO")) { + // IIS + size_t len=strlen(filespec_to_process)-strlen(path_info); + char *buf=(char *)pool.malloc(len+1); + strncpy(buf, filespec_to_process, len); buf[len]=0; + request_info.document_root=buf; + } else + throw Exception("parser.runtime", + 0, + "ISAPI: no PATH_INFO defined (in reinventing DOCUMENT_ROOT)"); + + request_info.path_translated=filespec_to_process; + request_info.method=lpECB->lpszMethod; + request_info.query_string=lpECB->lpszQueryString; + if(lpECB->lpszQueryString && *lpECB->lpszQueryString) { + char *reconstructed_uri=(char *)pool.malloc( + strlen(lpECB->lpszPathInfo)+1/*'?'*/+ + strlen(lpECB->lpszQueryString)+1/*0*/); + strcpy(reconstructed_uri, lpECB->lpszPathInfo); + strcat(reconstructed_uri, "?"); + strcat(reconstructed_uri, lpECB->lpszQueryString); + request_info.uri=reconstructed_uri; + } else + request_info.uri=lpECB->lpszPathInfo; + + request_info.content_type=lpECB->lpszContentType; + request_info.content_length=lpECB->cbTotalBytes; + request_info.cookie=SAPI::get_env(pool, "HTTP_COOKIE"); + request_info.user_agent=SAPI::get_env(pool, "HTTP_USER_AGENT"); + + + // prepare to process request + Request request(pool, + request_info, + String::UL_HTML|String::UL_OPTIMIZE_BIT, +#ifdef _DEBUG + true +#else + false +#endif + /* status_allowed */); + + // some root-controlled location + // c:\windows + char root_config_path[MAX_STRING]; + GetWindowsDirectory(root_config_path, MAX_STRING); + // must be dynamic: rethrowing from request.core + // may return 'source' which can be inside of 'root auto.p@exeception' + char *root_config_filespec=(char *)pool.malloc(MAX_STRING); + snprintf(root_config_filespec, MAX_STRING, + "%s/%s", + root_config_path, CONFIG_FILE_NAME); + + // beside by binary + static char site_config_path[MAX_STRING]; + strncpy(site_config_path, argv0, MAX_STRING-1); site_config_path[MAX_STRING-1]=0; // filespec of my binary + if(!( + rsplit(site_config_path, '/') || + rsplit(site_config_path, '\\'))) { // strip filename + // no path, just filename + site_config_path[0]='.'; site_config_path[1]=0; + } + char site_config_filespec[MAX_STRING]; + snprintf(site_config_filespec, MAX_STRING, + "%s/%s", + site_config_path, CONFIG_FILE_NAME); + + // process the request + request.core( + root_config_filespec, false /*fail_on_read_problem*/, // /path/to/root/parser3.conf + site_config_filespec, false /*fail_on_read_problem*/, // /path/to/site/parser3.conf + header_only); +} + +void call_real_parser_handler__do_SEH(Pool& pool, + LPEXTENSION_CONTROL_BLOCK lpECB, + bool header_only) { +#if _MSC_VER & !defined(_DEBUG) + LPEXCEPTION_POINTERS system_exception=0; + __try { +#endif + real_parser_handler(pool, lpECB, header_only); + +#if _MSC_VER & !defined(_DEBUG) + } __except ( + (system_exception=GetExceptionInformation()), + EXCEPTION_EXECUTE_HANDLER) { + + if(system_exception) + if(_EXCEPTION_RECORD *er=system_exception->ExceptionRecord) + throw Exception(0, + 0, + "Exception 0x%08X at 0x%08X", er->ExceptionCode, er->ExceptionAddress); + else + throw Exception(0, 0, "Exception "); + else + throw Exception(0, 0, "Exception "); + } +#endif +} + +inline DWORD RealHttpExtensionProc(LPEXTENSION_CONTROL_BLOCK lpECB) { Pool_storage pool_storage; Pool pool(&pool_storage); // no allocations until assigned context [for reporting] SAPI_func_context ctx={ @@ -290,91 +391,13 @@ DWORD WINAPI HttpExtensionProc(LPEXTENSI 0, // filling later: so that if there would be error pool would have ctx 200 // default http_response_code }; - _asm nop; // int 3; pool.set_context(&ctx);// no allocations before this line! - -#ifdef XML - /** - * Initialize Xerces and Xalan. - * - * Should be called only once per process before making - * any other API calls. - */ - //_asm int 3; - XalanInitialize(); - pool.register_cleanup(callXalanTerminate, 0); -#endif - bool header_only=strcasecmp(lpECB->lpszMethod, "HEAD")==0; - PTRY { // global try - ctx.header=new(pool) String(pool); - - // Request info - Request::Info request_info; - - size_t path_translated_buf_size=strlen(lpECB->lpszPathTranslated)+1; - char *filespec_to_process=(char *)pool.malloc(path_translated_buf_size); - memcpy(filespec_to_process, lpECB->lpszPathTranslated, path_translated_buf_size); -#ifdef WIN32 - back_slashes_to_slashes(filespec_to_process); -#endif - - if(const char *path_info=SAPI::get_env(pool, "PATH_INFO")) { - // IIS - size_t len=strlen(filespec_to_process)-strlen(path_info); - char *buf=(char *)pool.malloc(len+1); - strncpy(buf, filespec_to_process, len); buf[len]=0; - request_info.document_root=buf; - } else - PTHROW(0, 0, - 0, - "ISAPI: no PATH_INFO defined (in reinventing DOCUMENT_ROOT)"); - - request_info.path_translated=filespec_to_process; - request_info.method=lpECB->lpszMethod; - request_info.query_string=lpECB->lpszQueryString; - if(lpECB->lpszQueryString && *lpECB->lpszQueryString) { - char *reconstructed_uri=(char *)pool.malloc( - strlen(lpECB->lpszPathInfo)+1/*'?'*/+ - strlen(lpECB->lpszQueryString)+1/*0*/); - strcpy(reconstructed_uri, lpECB->lpszPathInfo); - strcat(reconstructed_uri, "?"); - strcat(reconstructed_uri, lpECB->lpszQueryString); - request_info.uri=reconstructed_uri; - } else - request_info.uri=lpECB->lpszPathInfo; - - request_info.content_type=lpECB->lpszContentType; - request_info.content_length=lpECB->cbTotalBytes; - request_info.cookie=SAPI::get_env(pool, "HTTP_COOKIE"); - request_info.user_agent=SAPI::get_env(pool, "HTTP_USER_AGENT"); - - - // prepare to process request - Request request(pool, - request_info, - String::UL_USER_HTML - ); - - // some root-controlled location - // c:\windows - char root_config_path[MAX_STRING]; - GetWindowsDirectory(root_config_path, MAX_STRING); - // must be dynamic: rethrowing from request.core - // may return 'source' which can be inside of 'root auto.p@exeception' - char *root_config_filespec=(char *)pool.malloc(MAX_STRING); - snprintf(root_config_filespec, MAX_STRING, - "%s/%s", - root_config_path, CONFIG_FILE_NAME); - - // process the request - request.core( - root_config_filespec, false/*may be abcent*/, // /path/to/admin/auto.p - 0/*parser_site_auto_path*/, false, // /path/to/site/auto.p - header_only); + try { // global try + call_real_parser_handler__do_SEH(pool, lpECB, header_only); // successful finish - } PCATCH(e) { // global problem + } catch(const Exception& e) { // global problem // don't allocate anything on pool here: // possible pool' exception not catch-ed now // and there could be out-of-memory exception @@ -390,7 +413,7 @@ DWORD WINAPI HttpExtensionProc(LPEXTENSI int header_len=snprintf(header_buf, MAX_STRING, "content-type: text/plain\r\n" "content-length: %lu\r\n" - "expires: Fri, 23 Mar 2001 09:32:23 GMT\r\n" +// "expires: Fri, 23 Mar 2001 09:32:23 GMT\r\n" "\r\n", content_length); @@ -412,7 +435,80 @@ DWORD WINAPI HttpExtensionProc(LPEXTENSI // unsuccessful finish } - PEND_CATCH - +/* + const char *body="test"; + + // + int content_length=strlen(body); + + // prepare header // not using SAPI func wich allocates on pool + char header_buf[MAX_STRING]; + int header_len=snprintf(header_buf, MAX_STRING, + "content-type: text/plain\r\n" + "content-length: %lu\r\n" + "expires: Fri, 23 Mar 2001 09:32:23 GMT\r\n" + "\r\n", + content_length); + HSE_SEND_HEADER_EX_INFO header_info; + header_info.pszStatus="200 OK"; + header_info.cchStatus=strlen(header_info.pszStatus); + header_info.pszHeader=header_buf; + header_info.cchHeader=header_len; + header_info.fKeepConn=true; + + // send header + lpECB->dwHttpStatusCode=200; + lpECB->ServerSupportFunction(lpECB->ConnID, + HSE_REQ_SEND_RESPONSE_HEADER_EX, &header_info, NULL, NULL); + + // send body + DWORD num_bytes=content_length; + lpECB->WriteClient(lpECB->ConnID, + (void *)body, &num_bytes, HSE_IO_SYNC); +*/ return HSE_STATUS_SUCCESS_AND_KEEP_CONN; } + +#ifdef _DEBUG +//for memory leaks detection only +#undef _WINDOWS_ +#include +#endif +DWORD WINAPI HttpExtensionProc(LPEXTENSION_CONTROL_BLOCK lpECB) { +// Declare the variables needed +#ifdef _DEBUG +// _crtBreakAlloc=97779;//97777; //997; + + CMemoryState oldMemState, newMemState, diffMemState; + oldMemState.Checkpoint(); + //global_pool_storagep->fbreak_on_alloc=true; +#endif + + DWORD result=RealHttpExtensionProc(lpECB); + +#ifdef _DEBUG + newMemState.Checkpoint(); + if( diffMemState.Difference( oldMemState, newMemState ) ) + { + TRACE( "Memory leaked!\n" ); + diffMemState.DumpStatistics( ); + diffMemState.DumpAllObjectsSince(); + } +#endif + return result; +} + +BOOL WINAPI DllMain( + HINSTANCE hinstDLL, // handle to the DLL module + DWORD fdwReason, // reason for calling function + LPVOID lpvReserved // reserved + ) { + + GetModuleFileName( + hinstDLL, // handle to module + argv0, // file name of module + sizeof(argv0) // size of buffer + ); + + return TRUE; +} \ No newline at end of file