[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.41 and 1.58

version 1.41, 2001/09/15 14:22:47 version 1.58, 2001/11/08 11:52:34
Line 2 Line 2
         Parser: IIS extension.          Parser: IIS extension.
   
         Copyright (c) 2000,2001 ArtLebedev Group (http://www.artlebedev.com)          Copyright (c) 2000,2001 ArtLebedev Group (http://www.artlebedev.com)
           Author: Alexander Petrosyan <paf@design.ru> (http://paf.design.ru)
   
         Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf)          $Id$
 */  */
 static const char *RCSId="$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 "pa_config_includes.h"
   
 #include <windows.h>  #include <windows.h>
 #include <process.h>  #include <process.h>
   
Line 23  static const char *RCSId="$Id$"; Line 25  static const char *RCSId="$Id$";
 #include "pool_storage.h"  #include "pool_storage.h"
 #include "pa_socks.h"  #include "pa_socks.h"
   
   #ifdef XML
   #include <XalanTransformer/XalanCAPI.h>
   #endif
   
 #define MAX_STATUS_LENGTH sizeof("xxxx LONGEST STATUS DESCRIPTION")  #define MAX_STATUS_LENGTH sizeof("xxxx LONGEST STATUS DESCRIPTION")
   
   // consts
   
   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[];
   #ifdef XML
   extern const char *xalan_patched_RCSIds[];
   #endif
   const char **RCSIds[]={
           main_RCSIds,
   #ifdef USE_SMTP
           smtp_RCSIds,
   #endif
           gd_RCSIds,
           classes_RCSIds,
           types_RCSIds,
           parser3isapi_RCSIds,
   #ifdef XML
           xalan_patched_RCSIds,
   #endif
           0
   };
   
 // SAPI  // SAPI
   
 #ifndef DOXYGEN  #ifndef DOXYGEN
Line 39  struct SAPI_func_context { Line 73  struct SAPI_func_context {
 };  };
 #endif  #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].  // goes to 'cs-uri-query' log file field. webmaster: switch it ON[default OFF].
 void SAPI::log(Pool& pool, const char *fmt, ...) {  void SAPI::log(Pool& pool, const 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);
 }  }
   
   /// @todo event log
   void SAPI::die(const char *fmt, ...) {
           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 78  const char *SAPI::get_env(Pool& pool, co Line 137  const char *SAPI::get_env(Pool& pool, co
 }  }
   
 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.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 108  size_t SAPI::read_post(Pool& pool, char Line 167  size_t SAPI::read_post(Pool& pool, char
 }  }
   
 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 125  void SAPI::add_header_attribute(Pool& po Line 184  void SAPI::add_header_attribute(Pool& po
   
 /// @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(          ctx.header->APPEND_CONST(
                 "expires: Fri, 23 Mar 2001 09:32:23 GMT\r\n"                  "expires: Fri, 23 Mar 2001 09:32:23 GMT\r\n"
Line 161  void SAPI::send_header(Pool& pool) { Line 220  void SAPI::send_header(Pool& pool) {
 }  }
   
 void SAPI::send_body(Pool& pool, const void *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, 
Line 177  static bool parser_init() { Line 236  static bool parser_init() {
         globals_inited=true;          globals_inited=true;
   
         static Pool pool(0); // global pool          static Pool pool(0); // global pool
         PTRY {          try {
                 // init socks                  // init socks
                 init_socks(pool);                  init_socks(pool);
   
   #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
   
                 // init global classes                  // init global classes
                 init_methoded_array(pool);                  init_methoded_array(pool);
                 // init global variables                  // init global variables
Line 188  static bool parser_init() { Line 259  static bool parser_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 286  BOOL WINAPI GetExtensionVersion(HSE_VERS
         @test          @test
                 PARSER_VERSION from outside                  PARSER_VERSION from outside
 */  */
   
   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);
           
           // 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(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,
                   false /* 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);
   
           // 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);
   }
   
   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,
                                   0,
                                   "Exception 0x%08X at 0x%08X", er->ExceptionCode,  er->ExceptionAddress);
                           else
                                   throw Exception(0, 0, 0, "Exception <no exception record>");
                           else
                                   throw Exception(0, 0, 0, "Exception <no exception information>");
           }
   #endif
   }
   
   
 DWORD WINAPI HttpExtensionProc(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]
Line 224  DWORD WINAPI HttpExtensionProc(LPEXTENSI Line 391  DWORD WINAPI HttpExtensionProc(LPEXTENSI
                 0, // filling later: so that if there would be error pool would have ctx                  0, // filling later: so that if there would be error pool would have ctx
                 200 // default http_response_code                  200 // default http_response_code
         };          };
         _asm nop; // int 3;  
         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;  #ifdef XML
         PTRY { // global try          /**
                 ctx.header=new(pool) String(pool);           * Initialize Xerces and Xalan.
                            *
                 // Request info           * Should be called only once per process before making
                 Request::Info request_info;           * any other API calls.
            */
                 size_t path_translated_buf_size=strlen(lpECB->lpszPathTranslated)+1;          //_asm int 3;
                 char *filespec_to_process=(char *)malloc(path_translated_buf_size);          XalanInitialize();
                 memcpy(filespec_to_process, lpECB->lpszPathTranslated, path_translated_buf_size);          pool.register_cleanup(callXalanTerminate, 0);
 #ifdef WIN32  
                 back_slashes_to_slashes(filespec_to_process);  
 #endif  #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 *)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");  
   
                           bool header_only=strcasecmp(lpECB->lpszMethod, "HEAD")==0;
                 // prepare to process request          try { // global try
                 Request request(pool,                  call_real_parser_handler__do_SEH(pool, lpECB, header_only);
                         request_info,  
                         String::UL_USER_HTML  
                         );  
   
                 // 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:                  // 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
Line 329  DWORD WINAPI HttpExtensionProc(LPEXTENSI Line 448  DWORD WINAPI HttpExtensionProc(LPEXTENSI
   
                 // unsuccessful finish                  // unsuccessful finish
         }          }
         PEND_CATCH  
                   
         return HSE_STATUS_SUCCESS_AND_KEEP_CONN;          return HSE_STATUS_SUCCESS_AND_KEEP_CONN;
 }  }
Removed from v.1.41  
changed lines
  Added in v.1.58

E-mail: