[BACK]Return to parser3isapi.C CVS log [TXT] [DIR] Up to [parser3project] / parser3 / src / targets / isapi

Diff for /parser3/src/targets/isapi/parser3isapi.C between versions 1.11 and 1.69.2.2

version 1.11, 2001/03/23 13:27:56 version 1.69.2.2, 2002/05/07 07:23:11
Line 1 Line 1
   /** @file
           Parser: IIS extension.
   
           Copyright (c) 2000,2001, 2002 ArtLebedev Group (http://www.artlebedev.com)
           Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
   
           $Id$
   */
   
 #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"
 #include "pa_request.h"  #include "pa_request.h"
 #include "pa_version.h"  #include "pa_version.h"
   #include "pool_storage.h"
   #include "pa_socks.h"
   
   #include <windows.h>
   #include <process.h>
   #include <new.h>
   
   #include <httpext.h>
   
 #define MAX_STATUS_LENGTH sizeof("xxxx LONGEST STATUS DESCRIPTION")  #define MAX_STATUS_LENGTH sizeof("xxxx LONGEST STATUS DESCRIPTION")
   
 //@{  // consts
 /// SAPI funcs decl  
 struct sapi_func_context {  extern const char *main_RCSIds[];
   #ifdef USE_SMTP
   extern const char *smtp_RCSIds[];
   #endif
   extern const char *gd_RCSIds[];
   extern const char *classes_RCSIds[];
   extern const char *types_RCSIds[];
   extern const char *parser3isapi_RCSIds[];
   const char **RCSIds[]={
           main_RCSIds,
   #ifdef USE_SMTP
           smtp_RCSIds,
   #endif
           gd_RCSIds,
           classes_RCSIds,
           types_RCSIds,
           parser3isapi_RCSIds,
           0
   };
   
   // globals
   
   char argv0[MAX_STRING]="";
   
   // SAPI
   
   #ifndef DOXYGEN
   /*
           ISAPI SAPI functions receive this context information. 
           see Pool::set_context
   */
   struct SAPI_func_context {
         LPEXTENSION_CONTROL_BLOCK lpECB;          LPEXTENSION_CONTROL_BLOCK lpECB;
         String *header;          String *header;
         DWORD http_response_code;          DWORD http_response_code;
 };  };
   #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<SAPI_func_context *>(pool.get_context());
           
           va_list args;
           va_start(args,fmt);
           char buf[MAX_STRING];
           const char *prefix="PARSER_ERROR:";
           strcpy(buf, prefix);
           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, 
                   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) {  const char *SAPI::get_env(Pool& pool, const char *name) {
         sapi_func_context& ctx=*static_cast<sapi_func_context *>(pool.context());          SAPI_func_context& ctx=*static_cast<SAPI_func_context *>(pool.get_context());
   
         char *variable_buf=(char *)pool.malloc(MAX_STRING);          char *variable_buf=(char *)pool.malloc(MAX_STRING);
         DWORD variable_len = MAX_STRING-1;          DWORD variable_len = MAX_STRING-1;
Line 45  const char *SAPI::get_env(Pool& pool, co Line 119  const char *SAPI::get_env(Pool& pool, co
         return 0;          return 0;
 }  }
   
 uint SAPI::read_post(Pool& pool, char *buf, uint 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.context());          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 76  uint SAPI::read_post(Pool& pool, char *b Line 150  uint SAPI::read_post(Pool& pool, char *b
 }  }
   
 void SAPI::add_header_attribute(Pool& pool, const char *key, const char *value) {  void SAPI::add_header_attribute(Pool& pool, const char *key, const char *value) {
         sapi_func_context& ctx=*static_cast<sapi_func_context *>(pool.context());          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;
Line 87  void SAPI::add_header_attribute(Pool& po Line 161  void SAPI::add_header_attribute(Pool& po
                 ctx.header->APPEND_CONST(key);                  ctx.header->APPEND_CONST(key);
                 ctx.header->APPEND_CONST(": ");                  ctx.header->APPEND_CONST(": ");
                 ctx.header->APPEND_CONST(value);                  ctx.header->APPEND_CONST(value);
                 ctx.header->APPEND_CONST("\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(Pool& pool) {
         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\n"  
                 "\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 118  void SAPI::send_header(Pool& pool) { Line 189  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 128  void SAPI::send_header(Pool& pool) { Line 200  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 char *buf, size_t size) {  void SAPI::send_body(Pool& pool, const 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<char *>(buf), &num_bytes, HSE_IO_SYNC);                  const_cast<void *>(buf), &num_bytes, HSE_IO_SYNC);
 }  }
 //@}  
   
 //   // 
   
 static void parser_init() {  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;          static bool globals_inited=false;
         if(globals_inited)          if(globals_inited)
                 return;                  return true;
         globals_inited=true;          globals_inited=true;
   
         static Pool pool; // global pool          _set_new_handler(failed_new);
         PTRY {  
           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                  // init global variables
                 pa_globals_init(pool);                  pa_globals_init(pool);
                   
                 //...                  // successful finish
         } PCATCH(e) { // global problem                   return true;
           } catch(const Exception& e) { // global problem 
                 const char *body=e.comment();                  const char *body=e.comment();
                 // TODO: somehow report that error                  
                   // unsuccessful finish
                   return false;
         }          }
         PEND_CATCH  
 }  }
   
 /// ISAPI //  /// ISAPI //
 BOOL WINAPI GetExtensionVersion(HSE_VERSION_INFO *pVer) {  BOOL WINAPI GetExtensionVersion(HSE_VERSION_INFO *pVer) {
         pVer->dwExtensionVersion = HSE_VERSION;          pVer->dwExtensionVersion = HSE_VERSION;
         strncpy(pVer->lpszExtensionDesc, "Parser " PARSER_VERSION, HSE_MAX_EXT_DLL_NAME_LEN);          strncpy(pVer->lpszExtensionDesc, "Parser "PARSER_VERSION, HSE_MAX_EXT_DLL_NAME_LEN-1);
         return TRUE;          pVer->lpszExtensionDesc[HSE_MAX_EXT_DLL_NAME_LEN-1]=0;
           return parser_init();
 }  }
   
 /**   /** 
Line 171  BOOL WINAPI GetExtensionVersion(HSE_VERS Line 263  BOOL WINAPI GetExtensionVersion(HSE_VERS
         @todo           @todo 
                 IIS: remove trailing default-document[index.html] from $request.uri.                  IIS: remove trailing default-document[index.html] from $request.uri.
                 to do that we need to consult metabase,                  to do that we need to consult metabase,
                 wich is tested&works but seems slow.                  wich is tested&works but seems slow runtime 
                   and not could-be-quickly-implemented if prepared.
           @test
                   PARSER_VERSION from outside
 */  */
 DWORD WINAPI HttpExtensionProc(LPEXTENSION_CONTROL_BLOCK lpECB) {  
         Pool pool;  void real_parser_handler(Pool& pool, LPEXTENSION_CONTROL_BLOCK lpECB, bool header_only) {
           static_cast<SAPI_func_context *>(pool.get_context())->header=new(pool) String(pool);
                   
         bool header_only=strcasecmp(lpECB->lpszMethod, "HEAD")==0;          // Request info
         PTRY { // global try          Request::Info request_info;
                 sapi_func_context ctx={  
                         lpECB,          size_t path_translated_buf_size=strlen(lpECB->lpszPathTranslated)+1;
                         new(pool) String(pool),          char *filespec_to_process=(char *)pool.malloc(path_translated_buf_size);
                         200          memcpy(filespec_to_process, lpECB->lpszPathTranslated, path_translated_buf_size);
                 };  #ifdef WIN32
                 pool.set_context(&ctx);          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);
                                   
                 // Request info  #if _MSC_VER & !defined(_DEBUG)
                 Request::Info request_info;          } __except (
                   (system_exception=GetExceptionInformation()), 
                   EXCEPTION_EXECUTE_HANDLER) {
                                   
                 const char *filespec_to_process=lpECB->lpszPathTranslated;                  if(system_exception)
                 if(const char *path_info=SAPI::get_env(pool, "PATH_INFO")) {                          if(_EXCEPTION_RECORD *er=system_exception->ExceptionRecord)
                         // IIS                                  throw Exception(0,
                         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,                                  0,
                                 "ISAPI: no PATH_INFO defined (in reinventing DOCUMENT_ROOT)");                                  "Exception 0x%08X at 0x%08X", er->ExceptionCode,  er->ExceptionAddress);
                           else
                                   throw Exception(0, 0, "Exception <no exception record>");
                           else
                                   throw Exception(0, 0, "Exception <no exception information>");
           }
   #endif
   }
   
                 request_info.path_translated=filespec_to_process;  inline DWORD RealHttpExtensionProc(LPEXTENSION_CONTROL_BLOCK lpECB) {
                 request_info.method=lpECB->lpszMethod;          Pool_storage pool_storage;
                 request_info.query_string=lpECB->lpszQueryString;          Pool pool(&pool_storage); // no allocations until assigned context [for reporting]
                 if(lpECB->lpszQueryString && *lpECB->lpszQueryString) {          SAPI_func_context ctx={
                         char *reconstructed_uri=(char *)malloc(                  lpECB,
                                 strlen(lpECB->lpszPathInfo)+1/*'?'*/+                  0, // filling later: so that if there would be error pool would have ctx
                                 strlen(lpECB->lpszQueryString)+1/*0*/);                  200 // default http_response_code
                         strcpy(reconstructed_uri, lpECB->lpszPathInfo);          };
                         strcat(reconstructed_uri, "?");          pool.set_context(&ctx);// no allocations before this line!
                         strcat(reconstructed_uri, lpECB->lpszQueryString);  
                         request_info.uri=reconstructed_uri;          bool header_only=strcasecmp(lpECB->lpszMethod, "HEAD")==0;
                 } else          try { // global try
                         request_info.uri=lpECB->lpszPathInfo;                  call_real_parser_handler__do_SEH(pool, lpECB, header_only);
                   
                 request_info.content_type=lpECB->lpszContentType;  
                 request_info.content_length=lpECB->cbTotalBytes;  
                 request_info.cookie=SAPI::get_env(pool, "HTTP_COOKIE");  
                   
                 // prepare to process request  
                 Request request(pool,  
                         request_info,  
                         String::UL_HTML_TYPO  
                         );  
                   
                 // some root-controlled location  
                 //   c:\windows  
                 // must be dynamic: rethrowing from request.core   
                 //   may return 'source' which can be inside of 'root auto.p@exeception'  
                 char *root_auto_path=(char *)pool.malloc(MAX_STRING);  
                 GetWindowsDirectory(root_auto_path, MAX_STRING);  
   
                 // process the request  
                 request.core(  
                         root_auto_path, false/*may be abcent*/, // /path/to/admin/auto.p  
                         0/*parser_site_auto_path*/, false, // /path/to/site/auto.p  
                         header_only);  
                   
                 // successful finish                  // 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
                 const char *body=e.comment();                  const char *body=e.comment();
                 int content_length=strlen(body);                  // log it
                   SAPI::log(pool, "exception in request exception handler: %s", body);
   
                 // prepare header                  //
                 SAPI::add_header_attribute(pool, "content-type", "text/plain");                  int content_length=strlen(body);
                 char content_length_cstr[MAX_NUMBER];  
                 snprintf(content_length_cstr, MAX_NUMBER, "%lu", content_length);  
                 SAPI::add_header_attribute(pool, "content-length", content_length_cstr);  
   
                   // 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                  // send header
                 SAPI::send_header(pool);                  lpECB->dwHttpStatusCode=200;
                   lpECB->ServerSupportFunction(lpECB->ConnID, 
                           HSE_REQ_SEND_RESPONSE_HEADER_EX, &header_info, NULL, NULL);
   
                 // send body                  // send body
                 if(!header_only)                  if(!header_only)
                         SAPI::send_body(pool, body, content_length);                          SAPI::send_body(pool, body, content_length);
   
                 // unsuccessful finish                  // unsuccessful finish
                 _endthread();  
         }          }
         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();
   #endif
           
           DWORD result=RealHttpExtensionProc(lpECB);
   
 BOOL APIENTRY DllMain(HANDLE hModule,   #ifdef _DEBUG
                                           DWORD  ul_reason_for_call,       newMemState.Checkpoint();
                                           LPVOID lpReserved      if( diffMemState.Difference( oldMemState, newMemState ) )
                                           ) {      {
     switch (ul_reason_for_call) {          TRACE( "Memory leaked!\n" );
                 case DLL_PROCESS_ATTACH:                  diffMemState.DumpStatistics( );
                         parser_init();                  diffMemState.DumpAllObjectsSince();
                         break;  
                 case DLL_THREAD_ATTACH:  
                         break;  
                 case DLL_THREAD_DETACH:  
                         break;  
                 case DLL_PROCESS_DETACH:  
                         break;  
     }      }
     return TRUE;  #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;
   }
   
Removed from v.1.11  
changed lines
  Added in v.1.69.2.2

E-mail: