Diff for /parser3/src/targets/isapi/parser3isapi.C between versions 1.65 and 1.73

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

Removed from v.1.65  
changed lines
  Added in v.1.73


E-mail: