|
|
| version 1.65, 2002/03/05 07:48:07 | version 1.73, 2002/06/11 14:14:16 |
|---|---|
| Line 50 const char **RCSIds[]={ | Line 50 const char **RCSIds[]={ |
| 0 | 0 |
| }; | }; |
| 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 | // globals |
| char argv0[MAX_STRING]=""; | char argv0[MAX_STRING]=""; |
| Line 104 const char *SAPI::get_env(Pool& pool, co | Line 122 const char *SAPI::get_env(Pool& pool, co |
| 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=(char *)pool.malloc(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; |
| } | } |
| static int grep_char(const char *s, char c) { | |
| int result=0; | |
| if(s) { | |
| while(s=strchr(s, c)) { | |
| s++; // skip found c | |
| result++; | |
| } | |
| } | |
| return result; | |
| } | |
| static const char *mk_env_pair(Pool& pool, const char *key, const char *value) { | |
| char *result=(char *)pool.malloc(strlen(key)+1/*=*/+strlen(value)+1/*0*/); | |
| strcpy(result, key); strcat(result, "="); strcat(result, value); | |
| return result; | |
| } | |
| const char *const *SAPI::environment(Pool& pool) { | |
| // we know this buf is writable | |
| char *all_http_vars=const_cast<char *>(SAPI::get_env(pool, "ALL_HTTP")); | |
| const int http_var_count=grep_char(all_http_vars, '\n')+1/*\n for theoretical(never saw) this \0*/; | |
| const char **result= | |
| (const char **)pool.malloc(sizeof(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(pool, key)) | |
| *cur++=mk_env_pair(pool, 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(pool, key, value); | |
| } | |
| // mark EOE | |
| *cur=0; | |
| return result; | |
| } | |
| size_t SAPI::read_post(Pool& pool, char *buf, size_t max_bytes) { | size_t SAPI::read_post(Pool& pool, char *buf, size_t max_bytes) { |
| SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.get_context()); | SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.get_context()); |
| Line 189 void SAPI::send_header(Pool& pool) { | Line 255 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->size(); |
| header_info.fKeepConn=true; | header_info.fKeepConn=true; |
| Line 214 int failed_new(size_t size) { | Line 281 int failed_new(size_t size) { |
| return 0; // not reached | return 0; // not reached |
| } | } |
| #ifdef _DEBUG | |
| static Pool_storage *global_pool_storagep; | |
| #endif | |
| static bool parser_init() { | static bool parser_init() { |
| static bool globals_inited=false; | static bool globals_inited=false; |
| if(globals_inited) | if(globals_inited) |
| Line 223 static bool parser_init() { | Line 293 static bool parser_init() { |
| _set_new_handler(failed_new); | _set_new_handler(failed_new); |
| static Pool_storage pool_storage; | static Pool_storage pool_storage; |
| #ifdef _DEBUG | |
| global_pool_storagep=&pool_storage; | |
| #endif | |
| static Pool pool(&pool_storage); // global pool | static Pool pool(&pool_storage); // global pool |
| try { | try { |
| // init socks | // init socks |
| Line 282 void real_parser_handler(Pool& pool, LPE | Line 355 void real_parser_handler(Pool& pool, LPE |
| 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 |
| throw Exception(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)"); |
| Line 303 void real_parser_handler(Pool& pool, LPE | Line 376 void real_parser_handler(Pool& pool, LPE |
| request_info.content_type=lpECB->lpszContentType; | request_info.content_type=lpECB->lpszContentType; |
| request_info.content_length=lpECB->cbTotalBytes; | request_info.content_length=lpECB->cbTotalBytes; |
| request_info.cookie=SAPI::get_env(pool, "HTTP_COOKIE"); | request_info.cookie=SAPI::get_env(pool, "HTTP_COOKIE"); |
| request_info.user_agent=SAPI::get_env(pool, "HTTP_USER_AGENT"); | |
| // prepare to process request | // prepare to process request |
| Request request(pool, | Request request(pool, |
| request_info, | request_info, |
| String::UL_HTML|String::UL_OPTIMIZE_BIT, | String::UL_HTML|String::UL_OPTIMIZE_BIT, |
| false /* status_allowed */); | #ifdef _DEBUG |
| true | |
| #else | |
| false | |
| #endif | |
| /* status_allowed */); | |
| // some root-controlled location | // some root-controlled location |
| // c:\windows | // c:\windows |
| Line 339 void real_parser_handler(Pool& pool, LPE | Line 416 void real_parser_handler(Pool& pool, LPE |
| // process the request | // process the request |
| request.core( | request.core( |
| root_config_filespec, false /*don't fail_on_read_problem*/, // /path/to/admin/parser3.conf | root_config_filespec, false /*fail_on_read_problem*/, // /path/to/root/parser3.conf |
| site_config_filespec, false /*don't fail_on_read_problem*/, // /path/to/site/parser3.conf | site_config_filespec, false /*fail_on_read_problem*/, // /path/to/site/parser3.conf |
| header_only); | header_only); |
| } | } |
| Line 360 void call_real_parser_handler__do_SEH(Po | Line 437 void call_real_parser_handler__do_SEH(Po |
| if(system_exception) | if(system_exception) |
| if(_EXCEPTION_RECORD *er=system_exception->ExceptionRecord) | if(_EXCEPTION_RECORD *er=system_exception->ExceptionRecord) |
| throw Exception(0, 0, | throw Exception(0, |
| 0, | 0, |
| "Exception 0x%08X at 0x%08X", er->ExceptionCode, er->ExceptionAddress); | "Exception 0x%08X at 0x%08X", er->ExceptionCode, er->ExceptionAddress); |
| else | else |
| throw Exception(0, 0, 0, "Exception <no exception record>"); | throw Exception(0, 0, "Exception <no exception record>"); |
| else | else |
| throw Exception(0, 0, 0, "Exception <no exception information>"); | throw Exception(0, 0, "Exception <no exception information>"); |
| } | } |
| #endif | #endif |
| } | } |
| inline DWORD RealHttpExtensionProc(LPEXTENSION_CONTROL_BLOCK lpECB) { | |
| DWORD WINAPI HttpExtensionProc(LPEXTENSION_CONTROL_BLOCK lpECB) { | |
| Pool_storage pool_storage; | Pool_storage pool_storage; |
| Pool pool(&pool_storage); // no allocations until assigned context [for reporting] | Pool pool(&pool_storage); // no allocations until assigned context [for reporting] |
| SAPI_func_context ctx={ | SAPI_func_context ctx={ |
| Line 381 DWORD WINAPI HttpExtensionProc(LPEXTENSI | Line 457 DWORD WINAPI HttpExtensionProc(LPEXTENSI |
| 200 // default http_response_code | 200 // default http_response_code |
| }; | }; |
| pool.set_context(&ctx);// no allocations before this line! | pool.set_context(&ctx);// no allocations before this line! |
| bool header_only=strcasecmp(lpECB->lpszMethod, "HEAD")==0; | bool header_only=strcasecmp(lpECB->lpszMethod, "HEAD")==0; |
| try { // global try | try { // global try |
| call_real_parser_handler__do_SEH(pool, lpECB, header_only); | call_real_parser_handler__do_SEH(pool, lpECB, header_only); |
| Line 402 DWORD WINAPI HttpExtensionProc(LPEXTENSI | Line 478 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 458 DWORD WINAPI HttpExtensionProc(LPEXTENSI | Line 534 DWORD WINAPI HttpExtensionProc(LPEXTENSI |
| 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( | BOOL WINAPI DllMain( |
| HINSTANCE hinstDLL, // handle to the DLL module | HINSTANCE hinstDLL, // handle to the DLL module |
| DWORD fdwReason, // reason for calling function | DWORD fdwReason, // reason for calling function |