|
|
| version 1.41, 2001/09/15 14:22:47 | version 1.82.2.6.2.6, 2003/04/08 13:58:30 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: IIS extension. | Parser: IIS extension. |
| Copyright (c) 2000,2001 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2000,2001-2003 ArtLebedev Group (http://www.artlebedev.com) |
| Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) | |
| Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) | |
| */ | */ |
| static const char *RCSId="$Id$"; | |
| static const char* IDENT_PARSER3ISAPI_C="$Date$"; | |
| #ifndef _MSC_VER | #ifndef _MSC_VER |
| # error compile ISAPI module with MSVC [no urge for now to make it autoconf-ed (PAF)] | # error compile ISAPI module with MSVC [no urge for now to make it autoconf-ed (PAF)] |
| #endif | #endif |
| #include <windows.h> | #include "pa_config_includes.h" |
| #include <process.h> | |
| #include <httpext.h> | |
| #include "pa_sapi.h" | #include "pa_sapi.h" |
| #include "pa_globals.h" | #include "pa_globals.h" |
| Line 23 static const char *RCSId="$Id$"; | Line 20 static const char *RCSId="$Id$"; |
| #include "pool_storage.h" | #include "pool_storage.h" |
| #include "pa_socks.h" | #include "pa_socks.h" |
| #include <windows.h> | |
| #include <process.h> | |
| #include <httpext.h> | |
| #define MAX_STATUS_LENGTH sizeof("xxxx LONGEST STATUS DESCRIPTION") | #define MAX_STATUS_LENGTH sizeof("xxxx LONGEST STATUS DESCRIPTION") |
| // consts | |
| const char* IIS51vars[]={ | |
| "APPL_MD_PATH", "APPL_PHYSICAL_PATH", | |
| "AUTH_PASSWORD", "AUTH_TYPE", "AUTH_USER", | |
| "CERT_COOKIE", "CERT_FLAGS", "CERT_ISSUER", "CERT_KEYSIZE", "CERT_SECRETKEYSIZE", | |
| "CERT_SERIALNUMBER", "CERT_SERVER_ISSUER", "CERT_SERVER_SUBJECT", "CERT_SUBJECT", | |
| "CONTENT_LENGTH", "CONTENT_TYPE", | |
| "LOGON_USER", | |
| "HTTPS", "HTTPS_KEYSIZE", "HTTPS_SECRETKEYSIZE", "HTTPS_SERVER_ISSUER", "HTTPS_SERVER_SUBJECT", | |
| "INSTANCE_ID", "INSTANCE_META_PATH", | |
| "PATH_INFO", "PATH_TRANSLATED", | |
| "QUERY_STRING", | |
| "REMOTE_ADDR", "REMOTE_HOST", "REMOTE_USER", "REQUEST_METHOD", | |
| "SCRIPT_NAME", | |
| "SERVER_NAME", "SERVER_PORT", "SERVER_PORT_SECURE", "SERVER_PROTOCOL", "SERVER_SOFTWARE", | |
| "URL", | |
| }; | |
| const int IIS51var_count=sizeof(IIS51vars)/sizeof(*IIS51vars); | |
| // globals | |
| char argv0[MAX_STRING]=""; | |
| // SAPI | // SAPI |
| #ifndef DOXYGEN | #ifndef DOXYGEN |
| Line 40 struct SAPI_func_context { | Line 66 struct SAPI_func_context { |
| #endif | #endif |
| // goes to 'cs-uri-query' log file field. webmaster: switch it ON[default OFF]. | // goes to 'cs-uri-query' log file field. webmaster: switch it ON[default OFF]. |
| void SAPI::log(Pool& pool, const char *fmt, ...) { | void SAPI::logconst char* fmt, ...) { |
| SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.context()); | SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.get_context()); |
| va_list args; | va_list args; |
| va_start(args,fmt); | va_start(args,fmt); |
| char buf[MAX_STRING]; | char buf[MAX_STRING]; |
| const char *prefix="PARSER_ERROR:"; | const char* prefix="PARSER_ERROR:"; |
| strcpy(buf, prefix); | strcpy(buf, prefix); |
| DWORD size=vsnprintf(buf+strlen(prefix), MAX_STRING-strlen(prefix), fmt, args); | char *start=buf+strlen(prefix); |
| DWORD size=vsnprintf(start, MAX_STRING-strlen(prefix), fmt, args); | |
| remove_crlf(start, start+size); | |
| ctx.lpECB->ServerSupportFunction(ctx.lpECB->ConnID, | ctx.lpECB->ServerSupportFunction(ctx.lpECB->ConnID, |
| HSE_APPEND_LOG_PARAMETER, buf, &size, 0); | HSE_APPEND_LOG_PARAMETER, buf, &size, 0); |
| } | } |
| const char *SAPI::get_env(Pool& pool, const char *name) { | /// @todo event log |
| SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.context()); | static void die_or_abort(const char* fmt, va_list args, bool write_core) { |
| if(FILE *log=fopen("c:\\parser3die.log", "at")) { | |
| vfprintf(log, fmt, args); | |
| fclose(log); | |
| } | |
| // exit & try to produce core dump | |
| abort(); | |
| } | |
| void SAPI::die(const char* fmt, ...) { | |
| va_list args; | |
| va_start(args, fmt); | |
| die_or_abort(fmt, args, false/*write core?*/); | |
| va_end(args); | |
| } | |
| void SAPI::abort(const char* fmt, ...) { | |
| va_list args; | |
| va_start(args, fmt); | |
| die_or_abort(fmt, args, true/*write core?*/); | |
| va_end(args); | |
| } | |
| char *variable_buf=(char *)pool.malloc(MAX_STRING); | const char* SAPI::get_envconst char* name) { |
| SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.get_context()); | |
| char *variable_buf=new(PointerFreeGC) char[MAX_STRING]; | |
| DWORD variable_len = MAX_STRING-1; | DWORD variable_len = MAX_STRING-1; |
| if(ctx.lpECB->GetServerVariable(ctx.lpECB->ConnID, const_cast<char *>(name), | if(ctx.lpECB->GetServerVariable(ctx.lpECB->ConnID, const_cast<char *>(name), |
| variable_buf, &variable_len)) { | variable_buf, &variable_len)) { |
| variable_buf[variable_len]=0; | if(*variable_buf) { // saw returning len=1 && *buf=0 :( |
| return variable_buf; | variable_buf[variable_len]=0; |
| return variable_buf; | |
| } | |
| } else if (GetLastError()==ERROR_INSUFFICIENT_BUFFER) { | } else if (GetLastError()==ERROR_INSUFFICIENT_BUFFER) { |
| variable_buf=(char *)pool.malloc(variable_len+1); | variable_buf=new(PointerFreeGC) char[variable_len+1]; |
| if(ctx.lpECB->GetServerVariable(ctx.lpECB->ConnID, const_cast<char *>(name), | if(ctx.lpECB->GetServerVariable(ctx.lpECB->ConnID, const_cast<char *>(name), |
| variable_buf, &variable_len)) { | variable_buf, &variable_len)) { |
| variable_buf[variable_len]=0; | if(*variable_buf) { |
| return variable_buf; | variable_buf[variable_len]=0; |
| return variable_buf; | |
| } | |
| } | } |
| } | } |
| return 0; | return 0; |
| } | } |
| size_t SAPI::read_post(Pool& pool, char *buf, size_t max_bytes) { | static int grep_char(const char* s, char c) { |
| SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.context()); | int result=0; |
| if(s) { | |
| while(s=strchr(s, c)) { | |
| s++; // skip found c | |
| result++; | |
| } | |
| } | |
| return result; | |
| } | |
| static const char* mk_env_pairconst char* key, const char* value) { | |
| char *result=new(PointerFreeGC) char[strlen(key)+1/*=*/+strlen(value)+1/*0*/]; | |
| strcpy(result, key); strcat(result, "="); strcat(result, value); | |
| return result; | |
| } | |
| const char* const *SAPI::environment(SAPI_Info& info, ) { | |
| // we know this buf is writable | |
| const char* all_http_vars=SAPI::get_env("ALL_HTTP"); | |
| const int http_var_count=grep_char(all_http_vars, '\n')+1/*\n for theoretical(never saw) this \0*/; | |
| const char* *result=new const char*[IIS51var_count+http_var_count+1/*0*/]; | |
| const char* *cur=result; | |
| // IIS5.1 vars | |
| for(int i=0; i<IIS51var_count; i++) { | |
| const char* key=IIS51vars[i]; | |
| if(const char* value=SAPI::get_env(key)) | |
| *cur++=mk_env_pair(key, value); | |
| } | |
| // HTTP_* vars | |
| if(char *s=all_http_vars) { | |
| while(char *key=lsplit(&s, '\n')) | |
| if(char *value=lsplit(key, ':')) | |
| *cur++=mk_env_pair(key, value); | |
| } | |
| // mark EOE | |
| *cur=0; | |
| return result; | |
| } | |
| size_t SAPI::read_postchar *buf, size_t max_bytes) { | |
| SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.get_context()); | |
| DWORD read_from_buf=0; | DWORD read_from_buf=0; |
| DWORD read_from_input=0; | DWORD read_from_input=0; |
| Line 107 size_t SAPI::read_post(Pool& pool, char | Line 204 size_t SAPI::read_post(Pool& pool, char |
| return total_read; | return total_read; |
| } | } |
| void SAPI::add_header_attribute(Pool& pool, const char *key, const char *value) { | void SAPI::add_header_attribute |
| SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.context()); | const char* dont_store_key, const char* dont_store_value) { |
| SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.get_context()); | |
| if(strcasecmp(key, "location")==0) | if(strcasecmp(key, "location")==0) |
| ctx.http_response_code=302; | ctx.http_response_code=302; |
| if(strcasecmp(key, "status")==0) | if(strcasecmp(key, "status")==0) |
| ctx.http_response_code=atoi(value); | ctx.http_response_code=atoi(dont_store_value); |
| else { | else { |
| ctx.header->APPEND_CONST(key); | todo: copy dont_store_ to nonvilotile |
| ctx.header->APPEND_CONST(dont_store_key); | |
| ctx.header->APPEND_CONST(": "); | ctx.header->APPEND_CONST(": "); |
| ctx.header->APPEND_CONST(value); | ctx.header->APPEND_CONST(dont_store_value); |
| ctx.header->APPEND_CONST("\r\n"); | ctx.header->APPEND_CONST("\r\n"); |
| } | } |
| } | } |
| /// @todo intelligent cache-control | /// @todo intelligent cache-control |
| void SAPI::send_header(Pool& pool) { | void SAPI::send_header() { |
| SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.context()); | SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(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; | HSE_SEND_HEADER_EX_INFO header_info; |
| char status_buf[MAX_STATUS_LENGTH]; | char status_buf[MAX_STATUS_LENGTH]; |
| Line 150 void SAPI::send_header(Pool& pool) { | Line 246 void SAPI::send_header(Pool& pool) { |
| break; | break; |
| } | } |
| header_info.cchStatus=strlen(header_info.pszStatus); | 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.pszHeader=ctx.header->cstr(); |
| header_info.cchHeader=ctx.header->size(); | header_info.cchHeader=ctx.header->length(); |
| header_info.fKeepConn=true; | header_info.fKeepConn=true; |
| ctx.lpECB->dwHttpStatusCode=ctx.http_response_code; | ctx.lpECB->dwHttpStatusCode=ctx.http_response_code; |
| Line 160 void SAPI::send_header(Pool& pool) { | Line 257 void SAPI::send_header(Pool& pool) { |
| HSE_REQ_SEND_RESPONSE_HEADER_EX, &header_info, NULL, NULL); | HSE_REQ_SEND_RESPONSE_HEADER_EX, &header_info, NULL, NULL); |
| } | } |
| void SAPI::send_body(Pool& pool, const void *buf, size_t size) { | void SAPI::send_bodyconst void *buf, size_t size) { |
| SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.context()); | SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.get_context()); |
| DWORD num_bytes=size; | DWORD num_bytes=size; |
| ctx.lpECB->WriteClient(ctx.lpECB->ConnID, | ctx.lpECB->WriteClient(ctx.lpECB->ConnID, |
| const_cast<void *>(buf), &num_bytes, HSE_IO_SYNC); | const_cast<void *>(buf), &num_bytes, HSE_IO_SYNC); |
| } | } |
| // | |
| static bool parser_init() { | static bool parser_init() { |
| static bool globals_inited=false; | static bool globals_inited=false; |
| Line 176 static bool parser_init() { | Line 272 static bool parser_init() { |
| return true; | return true; |
| globals_inited=true; | globals_inited=true; |
| static Pool pool(0); // global pool | static Pool pool(&pool_storage); // global pool |
| PTRY { | try { |
| // init socks | // init socks |
| init_socks(pool); | pa_init_socks(); |
| // init global classes | // init global classes |
| init_methoded_array(pool); | init_methoded_array(); |
| // init global variables | // init global variables |
| pa_globals_init(pool); | pa_globals_init(); |
| // successful finish | // successful finish |
| return true; | return true; |
| } PCATCH(e) { // global problem | } catch(const Exception& e) { // global problem |
| //const char *body=e.comment(); | const char* body=e.comment(); |
| // unsuccessful finish | // unsuccessful finish |
| return false; | return false; |
| } | } |
| PEND_CATCH | |
| } | } |
| /// ISAPI // | /// ISAPI // |
| Line 216 BOOL WINAPI GetExtensionVersion(HSE_VERS | Line 310 BOOL WINAPI GetExtensionVersion(HSE_VERS |
| @test | @test |
| PARSER_VERSION from outside | PARSER_VERSION from outside |
| */ | */ |
| DWORD WINAPI HttpExtensionProc(LPEXTENSION_CONTROL_BLOCK lpECB) { | |
| Pool_storage pool_storage; | void real_parser_handlerLPEXTENSION_CONTROL_BLOCK lpECB, bool header_only) { |
| Pool pool(&pool_storage); // no allocations until assigned context [for reporting] | static_cast<SAPI_func_context *>(pool.get_context())->header=new String; |
| SAPI_func_context ctx={ | |
| lpECB, | |
| 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! | |
| bool header_only=strcasecmp(lpECB->lpszMethod, "HEAD")==0; | // Request info |
| PTRY { // global try | Request::Info request_info; |
| ctx.header=new(pool) String(pool); | |
| // Request info | |
| Request::Info request_info; | |
| size_t path_translated_buf_size=strlen(lpECB->lpszPathTranslated)+1; | size_t path_translated_buf_size=strlen(lpECB->lpszPathTranslated)+1; |
| char *filespec_to_process=(char *)malloc(path_translated_buf_size); | char *filespec_to_process=pool.copy(lpECB->lpszPathTranslated, path_translated_buf_size); |
| memcpy(filespec_to_process, lpECB->lpszPathTranslated, path_translated_buf_size); | |
| #ifdef WIN32 | #ifdef WIN32 |
| back_slashes_to_slashes(filespec_to_process); | back_slashes_to_slashes(filespec_to_process); |
| #endif | #endif |
| if(const char *path_info=SAPI::get_env(pool, "PATH_INFO")) { | if(const char* path_info=SAPI::get_env("PATH_INFO")) { |
| // IIS | // IIS |
| size_t len=strlen(filespec_to_process)-strlen(path_info); | size_t len=strlen(filespec_to_process)-strlen(path_info); |
| char *buf=(char *)pool.malloc(len+1); | char *buf=new(PointerFreeGC) char[len+1]; |
| strncpy(buf, filespec_to_process, len); buf[len]=0; | strncpy(buf, filespec_to_process, len); buf[len]=0; |
| request_info.document_root=buf; | request_info.document_root=buf; |
| } else | } else |
| PTHROW(0, 0, | throw Exception("parser.runtime", |
| 0, | 0, |
| "ISAPI: no PATH_INFO defined (in reinventing DOCUMENT_ROOT)"); | "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=new(PointerFreeGC) char[ | |
| 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("HTTP_COOKIE"); | |
| request_info.mail_received=false; | |
| // prepare to process request | |
| Request request(pool, | |
| request_info, | |
| String::L_HTML|String::L_OPTIMIZE_BIT, | |
| #ifdef _DEBUG | |
| true | |
| #else | |
| false | |
| #endif | |
| /* status_allowed */); | |
| request_info.path_translated=filespec_to_process; | // beside by binary |
| request_info.method=lpECB->lpszMethod; | static char beside_binary_path[MAX_STRING]; |
| request_info.query_string=lpECB->lpszQueryString; | strncpy(beside_binary_path, argv0, MAX_STRING-1); beside_binary_path[MAX_STRING-1]=0; // filespec of my binary |
| if(lpECB->lpszQueryString && *lpECB->lpszQueryString) { | if(!( |
| char *reconstructed_uri=(char *)malloc( | rsplit(beside_binary_path, '/') || |
| strlen(lpECB->lpszPathInfo)+1/*'?'*/+ | rsplit(beside_binary_path, '\\'))) { // strip filename |
| strlen(lpECB->lpszQueryString)+1/*0*/); | // no path, just filename |
| strcpy(reconstructed_uri, lpECB->lpszPathInfo); | beside_binary_path[0]='.'; beside_binary_path[1]=0; |
| strcat(reconstructed_uri, "?"); | } |
| strcat(reconstructed_uri, lpECB->lpszQueryString); | char config_filespec[MAX_STRING]; |
| request_info.uri=reconstructed_uri; | snprintf(config_filespec, MAX_STRING, |
| } else | "%s/%s", |
| request_info.uri=lpECB->lpszPathInfo; | beside_binary_path, AUTO_FILE_NAME); |
| bool fail_on_config_read_problem=entry_exists(config_filespec); | |
| request_info.content_type=lpECB->lpszContentType; | |
| request_info.content_length=lpECB->cbTotalBytes; | // process the request |
| request_info.cookie=SAPI::get_env(pool, "HTTP_COOKIE"); | request.core( |
| request_info.user_agent=SAPI::get_env(pool, "HTTP_USER_AGENT"); | config_filespec, fail_on_config_read_problem, // /path/to/first/auto.p |
| header_only); | |
| } | |
| void call_real_parser_handler__do_SEH | |
| LPEXTENSION_CONTROL_BLOCK lpECB, | |
| bool header_only) { | |
| #if _MSC_VER & !defined(_DEBUG) | |
| LPEXCEPTION_POINTERS system_exception=0; | |
| __try { | |
| #endif | |
| real_parser_handler(lpECB, header_only); | |
| // prepare to process request | #if _MSC_VER & !defined(_DEBUG) |
| Request request(pool, | } __except ( |
| request_info, | (system_exception=GetExceptionInformation()), |
| String::UL_USER_HTML | EXCEPTION_EXECUTE_HANDLER) { |
| ); | |
| if(system_exception) | |
| // some root-controlled location | if(_EXCEPTION_RECORD *er=system_exception->ExceptionRecord) |
| // c:\windows | throw Exception(0, |
| // must be dynamic: rethrowing from request.core | 0, |
| // may return 'source' which can be inside of 'root auto.p@exeception' | "Exception 0x%08X at 0x%08X", er->ExceptionCode, er->ExceptionAddress); |
| char *root_auto_path=(char *)pool.malloc(MAX_STRING); | else |
| GetWindowsDirectory(root_auto_path, MAX_STRING); | throw Exception(0, 0, "Exception <no exception record>"); |
| else | |
| // process the request | throw Exception(0, 0, "Exception <no exception information>"); |
| request.core( | } |
| root_auto_path, false/*may be abcent*/, // /path/to/admin/auto.p | #endif |
| 0/*parser_site_auto_path*/, false, // /path/to/site/auto.p | } |
| header_only); | |
| 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={ | |
| lpECB, | |
| 0, // filling later: so that if there would be error pool would have ctx | |
| 200 // default http_response_code [lpECB->dwHttpStatusCode seems to be always 0, even on 404 redirect to /404.html] | |
| }; | |
| pool.set_context(&ctx);// no allocations before this line! | |
| bool header_only=strcasecmp(lpECB->lpszMethod, "HEAD")==0; | |
| try { // global try | |
| call_real_parser_handler__do_SEH(lpECB, header_only); | |
| // successful finish | // successful finish |
| } PCATCH(e) { // global problem | } catch(const Exception& e) { // global problem |
| // don't allocate anything on pool here: | // don't allocate anything on pool here: |
| // possible pool' exception not catch-ed now | // possible pool' exception not catch-ed now |
| // and there could be out-of-memory exception | // and there could be out-of-memory exception |
| const char *body=e.comment(); | const char* body=e.comment(); |
| // log it | // log it |
| SAPI::log(pool, "exception in request exception handler: %s", body); | SAPI::log("exception in request exception handler: %s", body); |
| // | // |
| int content_length=strlen(body); | int content_length=strlen(body); |
| Line 307 DWORD WINAPI HttpExtensionProc(LPEXTENSI | Line 442 DWORD WINAPI HttpExtensionProc(LPEXTENSI |
| int header_len=snprintf(header_buf, MAX_STRING, | int header_len=snprintf(header_buf, MAX_STRING, |
| "content-type: text/plain\r\n" | "content-type: text/plain\r\n" |
| "content-length: %lu\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", | "\r\n", |
| content_length); | content_length); |
| Line 325 DWORD WINAPI HttpExtensionProc(LPEXTENSI | Line 460 DWORD WINAPI HttpExtensionProc(LPEXTENSI |
| // send body | // send body |
| if(!header_only) | if(!header_only) |
| SAPI::send_body(pool, body, content_length); | SAPI::send_body(body, content_length); |
| // unsuccessful finish | // 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; | return HSE_STATUS_SUCCESS_AND_KEEP_CONN; |
| } | } |
| #ifdef _DEBUG | |
| //for memory leaks detection only | |
| #undef _WINDOWS_ | |
| #include <afx.h> | |
| #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; | |
| } | |